StepTransformResult.Builder (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Warning: Dataflow SDK 1.x for Java is unsupported as of October 16, 2018. After August 12, 2020, you can use unsupported SDKs temporarily while you upgrade your pipelines. For more information, see Using an unsupported SDK.

For information on migrating from the 1.x SDK, see Migrating from Dataflow SDK 1.x for Java.

Note: If you are using Cloud Dataflow SDK version 2.x, see the Apache Beam API reference documentation.

com.google.cloud.dataflow.sdk.runners.inprocess

Class StepTransformResult.Builder

• java.lang.Object
• • com.google.cloud.dataflow.sdk.runners.inprocess.StepTransformResult.Builder

• Enclosing class:

  StepTransformResult

  ---

  
  

  public static class StepTransformResult.Builder
  extends Object

  A builder for creating instances of StepTransformResult.

• • Method Summary

    All Methods Instance Methods Concrete Methods 

    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)

    • Methods inherited from class java.lang.Object

      clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

• • Method Detail

    • build

      public StepTransformResult build()

    • withCounters

      public StepTransformResult.Builder withCounters(com.google.cloud.dataflow.sdk.util.common.CounterSet counters)

    • withState

      public StepTransformResult.Builder withState(com.google.cloud.dataflow.sdk.util.state.CopyOnAccessInMemoryStateInternals<?> state)

    • withTimerUpdate

      public StepTransformResult.Builder withTimerUpdate(InMemoryWatermarkManager.TimerUpdate timerUpdate)

    • addUnprocessedElements

      public StepTransformResult.Builder addUnprocessedElements(Iterable<? extends com.google.cloud.dataflow.sdk.util.WindowedValue<?>> unprocessed)

    • addOutput

      public StepTransformResult.Builder addOutput(InProcessPipelineRunner.UncommittedBundle<?> outputBundle,
                                                   InProcessPipelineRunner.UncommittedBundle<?>... outputBundles)

    • addOutput

      public StepTransformResult.Builder addOutput(Collection<InProcessPipelineRunner.UncommittedBundle<?>> outputBundles)

    • withAdditionalOutput

      public StepTransformResult.Builder withAdditionalOutput(com.google.cloud.dataflow.sdk.runners.inprocess.CommittedResult.OutputType producedAdditionalOutput)