Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.runners.inprocess
Interface InProcessPipelineOptions
-
- All Superinterfaces:
- ApplicationNameOptions, HasDisplayData, PipelineOptions
public interface InProcessPipelineOptions extends PipelineOptions, ApplicationNameOptions
Options that can be used to configure theInProcessPipelineRunner
.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions
PipelineOptions.AtomicLongFactory, PipelineOptions.CheckEnabled
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method and Description Clock
getClock()
Deprecated.the runner manages its ownClock
as an implementation detailExecutorServiceFactory
getExecutorServiceFactory()
Deprecated.the runner manages its ownExecutorService
as an implementation detailboolean
isBlockOnRun()
boolean
isShutdownUnboundedProducersWithMaxWatermark()
boolean
isTestImmutability()
void
setBlockOnRun(boolean b)
void
setClock(Clock clock)
void
setExecutorServiceFactory(ExecutorServiceFactory executorService)
void
setShutdownUnboundedProducersWithMaxWatermark(boolean shutdown)
void
setTestImmutability(boolean test)
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.ApplicationNameOptions
getAppName, setAppName
-
Methods inherited from interface com.google.cloud.dataflow.sdk.options.PipelineOptions
as, cloneAs, getOptionsId, getRunner, getStableUniqueNames, getTempLocation, outputRuntimeOptions, setOptionsId, setRunner, setStableUniqueNames, setTempLocation
-
Methods inherited from interface com.google.cloud.dataflow.sdk.transforms.display.HasDisplayData
populateDisplayData
-
-
-
-
Method Detail
-
getExecutorServiceFactory
@Deprecated @Hidden ExecutorServiceFactory getExecutorServiceFactory()
Deprecated. the runner manages its ownExecutorService
as an implementation detailGets theExecutorServiceFactory
to use to create instances ofExecutorService
to executePTransforms
.Defaults to a
FixedThreadPoolExecutorServiceFactory
, which produces instances ofExecutors.newCachedThreadPool()
.
-
setExecutorServiceFactory
void setExecutorServiceFactory(ExecutorServiceFactory executorService)
-
getClock
@Deprecated @Hidden Clock getClock()
Deprecated. the runner manages its ownClock
as an implementation detailGets theClock
used by this pipeline. The clock is used in place of accessing the system time when time values are required by the evaluator.
-
setClock
void setClock(Clock clock)
-
isShutdownUnboundedProducersWithMaxWatermark
@Default.Boolean(value=false) boolean isShutdownUnboundedProducersWithMaxWatermark()
-
setShutdownUnboundedProducersWithMaxWatermark
void setShutdownUnboundedProducersWithMaxWatermark(boolean shutdown)
-
isBlockOnRun
@Default.Boolean(value=true) boolean isBlockOnRun()
-
setBlockOnRun
void setBlockOnRun(boolean b)
-
isTestImmutability
@Default.Boolean(value=true) boolean isTestImmutability()
-
setTestImmutability
void setTestImmutability(boolean test)
-
-