Package org.apache.beam.sdk.extensions.ordered.combiner

Default implementation of the global sequence combiner used by OrderedEventProcessor when processing events using global sequences.

See: Description

Class Summary

Class	Description
DefaultSequenceCombiner<EventKeyT,EventT,StateT extends MutableState<EventT,?>>	Default global sequence combiner.
SequenceRangeAccumulator	Default accumulator used to combine sequence ranges.
SequenceRangeAccumulator.SequenceRangeAccumulatorCoder

Package org.apache.beam.sdk.extensions.ordered.combiner Description

Default implementation of the global sequence combiner used by OrderedEventProcessor when processing events using global sequences.