Modifier and Type | Method and Description |
---|---|
StateHolder |
SiddhiQueryContext.generateStateHolder(String name,
boolean groupBy,
StateFactory stateFactory) |
StateHolder |
SiddhiQueryContext.generateStateHolder(String name,
boolean groupBy,
StateFactory stateFactory,
boolean unSafe) |
StateHolder |
SiddhiAppContext.generateStateHolder(String name,
StateFactory stateFactory) |
StateHolder |
SiddhiAppContext.generateStateHolder(String name,
StateFactory stateFactory,
boolean unSafe) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
EventVariableFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MultiValueVariableFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
EventTimestampFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfLongFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MinimumFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CreateSetFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
SizeOfSetFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfDoubleFunctionExecutor.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 |
InstanceOfIntegerFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfStringFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
DefaultFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CastFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfFloatFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
UUIDFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
StateFactory |
ConvertFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
ScriptFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
CurrentTimeMillisFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfBooleanFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
StateFactory |
CoalesceFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IfThenElseFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MaximumFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
IncrementalStartTimeEndTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalTimeGetTimeZone.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalUnixTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalAggregateBaseTimeFunctionExecutor.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 |
---|---|
protected StateFactory |
PassThroughOutputRateLimiter.init() |
protected abstract StateFactory<S> |
OutputRateLimiter.init() |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.AllPerEventOutputRateLimiter.RateLimiterState> |
AllPerEventOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.LastGroupByPerEventOutputRateLimiter.RateLimiterState> |
LastGroupByPerEventOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.FirstGroupByPerEventOutputRateLimiter.RateLimiterState> |
FirstGroupByPerEventOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.FirstPerEventOutputRateLimiter.RateLimiterState> |
FirstPerEventOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.event.LastPerEventOutputRateLimiter.RateLimiterState> |
LastPerEventOutputRateLimiter.init() |
Modifier and Type | Method and Description |
---|---|
protected abstract StateFactory<S> |
SnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AllAggregationGroupByWindowedPerSnapshotOutputRateLimiter.RateLimiterState> |
AllAggregationGroupByWindowedPerSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.GroupByPerSnapshotOutputRateLimiter.RateLimiterState> |
GroupByPerSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.WindowedPerSnapshotOutputRateLimiter.RateLimiterState> |
WindowedPerSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState> |
AggregationGroupByWindowedPerSnapshotOutputRateLimiter.init() |
protected StateFactory<S> |
WrappedSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.PerSnapshotOutputRateLimiter.RateLimiterState> |
PerSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AllAggregationPerSnapshotOutputRateLimiter.RateLimiterState> |
AllAggregationPerSnapshotOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.snapshot.AggregationWindowedPerSnapshotOutputRateLimiter.AggregationRateLimiterState> |
AggregationWindowedPerSnapshotOutputRateLimiter.init() |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.AllPerTimeOutputRateLimiter.RateLimiterState> |
AllPerTimeOutputRateLimiter.init() |
protected StateFactory |
LastPerTimeOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.FirstGroupByPerTimeOutputRateLimiter.RateLimiterState> |
FirstGroupByPerTimeOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.LastGroupByPerTimeOutputRateLimiter.RateLimiterState> |
LastGroupByPerTimeOutputRateLimiter.init() |
protected StateFactory<io.siddhi.core.query.output.ratelimit.time.FirstPerTimeOutputRateLimiter.RateLimiterState> |
FirstPerTimeOutputRateLimiter.init() |
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
|
Modifier and Type | Method and Description |
---|---|
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 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<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<io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState> |
TimeWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState> |
FrequentWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
protected StateFactory |
SortWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
LossyFrequentWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
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 |
DelayWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
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 |
TimeLengthWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
ExpressionWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
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 |
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<io.siddhi.core.query.processor.stream.window.ExpressionBatchWindowProcessor.WindowState> |
ExpressionBatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
LengthBatchWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
EmptyWindowProcessor.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 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<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> |
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 |
WindowWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
ExpressionBatchWindowProcessor.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> |
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 |
ExpressionWindowProcessor.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.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.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.StdDevAttributeAggregatorExecutor.AggregatorState> |
StdDevAttributeAggregatorExecutor.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 |
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.MinForeverAttributeAggregatorExecutor.MinAggregatorState> |
MinForeverAttributeAggregatorExecutor.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.MaxAttributeAggregatorExecutor.MaxAggregatorState> |
MaxAttributeAggregatorExecutor.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 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.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.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.DistinctCountAttributeAggregatorExecutor.AggregatorState> |
DistinctCountAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
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 StateFactory |
SourceHandler.init(String siddhiAppName,
SourceSyncCallback sourceSyncCallback,
io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SiddhiAppContext siddhiAppContext) |
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 StateFactory<S> |
SinkHandler.init(io.siddhi.query.api.definition.StreamDefinition streamDefinition,
SinkHandlerCallback sinkHandlerCallback) |
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 |
Modifier and Type | Method and Description |
---|---|
abstract StateFactory<S> |
RecordTableHandler.init(String id,
io.siddhi.query.api.definition.TableDefinition tableDefinition)
Initialize the Record Table Handler
|
Constructor and Description |
---|
PartitionStateHolder(StateFactory stateFactory) |
PartitionSyncStateHolder(StateFactory stateFactory) |
SingleStateHolder(StateFactory stateFactory) |
SingleSyncStateHolder(StateFactory stateFactory) |
Copyright © 2021. All rights reserved.