|Constructor and Description|
|Modifier and Type||Method and Description|
Called after all the inbound edges' streams are exhausted.
Method that can be overridden to perform any necessary initialization for the processor.
Tells whether this processor is able to participate in cooperative multithreading.
emitFromTraverser, emitFromTraverser, emitFromTraverser, emitFromTraverserToSnapshot, flatMapper, flatMapper, flatMapper, getLogger, getOutbox, init, process, restoreFromSnapshot, restoreFromSnapshot, tryEmit, tryEmit, tryEmit, tryEmitToSnapshot, tryProcess, tryProcess0, tryProcess1, tryProcess2, tryProcess3, tryProcess4, tryProcessWatermark
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public boolean isCooperative()
There are specific requirements that all processing methods of a cooperative processor must follow:
Jet prefers cooperative processors because they result in a greater overall throughput. A processor should be non-cooperative only if it involves blocking operations, which would cause all other processors on the same shared thread to starve.
Processor instances of a single vertex are allowed to return different values, but a single processor instance must always return the same value.
The default implementation returns
protected void init(@Nonnull Processor.Context context)
Processor.complete()), but after the outbox and
loggerhave been initialized.
Subclasses are not required to call this superclass method, it does nothing.
public boolean complete()
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
Copyright © 2020 Hazelcast, Inc.. All rights reserved.