Package org.apache.beam.sdk.extensions.ordered.combiner
Default implementation of the global sequence combiner used by
OrderedEventProcessor when processing events using global
sequences.-
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