public static class StepTransformResult.Builder extends Object
StepTransformResult.| Modifier and Type | Method and Description |
|---|---|
StepTransformResult.Builder |
addOutput(Collection<InProcessPipelineRunner.UncommittedBundle<?>> outputBundles) |
StepTransformResult.Builder |
addOutput(InProcessPipelineRunner.UncommittedBundle<?> outputBundle,
InProcessPipelineRunner.UncommittedBundle<?>... outputBundles) |
StepTransformResult.Builder |
addUnprocessedElements(Iterable<? extends com.google.cloud.dataflow.sdk.util.WindowedValue<?>> unprocessed) |
StepTransformResult |
build() |
StepTransformResult.Builder |
withAdditionalOutput(com.google.cloud.dataflow.sdk.runners.inprocess.CommittedResult.OutputType producedAdditionalOutput) |
StepTransformResult.Builder |
withCounters(com.google.cloud.dataflow.sdk.util.common.CounterSet counters) |
StepTransformResult.Builder |
withState(com.google.cloud.dataflow.sdk.util.state.CopyOnAccessInMemoryStateInternals<?> state) |
StepTransformResult.Builder |
withTimerUpdate(InMemoryWatermarkManager.TimerUpdate timerUpdate) |
public StepTransformResult build()
public StepTransformResult.Builder withCounters(com.google.cloud.dataflow.sdk.util.common.CounterSet counters)
public StepTransformResult.Builder withState(com.google.cloud.dataflow.sdk.util.state.CopyOnAccessInMemoryStateInternals<?> state)
public StepTransformResult.Builder withTimerUpdate(InMemoryWatermarkManager.TimerUpdate timerUpdate)
public StepTransformResult.Builder addUnprocessedElements(Iterable<? extends com.google.cloud.dataflow.sdk.util.WindowedValue<?>> unprocessed)
public StepTransformResult.Builder addOutput(InProcessPipelineRunner.UncommittedBundle<?> outputBundle, InProcessPipelineRunner.UncommittedBundle<?>... outputBundles)
public StepTransformResult.Builder addOutput(Collection<InProcessPipelineRunner.UncommittedBundle<?>> outputBundles)
public StepTransformResult.Builder withAdditionalOutput(com.google.cloud.dataflow.sdk.runners.inprocess.CommittedResult.OutputType producedAdditionalOutput)