org.apache.beam.runners.gearpump

Interface GearpumpPipelineOptions

All Superinterfaces:

HasDisplayData, PipelineOptions

public interface GearpumpPipelineOptions
extends PipelineOptions

Options that configure the Gearpump pipeline.

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	getApplicationName()
io.gearpump.cluster.client.ClientContext	getClientContext()
int	getParallelism()
java.lang.Boolean	getRemote()
java.util.Map<java.lang.String,java.lang.String>	getSerializers()
void	setApplicationName(java.lang.String name)
void	setClientContext(io.gearpump.cluster.client.ClientContext clientContext)
void	setParallelism(int parallelism)
void	setRemote(java.lang.Boolean remote)
void	setSerializers(java.util.Map<java.lang.String,java.lang.String> serializers)

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

setApplicationName

void setApplicationName(java.lang.String name)

getApplicationName

java.lang.String getApplicationName()

setParallelism

void setParallelism(int parallelism)

getParallelism

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

setSerializers

void setSerializers(java.util.Map<java.lang.String,java.lang.String> serializers)

getSerializers

java.util.Map<java.lang.String,java.lang.String> getSerializers()

setRemote

void setRemote(java.lang.Boolean remote)

getRemote

@Default.Boolean(value=false)
java.lang.Boolean getRemote()

setClientContext

void setClientContext(io.gearpump.cluster.client.ClientContext clientContext)

getClientContext

io.gearpump.cluster.client.ClientContext getClientContext()