Package 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
    Description
    static final 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
    Description
    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, complete, 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