Modifier and Type | Class and Description |
---|---|
class |
PartitionStreamReceiver
Specific
StreamJunction.Receiver implementation to pump events into partitions. |
Modifier and Type | Class and Description |
---|---|
class |
MultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events to be fed into multi
stream processors which consume multiple streams.
|
class |
ProcessStreamReceiver
Parent implementation for all process stream receivers(Multi/Single/State).
|
class |
SingleProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
single stream stateless queries(Filter).
|
class |
StateMultiProcessStreamReceiver
Implementation of {StreamJunction.Receiver} to receive events to be fed into
multi stream stateful queries.
|
Modifier and Type | Class and Description |
---|---|
class |
PatternMultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into pattern queries
with multiple streams.
|
class |
PatternSingleProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into pattern queries
with single stream.
|
class |
SequenceMultiProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into sequence queries
with multiple streams.
|
class |
SequenceSingleProcessStreamReceiver
{StreamJunction.Receiver} implementation to receive events into sequence queries
with single stream.
|
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.subscribe(StreamJunction.Receiver receiver) |
Modifier and Type | Class and Description |
---|---|
class |
StreamCallback
StreamCallback is used to receive events from
StreamJunction . |
Modifier and Type | Class and Description |
---|---|
class |
SinkCallback
Sink Callback is used to get
Event s from Siddhi Streams using
StreamJunction and send them to SinkMapper s to do the mapping. |
Constructor and Description |
---|
StreamHandler(List<StreamJunction.Receiver> receivers,
int batchSize,
String streamName,
String siddhiAppName,
StreamJunction faultStreamJunction,
StreamJunction.OnErrorAction onErrorAction,
ExceptionListener exceptionListener) |
Copyright © 2021. All rights reserved.