public class InputDistributor extends Object implements InputProcessor
InputProcessor
which inject the event to a set of Input Processors.Constructor and Description |
---|
InputDistributor() |
Modifier and Type | Method and Description |
---|---|
void |
addInputProcessor(InputProcessor inputProcessor) |
void |
clear() |
void |
send(Event[] events,
int streamIndex) |
void |
send(Event event,
int streamIndex) |
void |
send(List<Event> events,
int streamIndex) |
void |
send(long timestamp,
Object[] data,
int streamIndex) |
public void send(Event event, int streamIndex)
send
in interface InputProcessor
public void send(Event[] events, int streamIndex)
send
in interface InputProcessor
public void send(List<Event> events, int streamIndex)
send
in interface InputProcessor
public void send(long timestamp, Object[] data, int streamIndex)
send
in interface InputProcessor
public void addInputProcessor(InputProcessor inputProcessor)
public void clear()
Copyright © 2021. All rights reserved.