Package | Description |
---|---|
io.siddhi.core.stream.output.sink | |
io.siddhi.core.stream.output.sink.distributed | |
io.siddhi.core.util.transport |
Modifier and Type | Class and Description |
---|---|
class |
InMemorySink
Implementation of
Sink which represents in-memory transport. |
class |
LogSink
Implementation of
Sink which can be used as a logger. |
class |
Sink
This is a Sink type.
|
Modifier and Type | Method and Description |
---|---|
void |
PassThroughSinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
abstract void |
SinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the events and send them to
SinkListener for publishing |
void |
PassThroughSinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
abstract void |
SinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the event and send it to
SinkListener for publishing |
Modifier and Type | Class and Description |
---|---|
class |
DistributedTransport
This is the base class for Distributed transports.
|
Modifier and Type | Class and Description |
---|---|
class |
MultiClientDistributedSink
This is the distributed transport to publish to multiple endpoints using client/publisher for each endpoint.
|
class |
SingleClientDistributedSink
This class implements a the distributed sink that could publish to multiple destination using a single
client/publisher.
|
Copyright © 2019. All rights reserved.