InProcessPipelineRunner.CommittedBundle (Google Cloud Dataflow SDK 1.9.1 API)

Google Cloud Dataflow SDK for Java, version 1.9.1

Interface InProcessPipelineRunner.CommittedBundle<T>

    • Method Detail

      • getPCollection

        PCollection<T> getPCollection()
        Returns the PCollection that the elements of this bundle belong to.
      • getKey<?> 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.