org.apache.beam.runners.prism

Interface PrismPipelineOptions

All Superinterfaces:

FileStagingOptions, HasDisplayData, PipelineOptions, PortablePipelineOptions

All Known Subinterfaces:

TestPrismPipelineOptions

public interface PrismPipelineOptions
extends PortablePipelineOptions

PipelineOptions for running a Pipeline on the PrismRunner.

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	JOB_PORT_FLAG_NAME

Method Summary

Modifier and Type	Method and Description
java.lang.Boolean	getEnableWebUI()
java.lang.String	getIdleShutdownTimeout()
java.lang.String	getPrismLocation()
java.lang.String	getPrismLogLevel()
java.lang.String	getPrismVersionOverride()
void	setEnableWebUI(java.lang.Boolean enableWebUI)
void	setIdleShutdownTimeout(java.lang.String idleShutdownTimeout)
void	setPrismLocation(java.lang.String prismLocation)
void	setPrismLogLevel(java.lang.String prismLogLevel)
void	setPrismVersionOverride(java.lang.String prismVersionOverride)

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

getDefaultEnvironmentConfig, getDefaultEnvironmentType, getEnableHeapDumps, getEnvironmentCacheMillis, getEnvironmentExpirationMillis, getEnvironmentOption, getEnvironmentOptions, getJobEndpoint, getJobServerTimeout, getLoadBalanceBundles, getOutputExecutablePath, getSdkWorkerParallelism, setDefaultEnvironmentConfig, setDefaultEnvironmentType, setEnableHeapDumps, setEnvironmentCacheMillis, setEnvironmentExpirationMillis, setEnvironmentOptions, setJobEndpoint, setJobServerTimeout, setLoadBalanceBundles, setOutputExecutablePath, setSdkWorkerParallelism

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

getFilesToStage, setFilesToStage

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

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

populateDisplayData

Field Detail

JOB_PORT_FLAG_NAME

static final java.lang.String JOB_PORT_FLAG_NAME

See Also:

Constant Field Values

Method Detail

getPrismLocation

java.lang.String getPrismLocation()

setPrismLocation

void setPrismLocation(java.lang.String prismLocation)

getPrismVersionOverride

java.lang.String getPrismVersionOverride()

setPrismVersionOverride

void setPrismVersionOverride(java.lang.String prismVersionOverride)

getEnableWebUI

@Default.Boolean(value=true)
java.lang.Boolean getEnableWebUI()

setEnableWebUI

void setEnableWebUI(java.lang.Boolean enableWebUI)

getIdleShutdownTimeout

@Default.String(value="5m")
java.lang.String getIdleShutdownTimeout()

setIdleShutdownTimeout

void setIdleShutdownTimeout(java.lang.String idleShutdownTimeout)

getPrismLogLevel

@Default.String(value="warn")
java.lang.String getPrismLogLevel()

setPrismLogLevel

void setPrismLogLevel(java.lang.String prismLogLevel)