Modifier and Type | Method and Description |
---|---|
CompiledCondition |
AggregationRuntime.compileExpression(io.siddhi.query.api.expression.Expression expression,
io.siddhi.query.api.aggregation.Within within,
io.siddhi.query.api.expression.Expression per,
List<io.siddhi.query.api.expression.Variable> queryGroupByList,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
StreamEvent |
AggregationRuntime.find(StateEvent matchingEvent,
CompiledCondition compiledCondition,
SiddhiQueryContext siddhiQueryContext) |
void |
IncrementalDataPurger.init(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
StreamEventFactory streamEventFactory,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Boolean isProcessingOnExternalTime,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
BaseIncrementalValueStore(String aggregatorName,
long initialTimestamp,
List<ExpressionExecutor> expressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy,
boolean local) |
IncrementalExecutor(String aggregatorName,
io.siddhi.query.api.aggregation.TimePeriod.Duration duration,
List<ExpressionExecutor> processExpressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
boolean isRoot,
Table table,
IncrementalExecutor child,
SiddhiQueryContext siddhiQueryContext,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
MultiValueVariableFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
FunctionExecutor.siddhiQueryContext |
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
CurrentTimeMillisFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IfThenElseFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
EventTimestampFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfLongFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
StateFactory |
CoalesceFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
SizeOfSetFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfFloatFunctionExecutor.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 |
DefaultFunctionExecutor.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 StateFactory |
InstanceOfBooleanFunctionExecutor.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 |
CastFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfDoubleFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
UUIDFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
InstanceOfStringFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MinimumFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
MaximumFunctionExecutor.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 |
IncrementalStartTimeEndTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalTimeGetTimeZone.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalAggregateBaseTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory |
IncrementalUnixTimeFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
protected StateFactory<io.siddhi.core.executor.incremental.IncrementalShouldUpdateFunctionExecutor.FunctionState> |
IncrementalShouldUpdateFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
StreamPartitioner(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
io.siddhi.query.api.execution.partition.Partition partition,
MetaStateEvent metaEvent,
List<VariableExpressionExecutor> executors,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
SiddhiQueryContext |
QueryRuntimeImpl.getSiddhiQueryContext() |
Constructor and Description |
---|
FindOnDemandQueryRuntime(AggregationRuntime aggregation,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
QueryRuntimeImpl(io.siddhi.query.api.execution.query.Query query,
StreamRuntime streamRuntime,
QuerySelector selector,
OutputRateLimiter outputRateLimiter,
OutputCallback outputCallback,
MetaComplexEvent metaComplexEvent,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
ProcessStreamReceiver.siddhiQueryContext |
Constructor and Description |
---|
MultiProcessStreamReceiver(String streamId,
int processCount,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
ProcessStreamReceiver(String streamId,
SiddhiQueryContext siddhiQueryContext) |
SingleProcessStreamReceiver(String streamId,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
StateMultiProcessStreamReceiver(String streamId,
int processCount,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
JoinStreamRuntime(SiddhiQueryContext siddhiQueryContext,
MetaStateEvent metaStateEvent) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
StreamPreStateProcessor.siddhiQueryContext |
Modifier and Type | Method and Description |
---|---|
void |
CountPreStateProcessor.init(SiddhiQueryContext siddhiQueryContext) |
void |
StreamPreStateProcessor.init(SiddhiQueryContext siddhiQueryContext) |
void |
AbsentStreamPreStateProcessor.init(SiddhiQueryContext siddhiQueryContext) |
void |
AbsentLogicalPreStateProcessor.init(SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
StateStreamRuntime(SiddhiQueryContext siddhiQueryContext,
MetaStateEvent metaStateEvent) |
Constructor and Description |
---|
PatternMultiProcessStreamReceiver(String streamId,
int processCount,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
PatternSingleProcessStreamReceiver(String streamId,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
SequenceMultiProcessStreamReceiver(String streamId,
int processCount,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
SequenceSingleProcessStreamReceiver(String streamId,
StateStreamRuntime stateStreamRuntime,
Object patternSyncObject,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
OutputRateLimiter.siddhiQueryContext |
Modifier and Type | Method and Description |
---|---|
void |
OutputRateLimiter.init(LockWrapper lockWrapper,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
SnapshotOutputRateLimiter.siddhiQueryContext |
Modifier and Type | Method and Description |
---|---|
void |
WrappedSnapshotOutputRateLimiter.init(SiddhiQueryContext siddhiQueryContext,
LockWrapper lockWrapper) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
AbstractStreamProcessor.siddhiQueryContext |
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 |
---|---|
CompiledCondition |
BatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.BatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
EmptyWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.EmptyWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExternalTimeBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExternalTimeBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
ExternalTimeWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.ExternalTimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
FrequentWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.FrequentWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
CompiledCondition |
LengthBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LengthBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
LengthWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LengthWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
LossyFrequentWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.LossyFrequentWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
CompiledCondition |
SessionWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.SessionWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
WindowWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
BatchingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
AggregateWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
GroupingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
FindableProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
CompiledCondition |
SlidingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
SortWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.SortWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
abstract CompiledCondition |
BatchingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
abstract CompiledCondition |
GroupingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
abstract CompiledCondition |
SlidingFindableWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
S state,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
CompiledCondition |
TimeBatchWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeBatchWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TimeLengthWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeLengthWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
TimeWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
DelayWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
io.siddhi.core.query.processor.stream.window.TimeWindowProcessor.WindowState state,
SiddhiQueryContext siddhiQueryContext) |
CompiledSelection |
TableWindowProcessor.compileSelection(io.siddhi.query.api.execution.query.selection.Selector selector,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledSelection |
QueryableProcessor.compileSelection(io.siddhi.query.api.execution.query.selection.Selector selector,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
To construct a selection having the capability of transforming events based on given selection logic.
|
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> |
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 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 |
SortWindowProcessor.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.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 |
LengthWindowProcessor.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 |
LossyFrequentWindowProcessor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
Deprecated.
|
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 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 |
AggregateWindowProcessor.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 |
TableWindowProcessor.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<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<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 |
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<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> |
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> |
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> |
GroupingWindowProcessor.init(MetaStreamEvent metaStreamEvent,
io.siddhi.query.api.definition.AbstractDefinition inputDefinition,
ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
StreamEventClonerHolder streamEventClonerHolder,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
GroupByKeyGenerator(List<io.siddhi.query.api.expression.Expression> groupByList,
MetaComplexEvent metaComplexEvent,
int currentState,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> executors,
SiddhiQueryContext siddhiQueryContext) |
OrderByEventComparator(List<io.siddhi.query.api.execution.query.selection.OrderByAttribute> groupByList,
MetaComplexEvent metaComplexEvent,
int currentState,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> executors,
SiddhiQueryContext siddhiQueryContext) |
QuerySelector(String id,
io.siddhi.query.api.execution.query.selection.Selector selector,
boolean currentOn,
boolean expiredOn,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
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.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.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.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.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.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.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.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.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.MinAttributeAggregatorExecutor.MinAggregatorState> |
MinAttributeAggregatorExecutor.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
|
void |
AttributeAggregatorExecutor.initAggregator(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
InMemoryTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
CacheTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext,
boolean updateCachePolicyAttribute) |
abstract CompiledUpdateSet |
Table.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
Builds the "compiled" set clause of an update query.
|
CompiledUpdateSet |
InMemoryTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CacheTable.CacheCompiledConditionWithRouteToCache |
CacheTable.generateCacheCompileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder storeMatchingMetaInfoHolder,
SiddhiQueryContext siddhiQueryContext,
List<VariableExpressionExecutor> storeVariableExpressionExecutors) |
Modifier and Type | Field and Description |
---|---|
protected SiddhiQueryContext |
AbstractQueryableRecordTable.siddhiQueryContextForTestOnDemandQuery |
Modifier and Type | Method and Description |
---|---|
SiddhiQueryContext |
AbstractRecordTable.RecordStoreCompiledCondition.getSiddhiQueryContext() |
SiddhiQueryContext |
ExpressionBuilder.getSiddhiQueryContext() |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
AbstractQueryableRecordTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
AbstractRecordTable.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledSelection |
AbstractQueryableRecordTable.compileSelection(io.siddhi.query.api.execution.query.selection.Selector selector,
List<io.siddhi.query.api.definition.Attribute> expectedOutputAttributes,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledUpdateSet |
AbstractQueryableRecordTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledUpdateSet |
AbstractRecordTable.compileUpdateSet(io.siddhi.query.api.execution.query.output.stream.UpdateSet updateSet,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
Constructor and Description |
---|
Scheduler(Schedulable singleThreadEntryValve,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
static CollectionExecutor |
CollectionExpressionParser.buildCollectionExecutor(CollectionExpression collectionExpression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
boolean isFirst,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext,
boolean isCache,
CacheTable cacheTable) |
static List<io.siddhi.query.api.definition.Attribute> |
OnDemandQueryParser.buildExpectedOutputAttributes(io.siddhi.query.api.execution.query.OnDemandQuery onDemandQuery,
Map<String,Table> tableMap,
int metaPosition,
MatchingMetaInfoHolder metaStreamInfoHolder,
SiddhiQueryContext siddhiQueryContext) |
static Operator |
OperatorParser.constructOperator(Object storeEvents,
io.siddhi.query.api.expression.Expression expression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
static Operator |
OperatorParser.constructOperatorForCache(Object storeEvents,
io.siddhi.query.api.expression.Expression expression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext,
boolean updateCachePolicyAttribute,
CacheTable cacheTable) |
static OutputCallback |
OutputParser.constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
boolean convertToStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
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) |
static OutputRateLimiter |
OutputParser.constructOutputRateLimiter(String id,
io.siddhi.query.api.execution.query.output.ratelimit.OutputRate outputRate,
boolean isGroupBy,
boolean isWindow,
SiddhiQueryContext siddhiQueryContext) |
static Processor |
SingleInputStreamParser.generateProcessor(io.siddhi.query.api.execution.query.input.handler.StreamHandler streamHandler,
MetaComplexEvent metaEvent,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
SiddhiQueryContext siddhiQueryContext) |
static StreamRuntime |
InputStreamParser.parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
io.siddhi.query.api.execution.query.Query query,
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,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
List<VariableExpressionExecutor> executors,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse an InputStream returning corresponding StreamRuntime
|
static Scheduler |
SchedulerParser.parse(Schedulable singleThreadEntryValve,
SiddhiQueryContext siddhiQueryContext)
Create Scheduler object.
|
static QuerySelector |
SelectorParser.parse(io.siddhi.query.api.execution.query.selection.Selector selector,
io.siddhi.query.api.execution.query.output.stream.OutputStream outputStream,
MetaComplexEvent metaComplexEvent,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> variableExpressionExecutors,
int metaPosition,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse Selector portion of a query and return corresponding QuerySelector.
|
static ExpressionExecutor |
ExpressionParser.parseExpression(io.siddhi.query.api.expression.Expression expression,
MetaComplexEvent metaEvent,
int currentState,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> executorList,
boolean groupBy,
int defaultStreamEventIndex,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext)
Parse the given expression and create the appropriate Executor by recursively traversing the expression
|
static StreamRuntime |
JoinInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.JoinInputStream joinInputStream,
io.siddhi.query.api.execution.query.Query query,
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,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap,
List<VariableExpressionExecutor> executors,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext) |
static SingleStreamRuntime |
SingleInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.SingleInputStream inputStream,
List<VariableExpressionExecutor> variableExpressionExecutors,
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,
Map<String,Table> tableMap,
MetaComplexEvent metaComplexEvent,
ProcessStreamReceiver processStreamReceiver,
boolean supportsBatchProcessing,
boolean outputExpectsExpiredEvents,
boolean findToBeExecuted,
boolean multiValue,
SiddhiQueryContext siddhiQueryContext)
Parse single InputStream and return SingleStreamRuntime
|
static StateStreamRuntime |
StateInputStreamParser.parseInputStream(io.siddhi.query.api.execution.query.input.stream.StateInputStream stateInputStream,
MetaStateEvent metaStateEvent,
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,
Map<String,Table> tableMap,
List<VariableExpressionExecutor> variableExpressionExecutors,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
CompiledCondition |
Window.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext)
To construct a finder having the capability of finding events at the processor that corresponds to the incoming
matchingEvent and the given matching expression logic.
|
Copyright © 2019. All rights reserved.