Modifier and Type | Method and Description |
---|---|
Collection<List<Sink>> |
SiddhiAppRuntime.getSinks() |
Constructor and Description |
---|
SiddhiAppRuntime(Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
InputManager inputManager,
Map<String,QueryRuntime> queryProcessorMap,
Map<String,StreamJunction> streamJunctionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
ConcurrentMap<String,AggregationRuntime> aggregationMap,
Map<String,List<Source>> sourceMap,
Map<String,List<Sink>> sinkMap,
Map<String,PartitionRuntime> partitionMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
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. |
Modifier and Type | Method and Description |
---|---|
void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder mapOptionHolder,
List<io.siddhi.query.api.annotation.Element> unmappedPayloadList,
Sink sink,
ConfigReader mapperConfigReader,
LatencyTracker mapperLatencyTracker,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
SinkCallback(List<Sink> sinks,
io.siddhi.query.api.definition.AbstractDefinition outputStreamDefinition) |
Modifier and Type | Class and Description |
---|---|
class |
DistributedTransport
This is the base class for Distributed transports.
|
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,List<Sink>> |
SiddhiAppRuntimeBuilder.getSinkMap() |
Modifier and Type | Method and Description |
---|---|
static void |
DefinitionParserHelper.addEventSink(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,List<Sink>> eventSinkMap,
SiddhiAppContext siddhiAppContext) |
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.