org.apache.beam.runners.jet.processors

Class WindowGroupP<K,V>

java.lang.Object

com.hazelcast.jet.core.AbstractProcessor

org.apache.beam.runners.jet.processors.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,R>

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

com.hazelcast.jet.core.Processor.Context

Method Summary

Modifier and Type	Method and Description
boolean	complete()
static <K,V> com.hazelcast.jet.function.SupplierEx<com.hazelcast.jet.core.Processor>	supplier(org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions, org.apache.beam.sdk.util.WindowedValue.WindowedValueCoder<KV<K,V>> inputCoder, Coder outputCoder, 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

Method Detail

supplier

public static <K,V> com.hazelcast.jet.function.SupplierEx<com.hazelcast.jet.core.Processor> supplier(org.apache.beam.runners.core.construction.SerializablePipelineOptions pipelineOptions,
                                                                                                     org.apache.beam.sdk.util.WindowedValue.WindowedValueCoder<KV<K,V>> inputCoder,
                                                                                                     Coder outputCoder,
                                                                                                     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()