Package | Description |
---|---|
io.siddhi.core.stream | |
io.siddhi.core.stream.input |
Modifier and Type | Class and Description |
---|---|
class |
StreamJunction.Publisher
Interface to be implemented to send events into the Stream Junction.
|
Modifier and Type | Class and Description |
---|---|
class |
InputDistributor
Implementation of
InputProcessor which inject the event to a set of Input Processors. |
class |
InputEntryValve
Implementation of
InputProcessor which inject the event to the next input processor through a valve. |
Modifier and Type | Field and Description |
---|---|
protected InputProcessor |
InputHandler.inputProcessor |
protected InputProcessor |
InputHandler.pausedInputPublisher |
Modifier and Type | Method and Description |
---|---|
void |
InputDistributor.addInputProcessor(InputProcessor inputProcessor) |
Constructor and Description |
---|
InputEntryValve(SiddhiAppContext siddhiAppContext,
InputProcessor inputProcessor) |
InputHandler(String streamId,
int streamIndex,
InputProcessor inputProcessor,
SiddhiAppContext siddhiAppContext) |
Copyright © 2019. All rights reserved.