Package org.apache.beam.runners.local

Interface Bundle<T,CollectionT>

All Superinterfaces:
Iterable<WindowedValue<T>>
public interface Bundle<T,CollectionT> extends Iterable<WindowedValue<T>>
An immutable collection of elements which are part of a PCollection.

  • Method Details

    • getPCollection

      @Nullable CollectionT getPCollection()
      Returns the PCollection that the elements of this bundle belong to.

    • getKey

      StructuralKey<?> getKey()
      Returns the key that was output in the most recent GroupByKey in the execution of this bundle.

    • getMinimumTimestamp

      Instant getMinimumTimestamp()
      Return the minimum timestamp among elements in this bundle.

      This should be equivalent to iterating over all of the elements within a bundle and selecting the minimum timestamp from among them.

    • getSynchronizedProcessingOutputWatermark

      Instant getSynchronizedProcessingOutputWatermark()
      Returns the processing time output watermark at the time the producing Executable 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 at the time this bundle was committed, including any timers that fired to produce this bundle.