Package | Description |
---|---|
io.siddhi.core.stream.input.source | |
io.siddhi.core.stream.output.sink | |
io.siddhi.core.stream.output.sink.distributed | |
io.siddhi.core.util.transport |
Modifier and Type | Field and Description |
---|---|
protected OptionHolder |
SourceMapper.sourceOptionHolder |
Modifier and Type | Method and Description |
---|---|
abstract StateFactory<S> |
Source.init(SourceEventListener sourceEventListener,
OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
To initialize the source.
|
StateFactory<State> |
InMemorySource.init(SourceEventListener sourceEventListener,
OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
abstract void |
SourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
List<AttributeMapping> attributeMappingList,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
Initialize Source-mapper
|
void |
PassThroughSourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
List<AttributeMapping> attributeMappingList,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
void |
SourceMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
String mapType,
OptionHolder mapOptionHolder,
List<AttributeMapping> attributeMappings,
String sourceType,
SourceSyncCallback sourceSyncCallback,
List<AttributeMapping> transportMappings,
SourceHandler sourceHandler,
OptionHolder sourceOptionHolder,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext) |
void |
Source.init(String sourceType,
OptionHolder transportOptionHolder,
SourceMapper sourceMapper,
String[] transportPropertyNames,
ConfigReader configReader,
String mapType,
OptionHolder mapOptionHolder,
List<AttributeMapping> attributeMappings,
List<AttributeMapping> transportMappings,
ConfigReader mapperConfigReader,
SourceHandler sourceHandler,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
Map<String,String> deploymentProperties,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Field and Description |
---|---|
protected OptionHolder |
SinkMapper.sinkOptionHolder |
Modifier and Type | Method and Description |
---|---|
protected abstract StateFactory<S> |
Sink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
protected StateFactory<State> |
LogSink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
protected StateFactory<State> |
InMemorySink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
abstract void |
SinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext)
Initialize the mapper and the mapping configurations.
|
void |
PassThroughSinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
SiddhiAppContext siddhiAppContext) |
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 |
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,
OptionHolder sinkOptionHolder,
SiddhiAppContext siddhiAppContext) |
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) |
abstract void |
SinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the events and send them to
SinkListener for publishing |
void |
PassThroughSinkMapper.mapAndSend(Event[] events,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
abstract void |
SinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener)
Called to map the event and send it to
SinkListener for publishing |
void |
PassThroughSinkMapper.mapAndSend(Event event,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
SinkListener sinkListener) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<State> |
DistributedTransport.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
void |
PartitionedDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
abstract void |
DistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
void |
RoundRobinDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
void |
BroadcastDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
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 |
PartitionedDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
abstract void |
DistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
void |
RoundRobinDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
void |
BroadcastDistributionStrategy.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
OptionHolder distributionOptionHolder,
List<OptionHolder> destinationOptionHolders,
ConfigReader configReader)
Initialize the Distribution strategy with the information it will require to make decisions.
|
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 |
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) |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
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) |
Copyright © 2021. All rights reserved.