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

Class DefaultSequenceCombiner<EventKeyT,​EventT,​StateT extends MutableState<EventT,​?>>

  • Type Parameters:
    EventKeyT - type of key
    EventT - type of event
    StateT - type of state
    All Implemented Interfaces:
    java.io.Serializable, org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<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>, org.apache.beam.sdk.transforms.display.HasDisplayData
    public class DefaultSequenceCombiner<EventKeyT,​EventT,​StateT extends MutableState<EventT,​?>>
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>
    Default global sequence combiner.

    Produces the largest ContiguousSequenceRange of contiguous longs which starts from the initial event identified by EventExaminer#isInitialEvent(long, EventT).

    This combiner currently doesn't use EventExaminer#isLastEvent(long, EventT).

    See Also:
    Serialized Form

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      SequenceRangeAccumulator addInput​(SequenceRangeAccumulator accum, org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<EventKeyT,​org.apache.beam.sdk.values.KV<java.lang.Long,​EventT>>> event)  
      SequenceRangeAccumulator createAccumulator()  
      ContiguousSequenceRange extractOutput​(SequenceRangeAccumulator accum)  
      java.lang.reflect.TypeVariable<?> getAccumTVariable()  
      @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.Coder<SequenceRangeAccumulator> getAccumulatorCoder​(@UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.CoderRegistry registry, @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.Coder<org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<EventKeyT,​org.apache.beam.sdk.values.KV<java.lang.Long,​EventT>>>> inputCoder)  
      org.apache.beam.sdk.coders.Coder<OutputT> getDefaultOutputCoder​(org.apache.beam.sdk.coders.CoderRegistry arg0, org.apache.beam.sdk.coders.Coder<@UnknownKeyFor @NonNull @Initialized InputT> arg1)  
      java.lang.String getIncompatibleGlobalWindowErrorMessage()  
      java.lang.reflect.TypeVariable<?> getInputTVariable()  
      java.lang.reflect.TypeVariable<?> getOutputTVariable()  
      SequenceRangeAccumulator mergeAccumulators​(java.lang.Iterable<SequenceRangeAccumulator> accumulators)  
      void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)  

      • Methods inherited from class org.apache.beam.sdk.transforms.Combine.CombineFn

        apply, compact, defaultValue, getInputType, getOutputType

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Method Detail

      • getAccumulatorCoder

        public @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.Coder<SequenceRangeAccumulator> getAccumulatorCoder​(@UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.CoderRegistry registry,
                                                                                                                           @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.Coder<org.apache.beam.sdk.values.TimestampedValue<org.apache.beam.sdk.values.KV<EventKeyT,​org.apache.beam.sdk.values.KV<java.lang.Long,​EventT>>>> inputCoder)
                                                                                                                    throws @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.CannotProvideCoderException
        Specified by:
        getAccumulatorCoder in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<EventKeyT,​EventT,​StateT extends MutableState<EventT,​?>>
        Throws:
        @UnknownKeyFor @NonNull @Initialized org.apache.beam.sdk.coders.CannotProvideCoderException

      • getDefaultOutputCoder

        public org.apache.beam.sdk.coders.Coder<OutputT> getDefaultOutputCoder​(org.apache.beam.sdk.coders.CoderRegistry arg0,
                                                                       org.apache.beam.sdk.coders.Coder<@UnknownKeyFor @NonNull @Initialized InputT> arg1)
                                                                throws org.apache.beam.sdk.coders.CannotProvideCoderException
        Specified by:
        getDefaultOutputCoder in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT extends java.lang.Object,​AccumT extends java.lang.Object,​OutputT extends java.lang.Object>
        Throws:
        org.apache.beam.sdk.coders.CannotProvideCoderException

      • getIncompatibleGlobalWindowErrorMessage

        public java.lang.String getIncompatibleGlobalWindowErrorMessage()
        Specified by:
        getIncompatibleGlobalWindowErrorMessage in interface org.apache.beam.sdk.transforms.CombineFnBase.GlobalCombineFn<InputT extends java.lang.Object,​AccumT extends java.lang.Object,​OutputT extends java.lang.Object>

      • getInputTVariable

        public java.lang.reflect.TypeVariable<?> getInputTVariable()

      • getAccumTVariable

        public java.lang.reflect.TypeVariable<?> getAccumTVariable()

      • getOutputTVariable

        public java.lang.reflect.TypeVariable<?> getOutputTVariable()

      • populateDisplayData

        public void populateDisplayData​(org.apache.beam.sdk.transforms.display.DisplayData.Builder arg0)
        Specified by:
        populateDisplayData in interface org.apache.beam.sdk.transforms.display.HasDisplayData