Package org.apache.beam.runners.direct

Interface DirectTestOptions

All Superinterfaces:

ApplicationNameOptions, HasDisplayData, PipelineOptions

@Hidden
public interface DirectTestOptions
extends PipelineOptions, ApplicationNameOptions

Internal-only options for tweaking the behavior of the PipelineOptions.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.UserAgentFactory

Method Summary

Modifier and Type	Method	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.transforms.display.HasDisplayData

populateDisplayData

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

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

Method Details

isRunnerDeterminedSharding

@Boolean(true)
boolean isRunnerDeterminedSharding()

setRunnerDeterminedSharding

void setRunnerDeterminedSharding(boolean goAheadAndDetermineSharding)