org.apache.beam.runners.prism

Interface PrismPipelineOptions

All Superinterfaces:

FileStagingOptions, HasDisplayData, PipelineOptions, PortablePipelineOptions

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

Method Summary

Modifier and Type	Method and Description
java.lang.String	getPrismLocation()
java.lang.String	getPrismVersionOverride()
void	setPrismLocation(java.lang.String prismLocation)
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

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)