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	getCodeJarPathname()
java.lang.Integer	getJetDefaultParallelism()
java.lang.String	getJetGroupName()
java.lang.Integer	getJetLocalMode()
java.lang.Boolean	getJetProcessorsCooperative()
java.lang.String	getJetServers()
void	setCodeJarPathname(java.lang.String codeJarPathname)
void	setJetDefaultParallelism(java.lang.Integer localParallelism)
void	setJetGroupName(java.lang.String jetGroupName)
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, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

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

populateDisplayData

Method Detail

getJetGroupName

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

setJetGroupName

void setJetGroupName(java.lang.String jetGroupName)

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)