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, getMetricsGraphiteHost, getMetricsGraphitePort, getMetricsHttpSinkUrl, getMetricsPushPeriod, getMetricsSink, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setMetricsGraphiteHost, setMetricsGraphitePort, 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()