Modifier and Type | Method and Description |
---|---|
protected StateFactory |
MaximumFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
EventTimestampFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfFloatFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CurrentTimeMillisFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CreateSetFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfIntegerFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected abstract StateFactory<S> |
FunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor, this method will be called before the other methods
|
protected StateFactory |
SizeOfSetFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfStringFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CastFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
StateFactory |
CoalesceFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
StateFactory |
ConvertFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MinimumFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfDoubleFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfLongFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
UUIDFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfBooleanFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
DefaultFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
ScriptFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IfThenElseFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
void |
FunctionExecutor.initExecutor(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
ConfigReader configReader,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
IncrementalAggregateBaseTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalStartTimeEndTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalUnixTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalTimeGetTimeZone.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState> |
IncrementalShouldUpdateFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Script.init(String name,
String body,
ConfigReader configReader) |
Modifier and Type | Method and Description |
---|---|
protected abstract StateFactory<S> |
AbstractStreamProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected StateFactory |
LogStreamProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamFunction
|
void |
AbstractStreamProcessor.initProcessor(MetaStreamEvent metaStreamEvent,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
boolean groupBy,
io.siddhi.query.api.SiddhiElement siddhiElement,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract StateFactory<S> |
StreamFunctionProcessor.init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
protected StateFactory |
Pol2CartStreamFunctionProcessor.init(io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamFunction
|
protected StateFactory<S> |
StreamFunctionProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the StreamProcessor, this method will be called before other methods
|
Modifier and Type | Method and Description |
---|---|
protected abstract StateFactory<S> |
HopingWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected StateFactory<io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState> |
SessionWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext) |
protected abstract StateFactory<S> |
GroupingWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected StateFactory |
DelayWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
TimeLengthWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState> |
TimeWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
LossyFrequentWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
protected StateFactory<io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState> |
FrequentWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
protected abstract StateFactory<S> |
SlidingWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected StateFactory |
LengthWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState> |
ExternalTimeWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
SortWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
LengthBatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
ExternalTimeBatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState> |
BatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
AggregateWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.CronWindowProcessor.WindowState> |
CronWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
TimeBatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected abstract StateFactory<S> |
BatchingWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext)
The init method of the WindowProcessor, this method will be called before other methods
|
protected StateFactory |
TableWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
HopingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
SlidingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
BatchingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<S> |
GroupingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
WindowWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.AvgAttributeAggregatorExecutor.AvgAttributeState> |
AvgAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState> |
MinAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState> |
MaxForeverAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected abstract StateFactory<S> |
AttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.SumAttributeAggregatorExecutor.AggregatorState> |
SumAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.UnionSetAttributeAggregatorExecutor.AggregatorState> |
UnionSetAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.DistinctCountAttributeAggregatorExecutor.AggregatorState> |
DistinctCountAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.CountAttributeAggregatorExecutor.AggregatorState> |
CountAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinForeverAttributeAggregatorExecutor.MinAggregatorState> |
MinForeverAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.OrAttributeAggregatorExecutor.AggregatorState> |
OrAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.StdDevAttributeAggregatorExecutor.AggregatorState> |
StdDevAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory |
AndAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MaxAttributeAggregatorExecutor.MaxAggregatorState> |
MaxAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
void |
AttributeAggregatorExecutor.initAggregator(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
abstract void |
Source.init(SourceEventListener sourceEventListener,
OptionHolder optionHolder,
String[] requestedTransportPropertyNames,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext)
To initialize the source.
|
void |
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,
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,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Sink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
protected void |
LogSink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
protected void |
InMemorySink.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext) |
void |
PassThroughSinkMapper.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder optionHolder,
Map<String,TemplateBuilder> payloadTemplateBuilderMap,
ConfigReader mapperConfigReader,
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 |
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,
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,
SiddhiAppContext siddhiAppContext) |
void |
Sink.initOnlyTransport(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
OptionHolder transportOptionHolder,
ConfigReader sinkConfigReader,
String type,
DistributedTransport.ConnectionCallback connectionCallback,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
protected void |
DistributedTransport.init(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
OptionHolder optionHolder,
ConfigReader sinkConfigReader,
SiddhiAppContext siddhiAppContext)
Will be called for initialing the
Sink |
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 |
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.
|
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 |
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.
|
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)
This is method contains the additional parameters which require to initialize distributed transport
|
abstract void |
DistributedTransport.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
Table.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
InMemoryTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
void |
Table.initTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
Modifier and Type | Method and Description |
---|---|
protected abstract void |
AbstractRecordTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
ConfigReader configReader)
Initializing the Record Table
|
void |
AbstractRecordTable.init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
StreamEventFactory storeEventPool,
StreamEventCloner storeEventCloner,
ConfigReader configReader,
SiddhiAppContext siddhiAppContext,
RecordTableHandler recordTableHandler) |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryConfigReader
Extension config readers
|
Modifier and Type | Method and Description |
---|---|
ConfigReader |
ConfigManager.generateConfigReader(String namespace,
String name) |
ConfigReader |
InMemoryConfigManager.generateConfigReader(String namespace,
String name) |
Modifier and Type | Method and Description |
---|---|
void |
MultiClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
void |
SingleClientDistributedSink.initTransport(OptionHolder sinkOptionHolder,
List<OptionHolder> destinationOptionHolders,
io.siddhi.query.api.annotation.Annotation sinkAnnotation,
ConfigReader sinkConfigReader,
DistributionStrategy strategy,
String type,
SiddhiAppContext siddhiAppContext) |
Copyright © 2019. All rights reserved.