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

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

Provides a transform for ordered processing. For a detailed reference implementation which uses this transform visit invalid input: '{@link <a href="">https://github.com/GoogleCloudPlatform/dataflow-ordered-processing</a>'}

See Also:

• OrderedEventProcessor

Related Packages

Package	Description
org.apache.beam.sdk.extensions.ordered.combiner	Default implementation of the global sequence combiner used by OrderedEventProcessor when processing events using global sequences.

Class	Description
ContiguousSequenceRange	A range of contiguous event sequences and the latest timestamp of the events in the range.
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.
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.
UnprocessedEvent.Reason