Package | Description |
---|---|
io.siddhi.core.stream.output.sink.distributed | |
io.siddhi.core.util.transport |
Modifier and Type | Class and Description |
---|---|
class |
BroadcastDistributionStrategy
Publishing strategy to broad cast message to all destinations
|
class |
PartitionedDistributionStrategy
Publishing strategy to allow publish messages to multiple destination by partitioning
|
class |
RoundRobinDistributionStrategy
Publishing strategy to implement messages in a round robin manner to multiple destinations
|
Modifier and Type | Field and Description |
---|---|
protected DistributionStrategy |
DistributedTransport.strategy |
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
|
abstract void |
DistributedTransport.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
MultiClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
void |
SingleClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
Map<String,String> deploymentProperties,
List<Map<String,String>> destinationDeploymentProperties,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Copyright © 2019. All rights reserved.