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.NoOpMetricsSink, PipelineOptions.UserAgentFactory

Method Summary

Modifier and Type	Method and Description
java.lang.String	getApplicationName()
org.apache.gearpump.cluster.client.ClientContext	getClientContext()
org.apache.gearpump.cluster.embedded.EmbeddedCluster	getEmbeddedCluster()
int	getParallelism()
java.util.Map<java.lang.String,java.lang.String>	getSerializers()
void	setApplicationName(java.lang.String name)
void	setClientContext(org.apache.gearpump.cluster.client.ClientContext clientContext)
void	setEmbeddedCluster(org.apache.gearpump.cluster.embedded.EmbeddedCluster cluster)
void	setParallelism(int parallelism)
void	setSerializers(java.util.Map<java.lang.String,java.lang.String> serializers)

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

as, getJobName, getMetricsHttpSinkUrl, getMetricsPushPeriod, getMetricsSink, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setMetricsHttpSinkUrl, setMetricsPushPeriod, setMetricsSink, 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()

setEmbeddedCluster

void setEmbeddedCluster(org.apache.gearpump.cluster.embedded.EmbeddedCluster cluster)

getEmbeddedCluster

org.apache.gearpump.cluster.embedded.EmbeddedCluster getEmbeddedCluster()

setClientContext

void setClientContext(org.apache.gearpump.cluster.client.ClientContext clientContext)

getClientContext

org.apache.gearpump.cluster.client.ClientContext getClientContext()