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

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

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

Related Packages

Package	Description
org.apache.beam.sdk.extensions.ordered	Provides a transform for ordered processing.

Classes

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