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

Class ViewP

java.lang.Object

com.hazelcast.jet.core.AbstractProcessor

org.apache.beam.runners.jet.processors.ViewP

All Implemented Interfaces:

com.hazelcast.jet.core.Processor

public class ViewP
extends com.hazelcast.jet.core.AbstractProcessor

Jet Processor implementation for Beam's side input producing primitives. Collects all input WindowedValues, groups them by windows and keys and when input is complete emits them.

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	Description
boolean	complete()
static com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor>	supplier(Coder inputCoder, Coder outputCoder, WindowingStrategy<?,?> windowingStrategy, String ownerId)
protected boolean	tryProcess(int ordinal, Object item)

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, tryProcessWatermark

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, tryProcess

Method Details

tryProcess

protected boolean tryProcess(int ordinal,
 @Nonnull
 Object item)

Overrides:

tryProcess in class com.hazelcast.jet.core.AbstractProcessor

complete

public boolean complete()

supplier

public static com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor> supplier(Coder inputCoder,
 Coder outputCoder,
 WindowingStrategy<?,?> windowingStrategy,
 String ownerId)