Package | Description |
---|---|
io.siddhi.core.stream.output.sink | |
io.siddhi.core.stream.output.sink.distributed |
Modifier and Type | Class and Description |
---|---|
class |
PassThroughSinkMapper
Implementation of
SinkMapper representing pass-through scenario where no mapping is done and
Event s are send directly to transports. |
Modifier and Type | Method and Description |
---|---|
SinkMapper |
Sink.getMapper() |
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,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
SinkHandlerCallback(SinkMapper sinkMapper) |
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,
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 © 2019. All rights reserved.