- Type Parameters:
T- type of emitted items
- All Implemented Interfaces:
public class ParallelBatchP<T> extends AbstractProcessor
Implements a mock batch source with parallelism. It emits the items from the lists you supply, preserving the order within each list.
Nested Class Summary
Nested classes/interfaces inherited from class com.hazelcast.jet.core.AbstractProcessor
Nested classes/interfaces inherited from interface com.hazelcast.jet.core.Processor
Constructors Constructor Description
ParallelBatchP(List<? extends Iterable<T>> iterables)Creates a processor that generates items using its assigned iterables.
Modifier and Type Method Description
complete()Called after all the inbound edges' streams are exhausted.
init(Processor.Context context)Method that can be overridden to perform any necessary initialization for the processor.
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
close, completeEdge, finishSnapshotRestore, isCooperative, saveToSnapshot, snapshotCommitFinish, snapshotCommitPrepare, tryProcess
ParallelBatchPCreates a processor that generates items using its assigned iterables. This processor picks its assigned iterables from the list of iterables according to its global processor index.
iterables- list of iterables used to emit items
initprotected void init(@Nonnull Processor.Context context)Description copied from class:
AbstractProcessorMethod that can be overridden to perform any necessary initialization for the processor. It is called exactly once and strictly before any of the processing methods (
Processor.complete()), but after the outbox and
loggerhave been initialized.
Subclasses are not required to call this superclass method, it does nothing.
contextassociated with this processor
completepublic boolean complete()Description copied from interface:
ProcessorCalled after all the inbound edges' streams are exhausted. If it returns
false, it will be invoked again until it returns
true. For example, a streaming source processor will return
falseforever. Unlike other methods which guarantee that no other method is called until they return
Processor.saveToSnapshot()can be called even though this method returned
After this method is called, no other processing methods are called on this processor, except for
Non-cooperative processors are required to return from this method from time to time to give the system a chance to check for snapshot requests and job cancellation. The time the processor spends in this method affects the latency of snapshots and job cancellations.
trueif the completing step is now done,
falseto call this method again