Interface | Description |
---|---|
OutputGroupDeterminer |
Output events are grouped before sent out to the transport to achieve efficient network communication.
|
SinkListener |
Sink Listener is used to get Events out from
SinkMapper s into Sinks. |
Class | Description |
---|---|
DynamicOptionGroupDeterminer |
This implementation of
OutputGroupDeterminer groups events based on dynamic options of the Sink. |
InMemorySink |
Implementation of
Sink which represents in-memory transport. |
LogSink |
Implementation of
Sink which can be used as a logger. |
PartitionedGroupDeterminer |
This implementation of
OutputGroupDeterminer groups events into 'n' number of partitions. |
PassThroughSinkMapper |
Implementation of
SinkMapper representing pass-through scenario where no mapping is done and
Event s are send directly to transports. |
Sink |
This is a Sink type.
|
SinkCallback |
Sink Callback is used to get
Event s from Siddhi Streams using
StreamJunction and send them to SinkMapper s to do the mapping. |
SinkHandler<S extends State> |
SinkHandler is an optional interface before
SinkMapper . |
SinkHandlerCallback |
Sink Handler Callback is used to send events to the
SinkMapper after being handled by SinkHandler . |
SinkHandlerManager |
SinkHandlerManager is a factory interface that would create the appropriate
SinkHandler
for each Sink . |
SinkMapper |
Abstract parent class to represent event mappers.
|
Enum | Description |
---|---|
Sink.OnErrorAction |
Different Type of On Error Actions
|
Copyright © 2019. All rights reserved.