org.apache.beam.runners.twister2

Interface Twister2PipelineOptions

All Superinterfaces:

ApplicationNameOptions, FileStagingOptions, HasDisplayData, PipelineOptions, StreamingOptions

public interface Twister2PipelineOptions
extends PipelineOptions, StreamingOptions, FileStagingOptions

Twister2PipelineOptions.

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	getClusterType()
java.lang.String	getJobFileZip()
java.lang.String	getJobType()
int	getParallelism()
int	getRamMegaBytes()
edu.iu.dsc.tws.tset.env.TSetEnvironment	getTSetEnvironment()
java.lang.String	getTwister2Home()
int	getWorkerCPUs()
void	setClusterType(java.lang.String name)
void	setJobFileZip(java.lang.String pathToZip)
void	setJobType(java.lang.String jobType)
void	setParallelism(int parallelism)
void	setRamMegaBytes(int ramMegaBytes)
void	setTSetEnvironment(edu.iu.dsc.tws.tset.env.TSetEnvironment environment)
void	setTwister2Home(java.lang.String twister2Home)
void	setWorkerCPUs(int workerCPUs)

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

getUpdateCompatibilityVersion, isStreaming, setStreaming, setUpdateCompatibilityVersion

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

getAppName, setAppName

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

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

getFilesToStage, setFilesToStage

Method Detail

getParallelism

@Default.Integer(value=1)
int getParallelism()

setParallelism

void setParallelism(int parallelism)

getTSetEnvironment

edu.iu.dsc.tws.tset.env.TSetEnvironment getTSetEnvironment()

setTSetEnvironment

void setTSetEnvironment(edu.iu.dsc.tws.tset.env.TSetEnvironment environment)

getClusterType

@Default.String(value="standalone")
java.lang.String getClusterType()

setClusterType

void setClusterType(java.lang.String name)

getJobFileZip

java.lang.String getJobFileZip()

setJobFileZip

void setJobFileZip(java.lang.String pathToZip)

getJobType

@Default.String(value="java_zip")
java.lang.String getJobType()

setJobType

void setJobType(java.lang.String jobType)

getTwister2Home

java.lang.String getTwister2Home()

setTwister2Home

void setTwister2Home(java.lang.String twister2Home)

getWorkerCPUs

@Default.Integer(value=2)
int getWorkerCPUs()

setWorkerCPUs

void setWorkerCPUs(int workerCPUs)

getRamMegaBytes

@Default.Integer(value=2048)
int getRamMegaBytes()

setRamMegaBytes

void setRamMegaBytes(int ramMegaBytes)