|Constructor and Description|
|Modifier and Type||Method and Description|
Tries to process the supplied input item, which was received from the edge with the supplied ordinal.
emitFromTraverser, emitFromTraverser, emitFromTraverser, emitFromTraverserToSnapshot, flatMapper, flatMapper, flatMapper, getLogger, getOutbox, init, init, process, restoreFromSnapshot, restoreFromSnapshot, tryEmit, tryEmit, tryEmit, tryEmitToSnapshot, tryProcess0, tryProcess1, tryProcess2, tryProcess3, tryProcess4, tryProcessWatermark
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
false, in which case it will be called again later with the same
(ordinal, item)combination before any other processing method is called.
The default implementation throws an
NOTE: unless the processor doesn't differentiate between
its inbound edges, the first choice should be leaving this method alone
and instead overriding the specific
tryProcessN() methods for
each ordinal the processor expects.
Copyright © 2019 Hazelcast, Inc.. All rights reserved.