Package org.apache.beam.runners.jet

Interface JetPipelineOptions

All Superinterfaces:

org.apache.beam.sdk.transforms.display.HasDisplayData, org.apache.beam.sdk.options.PipelineOptions

public interface JetPipelineOptions
extends org.apache.beam.sdk.options.PipelineOptions

Pipeline options specific to the Jet runner.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.options.PipelineOptions

org.apache.beam.sdk.options.PipelineOptions.AtomicLongFactory, org.apache.beam.sdk.options.PipelineOptions.CheckEnabled, org.apache.beam.sdk.options.PipelineOptions.DirectRunner, org.apache.beam.sdk.options.PipelineOptions.JobNameFactory, org.apache.beam.sdk.options.PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method	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.transforms.display.HasDisplayData

populateDisplayData

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

as, getGbek, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, revision, setGbek, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent

Method Detail

getClusterName

@Required
@String("jet")
java.lang.String getClusterName()

setClusterName

void setClusterName(java.lang.String clusterName)

getJetServers

@Required
@String("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

@Required
@Integer(2)
java.lang.Integer getJetDefaultParallelism()

setJetDefaultParallelism

void setJetDefaultParallelism(java.lang.Integer localParallelism)

getJetLocalMode

@Required
@Integer(0)
java.lang.Integer getJetLocalMode()

setJetLocalMode

void setJetLocalMode(java.lang.Integer noOfLocalClusterMembers)

getJetProcessorsCooperative

@Required
@Boolean(false)
java.lang.Boolean getJetProcessorsCooperative()

setJetProcessorsCooperative

void setJetProcessorsCooperative(java.lang.Boolean cooperative)