InProcessPipelineRunner.UncommittedBundle (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. See Migrating from Dataflow SDK 1.x for Java for migration guidance.

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

Interface InProcessPipelineRunner.UncommittedBundle<T>

• Type Parameters:

  T - the type of elements that can be added to this bundle

  Enclosing class:

  InProcessPipelineRunner

  ---

  
  

  public static interface InProcessPipelineRunner.UncommittedBundle<T>

  Part of a PCollection. Elements are output to a bundle, which will cause them to be executed by PTransforms that consume the PCollection this bundle is a part of at a later point. This is an uncommitted bundle and can have elements added to it.

• • Method Summary

    All Methods Instance Methods Abstract Methods 

    Modifier and Type	Method and Description
    InProcessPipelineRunner.UncommittedBundle<T>	add(com.google.cloud.dataflow.sdk.util.WindowedValue<T> element) Outputs an element to this bundle.
    InProcessPipelineRunner.CommittedBundle<T>	commit(Instant synchronizedProcessingTime) Commits this InProcessPipelineRunner.UncommittedBundle, returning an immutable InProcessPipelineRunner.CommittedBundle containing all of the elements that were added to it.
    PCollection<T>	getPCollection() Returns the PCollection that the elements of this InProcessPipelineRunner.UncommittedBundle belong to.

• • Method Detail

    • getPCollection

      PCollection<T> getPCollection()

      Returns the PCollection that the elements of this InProcessPipelineRunner.UncommittedBundle belong to.

    • add

      InProcessPipelineRunner.UncommittedBundle<T> add(com.google.cloud.dataflow.sdk.util.WindowedValue<T> element)

      Outputs an element to this bundle.

      Parameters:

      element - the element to add to this bundle

      Returns:

      this bundle

    • commit

      InProcessPipelineRunner.CommittedBundle<T> commit(Instant synchronizedProcessingTime)

      Commits this InProcessPipelineRunner.UncommittedBundle, returning an immutable InProcessPipelineRunner.CommittedBundle containing all of the elements that were added to it. The add(WindowedValue) method will throw an IllegalStateException if called after a call to commit.

      Parameters:

      synchronizedProcessingTime - the synchronized processing time at which this bundle was committed