public interface GearpumpPipelineOptions extends PipelineOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled, PipelineOptions.DirectRunner, PipelineOptions.JobNameFactory, PipelineOptions.UserAgentFactory
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) |
as, getJobName, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, getUserAgent, outputRuntimeOptions, setJobName, setOptionsId, setRunner, setStableUniqueNames, setTempLocation, setUserAgent
populateDisplayData
void setApplicationName(java.lang.String name)
java.lang.String getApplicationName()
void setParallelism(int parallelism)
@Default.Integer(value=1) int getParallelism()
void setSerializers(java.util.Map<java.lang.String,java.lang.String> serializers)
java.util.Map<java.lang.String,java.lang.String> getSerializers()
void setRemote(java.lang.Boolean remote)
@Default.Boolean(value=false) java.lang.Boolean getRemote()
void setClientContext(io.gearpump.cluster.client.ClientContext clientContext)
io.gearpump.cluster.client.ClientContext getClientContext()