Serialized Form

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

Class org.apache.beam.sdk.extensions.ordered.ContiguousSequenceRange extends java.lang.Object implements Serializable

Class org.apache.beam.sdk.extensions.ordered.OrderedEventProcessor extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.KV<EventKeyT,org.apache.beam.sdk.values.KV<java.lang.Long,EventT>>>,OrderedEventProcessorResult<EventKeyT,ResultT,EventT>> implements Serializable

Class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler extends java.lang.Object implements Serializable

Serialized Fields

eventTClass

java.lang.Class<EventT> eventTClass

keyTClass

java.lang.Class<KeyT> keyTClass

maxOutputElementsPerBundle

int maxOutputElementsPerBundle

produceStatusUpdateOnEveryEvent

boolean produceStatusUpdateOnEveryEvent

resultTClass

java.lang.Class<ResultT> resultTClass

stateTClass

java.lang.Class<StateT extends MutableState<EventT,?>> stateTClass

statusUpdateFrequency

org.joda.time.Duration statusUpdateFrequency

Class org.apache.beam.sdk.extensions.ordered.OrderedProcessingHandler.OrderedProcessingGlobalSequenceHandler extends OrderedProcessingHandler<EventT,KeyT,StateT extends MutableState<EventT,?>,ResultT> implements Serializable

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

Class org.apache.beam.sdk.extensions.ordered.combiner.DefaultSequenceCombiner extends org.apache.beam.sdk.transforms.Combine.CombineFn<org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<EventKeyT,org.apache.beam.sdk.values.KV<java.lang.Long,EventT>>>,SequenceRangeAccumulator,ContiguousSequenceRange> implements Serializable

Serialized Fields

eventExaminer

EventExaminer<EventT,StateT extends MutableState<EventT,?>> eventExaminer

Class org.apache.beam.sdk.extensions.ordered.combiner.SequenceRangeAccumulator.SequenceRangeAccumulatorCoder extends org.apache.beam.sdk.coders.CustomCoder<SequenceRangeAccumulator> implements Serializable

Serialized Fields

dataCoder

org.apache.beam.sdk.coders.VarLongCoder dataCoder

initialSequenceCoder

org.apache.beam.sdk.coders.NullableCoder<java.lang.Long> initialSequenceCoder

numberOfRangesCoder

org.apache.beam.sdk.coders.VarIntCoder numberOfRangesCoder