org.apache.beam.runners.jet

Interface JetPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface JetPipelineOptions
extends PipelineOptions

Pipeline options specific to the Jet runner.

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	getClusterName()
java.lang.String	getCodeJarPathname()
java.lang.Integer	getJetDefaultParallelism()
java.lang.Integer	getJetLocalMode()
java.lang.Boolean	getJetProcessorsCooperative()
java.lang.String	getJetServers()
void	setClusterName(java.lang.String clusterName)
void	setCodeJarPathname(java.lang.String codeJarPathname)
void	setJetDefaultParallelism(java.lang.Integer localParallelism)
void	setJetLocalMode(java.lang.Integer noOfLocalClusterMembers)
void	setJetProcessorsCooperative(java.lang.Boolean cooperative)
void	setJetServers(java.lang.String jetServers)

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

getClusterName

@Validation.Required
 @Default.String(value="jet")
java.lang.String getClusterName()

setClusterName

void setClusterName(java.lang.String clusterName)

getJetServers

@Validation.Required
 @Default.String(value="127.0.0.1:5701")
java.lang.String getJetServers()

setJetServers

void setJetServers(java.lang.String jetServers)

getCodeJarPathname

java.lang.String getCodeJarPathname()

setCodeJarPathname

void setCodeJarPathname(java.lang.String codeJarPathname)

getJetDefaultParallelism

@Validation.Required
 @Default.Integer(value=2)
java.lang.Integer getJetDefaultParallelism()

setJetDefaultParallelism

void setJetDefaultParallelism(java.lang.Integer localParallelism)

getJetLocalMode

@Validation.Required
 @Default.Integer(value=0)
java.lang.Integer getJetLocalMode()

setJetLocalMode

void setJetLocalMode(java.lang.Integer noOfLocalClusterMembers)

getJetProcessorsCooperative

@Validation.Required
 @Default.Boolean(value=false)
java.lang.Boolean getJetProcessorsCooperative()

setJetProcessorsCooperative

void setJetProcessorsCooperative(java.lang.Boolean cooperative)