public class Partitioner<E extends EventHandler> extends Object implements EventHandler, Lifecycle, BatchHandler
NULL_EVENTHANDLER| Constructor and Description |
|---|
Partitioner(Supplier<E> factory) |
Partitioner(Supplier<E> factory,
Consumer<E> initialiser) |
| Modifier and Type | Method and Description |
|---|---|
void |
batchEnd()
Indicates all events for a transaction have been received.
|
void |
batchPause()
Indicates more events are expected, but there is an unknown pause in the message flow
|
void |
init()
callback received before any events are processed by the Static event
processor.
|
void |
onEvent(Event e)
Called when a new event e is ready to be processed.
|
<s,t> void |
partition(LambdaReflection.SerializableFunction<s,?>... supplier) |
<s,t> void |
partition(LambdaReflection.SerializableFunction<s,t> supplier) |
void |
tearDown()
callback received after all events are processed by the Static event
processor, and no more are expected.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitafterEvent, eventClasspublic <s,t> void partition(LambdaReflection.SerializableFunction<s,t> supplier)
public <s,t> void partition(LambdaReflection.SerializableFunction<s,?>... supplier)
public void onEvent(Event e)
EventHandleronEvent in interface EventHandlere - the Event to process.public void tearDown()
Lifecyclepublic void batchPause()
BatchHandlerbatchPause in interface BatchHandlerpublic void batchEnd()
BatchHandlerbatchEnd in interface BatchHandlerCopyright © 2019. All rights reserved.