Package | Description |
---|---|
io.siddhi.core.stream.output.sink | |
io.siddhi.core.util.transport |
Modifier and Type | Method and Description |
---|---|
void |
Sink.initOnlyTransport(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
String type,
DistributedTransport.ConnectionCallback connectionCallback,
Map<String,String> deploymentProperties,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Class and Description |
---|---|
class |
MultiClientDistributedSink.MultiClientConnectionCallback
Connection callback to notify DistributionStrategy about new connection initiations and failures
|
class |
SingleClientDistributedSink.SingleClientConnectionCallback
Connection callback to notify DistributionStrategy about new connection initiations and failures
|
Copyright © 2021. All rights reserved.