org.apache.beam.runners.apex

Interface ApexPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions, java.io.Serializable

public interface ApexPipelineOptions
extends PipelineOptions, java.io.Serializable

Options that configure the Apex pipeline.

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 and Description
java.lang.String	getApplicationName()
java.lang.String	getConfigFile()
long	getRunMillis()
boolean	isEmbeddedExecution()
boolean	isEmbeddedExecutionDebugMode()
boolean	isParDoFusionEnabled()
boolean	isTupleTracingEnabled()
void	setApplicationName(java.lang.String name)
void	setConfigFile(java.lang.String name)
void	setEmbeddedExecution(boolean embedded)
void	setEmbeddedExecutionDebugMode(boolean embeddedDebug)
void	setParDoFusionEnabled(boolean enabled)
void	setRunMillis(long runMillis)
void	setTupleTracingEnabled(boolean enabled)

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

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

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

populateDisplayData

Method Detail

setApplicationName

void setApplicationName(java.lang.String name)

getApplicationName

java.lang.String getApplicationName()

setEmbeddedExecution

void setEmbeddedExecution(boolean embedded)

isEmbeddedExecution

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

setEmbeddedExecutionDebugMode

void setEmbeddedExecutionDebugMode(boolean embeddedDebug)

isEmbeddedExecutionDebugMode

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

setTupleTracingEnabled

void setTupleTracingEnabled(boolean enabled)

isTupleTracingEnabled

@Default.Boolean(value=false)
boolean isTupleTracingEnabled()

setRunMillis

void setRunMillis(long runMillis)

getRunMillis

@Default.Long(value=0L)
long getRunMillis()

setConfigFile

void setConfigFile(java.lang.String name)

getConfigFile

@Default.String(value="classpath:/beam-runners-apex.properties")
java.lang.String getConfigFile()

setParDoFusionEnabled

void setParDoFusionEnabled(boolean enabled)

isParDoFusionEnabled

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