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

Provides a transform for ordered processing. For a detailed reference implementation which uses this transform visit {@link https://github.com/GoogleCloudPlatform/dataflow-ordered-processing}

See Also:

OrderedEventProcessor

Interface Summary

Interface	Description
EventExaminer<EventT,StateT extends MutableState<EventT,?>>	Classes extending this interface will be called by OrderedEventProcessor to examine every incoming event.
MutableState<EventT,ResultT>	Mutable state mutates when events apply to it.

Class Summary

Class	Description
ContiguousSequenceRange	A range of contiguous event sequences and the latest timestamp of the events in the range.
OrderedEventProcessor<EventT,EventKeyT,ResultT,StateT extends MutableState<EventT,ResultT>>	Transform for processing ordered events.
OrderedEventProcessorResult<KeyT,ResultT,EventT>	The result of the ordered processing.
OrderedProcessingHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,ResultT>	Parent class for Ordered Processing configuration handlers.
OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,ResultT>	Parent class for Ordered Processing configuration handlers to handle processing of the events where global sequence is used.
OrderedProcessingStatus	Indicates the status of ordered processing for a particular key.
OrderedProcessingStatus.Builder
UnprocessedEvent<EventT>	Combines the source event which failed to process with the failure reason.

Enum Summary

Enum	Description
UnprocessedEvent.Reason