Package org.apache.beam.runners.jet.processors

Class WindowGroupP<K,​V>

  • Type Parameters:
    K - key type of KV values from the output of this primitive
    V - type of elements being windowed
    All Implemented Interfaces:
    com.hazelcast.jet.core.Processor
    public class WindowGroupP<K,​V>
extends com.hazelcast.jet.core.AbstractProcessor
    Jet Processor implementation for Beam's GroupByKeyOnly + GroupAlsoByWindow primitives.

    • Nested Class Summary

      • Nested classes/interfaces inherited from class com.hazelcast.jet.core.AbstractProcessor

        com.hazelcast.jet.core.AbstractProcessor.FlatMapper<T extends java.lang.Object,​R extends java.lang.Object>

      • Nested classes/interfaces inherited from interface com.hazelcast.jet.core.Processor

        com.hazelcast.jet.core.Processor.Context

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean complete()  
      static <K,​V>
      com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor>      		 supplier​(org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions, org.apache.beam.sdk.values.WindowedValues.WindowedValueCoder<org.apache.beam.sdk.values.KV<K,​V>> inputCoder, org.apache.beam.sdk.coders.Coder outputCoder, org.apache.beam.sdk.values.WindowingStrategy windowingStrategy, java.lang.String ownerId)  
      boolean tryProcess()  
      protected boolean tryProcess​(int ordinal, java.lang.Object item)  
      boolean tryProcessWatermark​(com.hazelcast.jet.core.Watermark watermark)  

      • Methods inherited from class com.hazelcast.jet.core.AbstractProcessor

        emitFromTraverser, emitFromTraverser, emitFromTraverser, emitFromTraverserToSnapshot, flatMapper, flatMapper, flatMapper, getLogger, getOutbox, init, init, process, restoreFromSnapshot, restoreFromSnapshot, tryEmit, tryEmit, tryEmit, tryEmitToSnapshot, tryProcess0, tryProcess1, tryProcess2, tryProcess3, tryProcess4

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface com.hazelcast.jet.core.Processor

        close, completeEdge, finishSnapshotRestore, isCooperative, saveToSnapshot, snapshotCommitFinish, snapshotCommitPrepare

    • Method Detail

      • supplier

        public static <K,​V> com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor> supplier​(org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions,
                                                                                                       org.apache.beam.sdk.values.WindowedValues.WindowedValueCoder<org.apache.beam.sdk.values.KV<K,​V>> inputCoder,
                                                                                                       org.apache.beam.sdk.coders.Coder outputCoder,
                                                                                                       org.apache.beam.sdk.values.WindowingStrategy windowingStrategy,
                                                                                                       java.lang.String ownerId)

      • tryProcess

        public boolean tryProcess()

      • tryProcess

        protected boolean tryProcess​(int ordinal,
                             @Nonnull
                             java.lang.Object item)
        Overrides:
        tryProcess in class com.hazelcast.jet.core.AbstractProcessor

      • tryProcessWatermark

        public boolean tryProcessWatermark​(@Nonnull
                                   com.hazelcast.jet.core.Watermark watermark)
        Specified by:
        tryProcessWatermark in interface com.hazelcast.jet.core.Processor
        Overrides:
        tryProcessWatermark in class com.hazelcast.jet.core.AbstractProcessor

      • complete

        public boolean complete()