org.apache.beam.runners.direct

Interface DirectTestOptions

All Superinterfaces:

ApplicationNameOptions, HasDisplayData, PipelineOptions

@Internal
 @Hidden
public interface DirectTestOptions
extends PipelineOptions, ApplicationNameOptions

Internal-only options for tweaking the behavior of the DirectRunner in ways that users should never do.

Currently, the only use is to disable user-friendly overrides that prevent fully testing certain composite transforms.

Nested Class Summary

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

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

Method Summary

Modifier and Type	Method and Description
boolean	isRunnerDeterminedSharding()
void	setRunnerDeterminedSharding(boolean goAheadAndDetermineSharding)

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

getAppName, setAppName

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

as, getJobName, getMetricsHttpSinkUrl, getMetricsPushPeriod, getMetricsSink, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setMetricsHttpSinkUrl, setMetricsPushPeriod, setMetricsSink, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

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

populateDisplayData

Method Detail

isRunnerDeterminedSharding

@Default.Boolean(value=true)
boolean isRunnerDeterminedSharding()

setRunnerDeterminedSharding

void setRunnerDeterminedSharding(boolean goAheadAndDetermineSharding)