org.apache.beam.runners.jet.processors

Class FlattenP

java.lang.Object

com.hazelcast.jet.core.AbstractProcessor

org.apache.beam.runners.jet.processors.FlattenP

All Implemented Interfaces:

com.hazelcast.jet.core.Processor

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

Jet Processor implementation for Beam's Flatten primitive.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	FlattenP.Supplier Jet Processor supplier that will provide instances of FlattenP.

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
protected boolean	tryProcess(int ordinal, java.lang.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, complete, completeEdge, finishSnapshotRestore, isCooperative, saveToSnapshot, tryProcess

Method Detail

tryProcess

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

Overrides:

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