org.apache.beam.sdk.options

Interface ExperimentalOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

All Known Subinterfaces:

DataflowPipelineDebugOptions, DataflowPipelineOptions, DataflowWorkerHarnessOptions, TestDataflowPipelineOptions

@Experimental
 @Hidden
public interface ExperimentalOptions
extends PipelineOptions

Apache Beam provides a number of experimental features that can be enabled with this flag. If executing against a managed service, please contact the service owners before enabling any experiments.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
static void	addExperiment(ExperimentalOptions options, java.lang.String experiment) Adds experiment to options if not already present.
java.util.List<java.lang.String>	getExperiments()
static boolean	hasExperiment(PipelineOptions options, java.lang.String experiment) Returns true iff the provided pipeline options has the specified experiment enabled.
void	setExperiments(java.util.List<java.lang.String> value)

Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions

as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData

populateDisplayData

Method Detail

getExperiments

@Nullable
java.util.List<java.lang.String> getExperiments()

setExperiments

void setExperiments(@Nullable
                    java.util.List<java.lang.String> value)

hasExperiment

static boolean hasExperiment(PipelineOptions options,
                             java.lang.String experiment)

Returns true iff the provided pipeline options has the specified experiment enabled.

addExperiment

static void addExperiment(ExperimentalOptions options,
                          java.lang.String experiment)

Adds experiment to options if not already present.