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

Class 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 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 com.hazelcast.function.SupplierEx<com.hazelcast.jet.core.Processor> supplier​(org.apache.beam.sdk.coders.Coder inputCoder, org.apache.beam.sdk.coders.Coder outputCoder, org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy, java.lang.String ownerId)  
      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, completeEdge, finishSnapshotRestore, isCooperative, saveToSnapshot, snapshotCommitFinish, snapshotCommitPrepare, tryProcess

    • Method Detail

      • tryProcess

        protected boolean tryProcess​(int ordinal,
                             @Nonnull
                             java.lang.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​(org.apache.beam.sdk.coders.Coder inputCoder,
                                                                                           org.apache.beam.sdk.coders.Coder outputCoder,
                                                                                           org.apache.beam.sdk.values.WindowingStrategy<?,​?> windowingStrategy,
                                                                                           java.lang.String ownerId)