Package 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	Description
static final String	JOB_PORT_FLAG_NAME

Method Summary

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

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

getFilesToStage, setFilesToStage

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

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

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

Field Details

JOB_PORT_FLAG_NAME

static final String JOB_PORT_FLAG_NAME

See Also:

• Constant Field Values

Method Details

getPrismLocation

String getPrismLocation()

setPrismLocation

void setPrismLocation(String prismLocation)

getPrismVersionOverride

String getPrismVersionOverride()

setPrismVersionOverride

void setPrismVersionOverride(String prismVersionOverride)

getEnableWebUI

@Boolean(true)
Boolean getEnableWebUI()

setEnableWebUI

void setEnableWebUI(Boolean enableWebUI)

getIdleShutdownTimeout

@String("5m")
String getIdleShutdownTimeout()

setIdleShutdownTimeout

void setIdleShutdownTimeout(String idleShutdownTimeout)

getPrismLogLevel

@String("warn")
String getPrismLogLevel()

setPrismLogLevel

void setPrismLogLevel(String prismLogLevel)