Package org.apache.beam.sdk.options
Interface ExperimentalOptions
-
- All Superinterfaces:
HasDisplayData
,PipelineOptions
@Experimental 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
-
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
STATE_CACHE_SIZE
static java.lang.String
STATE_SAMPLING_PERIOD_MILLIS
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description static void
addExperiment(ExperimentalOptions options, java.lang.String experiment)
Adds experiment to options if not already present.@Nullable java.util.List<java.lang.String>
getExperiments()
static java.lang.String
getExperimentValue(PipelineOptions options, java.lang.String experiment)
Return the value for the specified experiment or null if not present.static boolean
hasExperiment(PipelineOptions options, java.lang.String experiment)
Returns true iff the provided pipeline options has the specified experiment enabled.void
setExperiments(@Nullable java.util.List<java.lang.String> value)
-
Methods inherited from interface org.apache.beam.sdk.transforms.display.HasDisplayData
populateDisplayData
-
Methods inherited from interface org.apache.beam.sdk.options.PipelineOptions
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
-
-
-
-
Field Detail
-
STATE_CACHE_SIZE
static final java.lang.String STATE_CACHE_SIZE
- See Also:
- Constant Field Values
-
STATE_SAMPLING_PERIOD_MILLIS
static final java.lang.String STATE_SAMPLING_PERIOD_MILLIS
- See Also:
- Constant Field Values
-
-
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.
-
getExperimentValue
static java.lang.String getExperimentValue(PipelineOptions options, java.lang.String experiment)
Return the value for the specified experiment or null if not present.
-
-