org.apache.beam.runners.direct

Interface DirectOptions

All Superinterfaces:

ApplicationNameOptions, HasDisplayData, PipelineOptions

public interface DirectOptions
extends PipelineOptions, ApplicationNameOptions

Options that can be used to configure the DirectRunner.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	DirectOptions.AvailableParallelismFactory A DefaultValueFactory that returns the result of Runtime.availableProcessors() from the DirectOptions.AvailableParallelismFactory.create(PipelineOptions) method.

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

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

Method Summary

Modifier and Type	Method and Description
int	getTargetParallelism()
boolean	isBlockOnRun()
boolean	isEnforceEncodability()
boolean	isEnforceImmutability()
void	setBlockOnRun(boolean b)
void	setEnforceEncodability(boolean test)
void	setEnforceImmutability(boolean test)
void	setTargetParallelism(int target)

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

getAppName, setAppName

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

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

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

populateDisplayData

Method Detail

isBlockOnRun

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

setBlockOnRun

void setBlockOnRun(boolean b)

isEnforceImmutability

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

setEnforceImmutability

void setEnforceImmutability(boolean test)

isEnforceEncodability

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

setEnforceEncodability

void setEnforceEncodability(boolean test)

getTargetParallelism

@Default.InstanceFactory(value=DirectOptions.AvailableParallelismFactory.class)
int getTargetParallelism()

setTargetParallelism

void setTargetParallelism(int target)