JetPipelineOptions (Apache Beam 2.69.0)

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

Description

String

getClusterName()

String

getCodeJarPathname()

Integer

getJetDefaultParallelism()

Integer

getJetLocalMode()

Boolean

getJetProcessorsCooperative()

String

getJetServers()

void

setClusterName(String clusterName)

void

setCodeJarPathname(String codeJarPathname)

void

setJetDefaultParallelism(Integer localParallelism)

void

setJetLocalMode(Integer noOfLocalClusterMembers)

void

setJetProcessorsCooperative(Boolean cooperative)

void

setJetServers(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 Details
- getClusterName
  
  @Required @String("jet") String getClusterName()
- setClusterName
  
  void setClusterName(String clusterName)
- getJetServers
  
  @Required @String("127.0.0.1:5701") String getJetServers()
- setJetServers
  
  void setJetServers(String jetServers)
- getCodeJarPathname
  
  String getCodeJarPathname()
- setCodeJarPathname
  
  void setCodeJarPathname(String codeJarPathname)
- getJetDefaultParallelism
  
  @Required @Integer(2) Integer getJetDefaultParallelism()
- setJetDefaultParallelism
  
  void setJetDefaultParallelism(Integer localParallelism)
- getJetLocalMode
  
  @Required @Integer(0) Integer getJetLocalMode()
- setJetLocalMode
  
  void setJetLocalMode(Integer noOfLocalClusterMembers)
- getJetProcessorsCooperative
  
  @Required @Boolean(false) Boolean getJetProcessorsCooperative()
- setJetProcessorsCooperative
  
  void setJetProcessorsCooperative(Boolean cooperative)