InProcessPipelineRunner.CommittedBundle (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

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

Interface InProcessPipelineRunner.CommittedBundle<T>

    • Method Detail

      • getPCollection

        PCollection<T> getPCollection()
        Returns the PCollection that the elements of this bundle belong to.
      • getKey

        com.google.cloud.dataflow.sdk.runners.inprocess.StructuralKey<?> getKey()
        Returns the key that was output in the most recent GroupByKey in the execution of this bundle.
      • getSynchronizedProcessingOutputWatermark

        Instant getSynchronizedProcessingOutputWatermark()
        Returns the processing time output watermark at the time the producing PTransform committed this bundle. Downstream synchronized processing time watermarks cannot progress past this point before consuming this bundle.

        This value is no greater than the earliest incomplete processing time or synchronized processing time timer at the time this bundle was committed, including any timers that fired to produce this bundle.


Was this page helpful? Let us know how we did:

Send feedback about...

Cloud Dataflow
Need help? Visit our support page.