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

Class BoundedSourceP<T>

  • All Implemented Interfaces:
    com.hazelcast.jet.core.Processor, com.hazelcast.jet.Traverser
    public class BoundedSourceP<T>
extends com.hazelcast.jet.core.AbstractProcessor
implements com.hazelcast.jet.Traverser
    Jet Processor implementation for reading from a bounded Beam source.

    • 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
      void close()  
      boolean complete()  
      protected void init​(com.hazelcast.jet.core.Processor.Context context)  
      boolean isCooperative()  
      java.lang.Object next()  
      static <T> com.hazelcast.jet.core.ProcessorMetaSupplier supplier​(org.apache.beam.sdk.io.BoundedSource<T> boundedSource, org.apache.beam.runners.core.construction.SerializablePipelineOptions options, org.apache.beam.sdk.coders.Coder outputCoder, java.lang.String ownerId)  

      • Methods inherited from class com.hazelcast.jet.core.AbstractProcessor

        emitFromTraverser, emitFromTraverser, emitFromTraverser, emitFromTraverserToSnapshot, flatMapper, flatMapper, flatMapper, getLogger, getOutbox, init, process, restoreFromSnapshot, restoreFromSnapshot, tryEmit, tryEmit, tryEmit, tryEmitToSnapshot, tryProcess, 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

        completeEdge, finishSnapshotRestore, saveToSnapshot, snapshotCommitFinish, snapshotCommitPrepare, tryProcess

      • Methods inherited from interface com.hazelcast.jet.Traverser

        append, dropWhile, filter, flatMap, map, onFirstNull, peek, prepend, takeWhile

    • Method Detail

      • init

        protected void init​(@Nonnull
                    com.hazelcast.jet.core.Processor.Context context)
             throws java.lang.Exception
        Overrides:
        init in class com.hazelcast.jet.core.AbstractProcessor
        Throws:
        java.lang.Exception

      • next

        public java.lang.Object next()
        Specified by:
        next in interface com.hazelcast.jet.Traverser<T>

      • complete

        public boolean complete()
        Specified by:
        complete in interface com.hazelcast.jet.core.Processor

      • isCooperative

        public boolean isCooperative()
        Specified by:
        isCooperative in interface com.hazelcast.jet.core.Processor

      • close

        public void close()
           throws java.lang.Exception
        Specified by:
        close in interface com.hazelcast.jet.core.Processor
        Throws:
        java.lang.Exception

      • supplier

        public static <T> com.hazelcast.jet.core.ProcessorMetaSupplier supplier​(org.apache.beam.sdk.io.BoundedSource<T> boundedSource,
                                                                        org.apache.beam.runners.core.construction.SerializablePipelineOptions options,
                                                                        org.apache.beam.sdk.coders.Coder outputCoder,
                                                                        java.lang.String ownerId)