com.fluxtion.api.partition

Class Partitioner<E extends EventHandler>

java.lang.Object

com.fluxtion.api.partition.Partitioner<E>

All Implemented Interfaces:

BatchHandler, EventHandler, Lifecycle

public class Partitioner<E extends EventHandler>
extends Object
implements EventHandler, Lifecycle, BatchHandler

A simple event partitioner based on a single or multiple properties of an event. User register a creation function for an EventHandler and an optional initialiser that

Author:

gregp

Field Summary

Fields inherited from interface com.fluxtion.api.lifecycle.EventHandler

NULL_EVENTHANDLER

Constructor Summary

Constructors

Constructor and Description
Partitioner(Supplier<E> factory)
Partitioner(Supplier<E> factory, Consumer<E> initialiser)

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.fluxtion.api.lifecycle.EventHandler

afterEvent, eventClass

Constructor Detail

Partitioner

public Partitioner(Supplier<E> factory,
                   Consumer<E> initialiser)

Partitioner

public Partitioner(Supplier<E> factory)

Method Detail

partition

public <s,t> void partition(LambdaReflection.SerializableFunction<s,t> supplier)

partition

public <s,t> void partition(LambdaReflection.SerializableFunction<s,?>... supplier)

onEvent

public void onEvent(Event e)

Description copied from interface: EventHandler

Called when a new event e is ready to be processed.

Specified by:

onEvent in interface EventHandler

Parameters:

e - the Event to process.

tearDown

public void tearDown()

Description copied from interface: Lifecycle

callback received after all events are processed by the Static event processor, and no more are expected. tearDown methods are invoked in reverse-topological order.

Specified by:

tearDown in interface Lifecycle

batchPause

public void batchPause()

Description copied from interface: BatchHandler

Indicates more events are expected, but there is an unknown pause in the message flow

Specified by:

batchPause in interface BatchHandler

batchEnd

public void batchEnd()

Description copied from interface: BatchHandler

Indicates all events for a transaction have been received.

Specified by:

batchEnd in interface BatchHandler

init

public void init()

Description copied from interface: Lifecycle

callback received before any events are processed by the Static event processor. Init methods are invoked in topological order.

Specified by:

init in interface Lifecycle