Package | Description |
---|---|
io.siddhi.core.stream.output.sink | |
io.siddhi.core.stream.output.sink.distributed |
Modifier and Type | Method and Description |
---|---|
abstract SinkHandler |
SinkHandlerManager.generateSinkHandler() |
SinkHandler |
Sink.getHandler() |
Modifier and Type | Method and Description |
---|---|
Map<String,SinkHandler> |
SinkHandlerManager.getRegisteredSinkHandlers() |
Modifier and Type | Method and Description |
---|---|
void |
Sink.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
SinkMapper sinkMapper,
String mapType,
OptionHolder mapOptionHolder,
SinkHandler sinkHandler,
List<io.siddhi.query.api.annotation.Element> payloadElementList,
ConfigReader mapperConfigReader,
Map<String,String> deploymentProperties,
StreamJunction streamJunction,
SiddhiAppContext siddhiAppContext) |
void |
SinkHandlerManager.registerSinkHandler(String elementId,
SinkHandler sinkHandler) |
Modifier and Type | Method and Description |
---|---|
void |
DistributedTransport.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String type,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
SinkMapper sinkMapper,
String mapType,
OptionHolder mapOptionHolder,
SinkHandler sinkHandler,
List<io.siddhi.query.api.annotation.Element> payloadElementList,
ConfigReader mapperConfigReader,
StreamJunction streamJunction,
SiddhiAppContext siddhiAppContext,
List<OptionHolder> destinationOptionHolders,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
DistributionStrategy strategy,
String[] supportedDynamicOptions,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties)
This is method contains the additional parameters which require to initialize distributed transport
|
Copyright © 2021. All rights reserved.