org.apache.beam.runners.local

Interface Bundle<T,CollectionT>

All Superinterfaces:

java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>

public interface Bundle<T,CollectionT>
extends java.lang.Iterable<org.apache.beam.sdk.util.WindowedValue<T>>

An immutable collection of elements which are part of a PCollection.

Method Summary

Modifier and Type	Method and Description
StructuralKey<?>	getKey() Returns the key that was output in the most recent GroupByKey in the execution of this bundle.
Instant	getMinimumTimestamp() Return the minimum timestamp among elements in this bundle.
CollectionT	getPCollection() Returns the PCollection that the elements of this bundle belong to.
Instant	getSynchronizedProcessingOutputWatermark() Returns the processing time output watermark at the time the producing Executable committed this bundle.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

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.