Constructor and Description |
---|
SiddhiAppRuntimeImpl(Map<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> tableDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
Map<String,io.siddhi.query.api.definition.AbstractDefinition> aggregationDefinitionMap,
InputManager inputManager,
Map<String,QueryRuntime> queryProcessorMap,
Map<String,StreamJunction> streamJunctionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
ConcurrentMap<String,AggregationRuntime> aggregationMap,
Map<String,List<Source>> sourceMap,
Map<String,List<Sink>> sinkMap,
Map<String,PartitionRuntime> partitionMap,
ConcurrentMap<String,Trigger> triggerMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,StreamJunction> |
PartitionRuntimeImpl.getInnerPartitionStreamReceiverStreamJunctionMap() |
ConcurrentMap<String,StreamJunction> |
PartitionRuntimeImpl.getLocalStreamJunctionMap() |
Modifier and Type | Method and Description |
---|---|
void |
PartitionRuntimeImpl.addInnerpartitionStreamReceiverStreamJunction(String key,
StreamJunction streamJunction) |
Constructor and Description |
---|
PartitionRuntimeImpl(ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> windowDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.execution.partition.Partition partition,
int partitionIndex,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
void |
InsertIntoStreamCallback.init(StreamJunction outputStreamJunction) |
Modifier and Type | Method and Description |
---|---|
void |
StreamJunction.Publisher.setStreamJunction(StreamJunction streamJunction) |
Constructor and Description |
---|
StreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ExecutorService executorService,
int bufferSize,
StreamJunction faultStreamJunction,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
InputManager(SiddhiAppContext siddhiAppContext,
ConcurrentMap<String,io.siddhi.query.api.definition.AbstractDefinition> streamDefinitionMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
ConcurrentMap<String,Table> tableMap) |
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) |
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
|
Modifier and Type | Method and Description |
---|---|
void |
CronTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
void |
StartTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
void |
PeriodicTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
abstract void |
AbstractTrigger.init(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
SiddhiAppContext siddhiAppContext,
StreamJunction streamJunction) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,StreamJunction> |
SiddhiAppRuntimeBuilder.getStreamJunctions() |
Constructor and Description |
---|
StreamHandler(List<StreamJunction.Receiver> receivers,
int batchSize,
String streamName,
String siddhiAppName,
StreamJunction faultStreamJunction,
StreamJunction.OnErrorAction onErrorAction,
ExceptionListener exceptionListener) |
Modifier and Type | Method and Description |
---|---|
static OutputCallback |
OutputParser.constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
String key,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static void |
DefinitionParserHelper.addEventSink(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
StreamJunction streamJunction,
ConcurrentMap<String,List<Sink>> eventSinkMap,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
static void |
DefinitionParserHelper.addEventTrigger(io.siddhi.query.api.definition.TriggerDefinition triggerDefinition,
ConcurrentMap<String,Trigger> eventTriggerMap,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
static void |
DefinitionParserHelper.addStreamJunction(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
SiddhiAppContext siddhiAppContext) |
Copyright © 2021. All rights reserved.