DirectOptions (Apache Beam 2.67.0)

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

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, PipelineOptions.UserAgentFactory
Method Summary

Modifier and Type

Method

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.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
- isBlockOnRun
  
  @Boolean(true) boolean isBlockOnRun()
- setBlockOnRun
  
  void setBlockOnRun(boolean b)
- isEnforceImmutability
  
  @Boolean(true) boolean isEnforceImmutability()
- setEnforceImmutability
  
  void setEnforceImmutability(boolean test)
- isEnforceEncodability
  
  @Boolean(true) boolean isEnforceEncodability()
- setEnforceEncodability
  
  void setEnforceEncodability(boolean test)
- getTargetParallelism
  
  @InstanceFactory(AvailableParallelismFactory.class) int getTargetParallelism()
- setTargetParallelism
  
  void setTargetParallelism(int target)