org.apache.beam.runners.local

Interface Bundle<T>

All Superinterfaces:

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

public interface Bundle<T>
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
Instant	getMinimumTimestamp() Return the minimum timestamp among elements in this bundle.

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Method Detail

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.