Modifier and Type | Method and Description |
---|---|
List<ExpressionExecutor> |
BaseIncrementalValueStore.getExpressionExecutors() |
Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
List<ExpressionExecutor> outputExpressionExecutors,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
boolean isOptimisedLookup,
List<io.siddhi.query.api.execution.query.selection.OutputAttribute> defaultSelectorList,
List<String> groupByVariablesList,
boolean isLatestEventColAdded,
int baseAggregatorBeginIndex,
List<io.siddhi.query.api.expression.Expression> finalBaseExpressionList,
IncrementalDataPurger incrementalDataPurger,
IncrementalExecutorsInitialiser incrementalExecutorInitialiser,
SingleStreamRuntime singleStreamRuntime,
MetaStreamEvent tableMetaStreamEvent,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind) |
BaseIncrementalValueStore(String aggregatorName,
long initialTimestamp,
List<ExpressionExecutor> expressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy,
boolean local) |
IncrementalDataAggregator(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
io.siddhi.query.api.aggregation.TimePeriod.Duration durationToAggregate,
long oldestEventTimestamp,
List<ExpressionExecutor> baseExecutorsForFind,
ExpressionExecutor shouldUpdateTimestamp,
boolean groupBy,
MetaStreamEvent metaStreamEvent) |
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) |
OutOfOrderEventsDataAggregator(List<ExpressionExecutor> baseExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
List<ExpressionExecutor> outputExpressionExecutors,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
boolean isOptimisedLookup,
List<io.siddhi.query.api.execution.query.selection.OutputAttribute> defaultSelectorList,
List<String> groupByVariablesList,
boolean isLatestEventColAdded,
int baseAggregatorBeginIndex,
List<io.siddhi.query.api.expression.Expression> finalBaseExpressionList,
IncrementalDataPurger incrementalDataPurger,
IncrementalExecutorsInitialiser incrementalExecutorInitialiser,
SingleStreamRuntime singleStreamRuntime,
MetaStreamEvent tableMetaStreamEvent,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind) |
AggregationRuntime(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
List<ExpressionExecutor> outputExpressionExecutors,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
ExpressionExecutor shouldUpdateTimestamp,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
boolean isOptimisedLookup,
List<io.siddhi.query.api.execution.query.selection.OutputAttribute> defaultSelectorList,
List<String> groupByVariablesList,
boolean isLatestEventColAdded,
int baseAggregatorBeginIndex,
List<io.siddhi.query.api.expression.Expression> finalBaseExpressionList,
IncrementalDataPurger incrementalDataPurger,
IncrementalExecutorsInitialiser incrementalExecutorInitialiser,
SingleStreamRuntime singleStreamRuntime,
MetaStreamEvent tableMetaStreamEvent,
LatencyTracker latencyTrackerFind,
ThroughputTracker throughputTrackerFind) |
BaseIncrementalValueStore(String aggregatorName,
long initialTimestamp,
List<ExpressionExecutor> expressionExecutors,
ExpressionExecutor shouldUpdateTimestamp,
StreamEventFactory streamEventFactory,
SiddhiQueryContext siddhiQueryContext,
boolean groupBy,
boolean local) |
IncrementalAggregationProcessor(AggregationRuntime aggregationRuntime,
List<ExpressionExecutor> incomingExpressionExecutors,
MetaStreamEvent processedMetaStreamEvent,
LatencyTracker latencyTrackerInsert,
ThroughputTracker throughputTrackerInsert,
SiddhiAppContext siddhiAppContext) |
IncrementalDataAggregator(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
io.siddhi.query.api.aggregation.TimePeriod.Duration durationToAggregate,
long oldestEventTimestamp,
List<ExpressionExecutor> baseExecutorsForFind,
ExpressionExecutor shouldUpdateTimestamp,
boolean groupBy,
MetaStreamEvent metaStreamEvent) |
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) |
OutOfOrderEventsDataAggregator(List<ExpressionExecutor> baseExecutors,
ExpressionExecutor shouldUpdateTimestamp,
GroupByKeyGenerator groupByKeyGenerator,
MetaStreamEvent metaStreamEvent) |
Modifier and Type | Class and Description |
---|---|
class |
ConstantExpressionExecutor
Executor class for Constant Siddhi expressions.
|
class |
MultiValueVariableFunctionExecutor
Executor class for Siddhi event attribute that produces multiple values.
|
class |
VariableExpressionExecutor
Executor class for Siddhi event attributes.
|
Modifier and Type | Method and Description |
---|---|
protected StateFactory |
MultiValueVariableFunctionExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Class and Description |
---|---|
class |
AndConditionExpressionExecutor
Executor class for And condition.
|
class |
BoolConditionExpressionExecutor
Executor class for Boolean condition.
|
class |
ConditionExpressionExecutor
Super class for Condition Executors.
|
class |
InConditionExpressionExecutor
Executor class for In condition.
|
class |
IsNullConditionExpressionExecutor
Executor class for IsNull condition.
|
class |
IsNullStreamConditionExpressionExecutor
Executor class for IsNullStream condition.
|
class |
NotConditionExpressionExecutor
Executor class for Not condition.
|
class |
OrConditionExpressionExecutor
Executor class for Or condition.
|
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor |
BoolConditionExpressionExecutor.conditionExecutor |
protected ExpressionExecutor |
OrConditionExpressionExecutor.leftConditionExecutor |
protected ExpressionExecutor |
AndConditionExpressionExecutor.leftConditionExecutor |
protected ExpressionExecutor |
OrConditionExpressionExecutor.rightConditionExecutor |
protected ExpressionExecutor |
AndConditionExpressionExecutor.rightConditionExecutor |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
AndConditionExpressionExecutor.getLeftConditionExecutor() |
ExpressionExecutor |
AndConditionExpressionExecutor.getRightConditionExecutor() |
Constructor and Description |
---|
AndConditionExpressionExecutor(ExpressionExecutor leftConditionExecutor,
ExpressionExecutor rightConditionExecutor) |
BoolConditionExpressionExecutor(ExpressionExecutor conditionExecutor) |
IsNullConditionExpressionExecutor(ExpressionExecutor expressionExecutor) |
NotConditionExpressionExecutor(ExpressionExecutor conditionExecutor) |
OrConditionExpressionExecutor(ExpressionExecutor leftConditionExecutor,
ExpressionExecutor rightConditionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
CompareConditionExpressionExecutor
Parent Executor class for Compare conditions.
|
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor |
CompareConditionExpressionExecutor.leftExpressionExecutor |
protected ExpressionExecutor |
CompareConditionExpressionExecutor.rightExpressionExecutor |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
CompareConditionExpressionExecutor.getLeftExpressionExecutor() |
ExpressionExecutor |
CompareConditionExpressionExecutor.getRightExpressionExecutor() |
Constructor and Description |
---|
CompareConditionExpressionExecutor(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
EqualCompareConditionExpressionExecutor
Parent Executor class for Equal condition.
|
class |
EqualCompareConditionExpressionExecutorBoolBool
Executor class for Boolean-Boolean Equal condition.
|
class |
EqualCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Equal condition.
|
class |
EqualCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Equal condition.
|
class |
EqualCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Equal condition.
|
class |
EqualCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Equal condition.
|
class |
EqualCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Equal condition.
|
class |
EqualCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Equal condition.
|
class |
EqualCompareConditionExpressionExecutorFloatInt
Executor class for Float-Int Equal condition.
|
class |
EqualCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Equal condition.
|
class |
EqualCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Equal condition.
|
class |
EqualCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Equal condition.
|
class |
EqualCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Equal condition.
|
class |
EqualCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Equal condition.
|
class |
EqualCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Equal condition.
|
class |
EqualCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Equal condition.
|
class |
EqualCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Equal condition.
|
class |
EqualCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Equal condition.
|
class |
EqualCompareConditionExpressionExecutorStringString
Executor class for String-String Equal condition.
|
Modifier and Type | Class and Description |
---|---|
class |
GreaterThanCompareConditionExpressionExecutor
Parent Executor class for GreaterThan condition.
|
class |
GreaterThanCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorFloatInt
Executor class for Float-Integer Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Greater Than condition.
|
class |
GreaterThanCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Greater Than condition.
|
Modifier and Type | Class and Description |
---|---|
class |
GreaterThanEqualCompareConditionExpressionExecutor
Parent Executor class for Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorFloatInt
Executor class for Float-Integer Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Greater Than or Equal condition.
|
class |
GreaterThanEqualCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Greater Than or Equal condition.
|
Modifier and Type | Class and Description |
---|---|
class |
LessThanCompareConditionExpressionExecutor
Parent Executor class for Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorFloatInt
Executor class for Float-Integer Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Less Than condition.
|
class |
LessThanCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Less Than condition.
|
Modifier and Type | Class and Description |
---|---|
class |
LessThanEqualCompareConditionExpressionExecutor
Parent Executor class for Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorFloatInt
Executor class for Float-Integer Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Less Than or Equal condition.
|
class |
LessThanEqualCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Less Than or Equal condition.
|
Modifier and Type | Class and Description |
---|---|
class |
NotEqualCompareConditionExpressionExecutor
Parent Executor class for Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorBoolBool
Executor class for Boolean-Boolean Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorDoubleDouble
Executor class for Double-Double Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorDoubleFloat
Executor class for Double-Float Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorDoubleInt
Executor class for Double-Integer Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorDoubleLong
Executor class for Double-Long Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorFloatDouble
Executor class for Float-Double Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorFloatFloat
Executor class for Float-Float Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorFloatInt
Executor class for Float-Integer Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorFloatLong
Executor class for Float-Long Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorIntDouble
Executor class for Integer-Double Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorIntFloat
Executor class for Integer-Float Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorIntInt
Executor class for Integer-Integer Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorIntLong
Executor class for Integer-Long Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorLongDouble
Executor class for Long-Double Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorLongFloat
Executor class for Long-Float Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorLongInt
Executor class for Long-Integer Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorLongLong
Executor class for Long-Long Not Equal condition.
|
class |
NotEqualCompareConditionExpressionExecutorStringString
Executor class for String-String Not Equal condition.
|
Modifier and Type | Class and Description |
---|---|
class |
CastFunctionExecutor
Executor class for Siddhi cast function.
|
class |
CoalesceFunctionExecutor
Executor class for coalesce function.
|
class |
ConvertFunctionExecutor
Executor class for convert function.
|
class |
CreateSetFunctionExecutor
Executor class for createSet function.
|
class |
CurrentTimeMillisFunctionExecutor
Executor class for getting Siddhi application timestamp.
|
class |
DefaultFunctionExecutor
Executor class for default function.
|
class |
EventTimestampFunctionExecutor
Executor class for Siddhi cast function.
|
class |
FunctionExecutor<S extends State>
Parent abstract class for Function Executors.
|
class |
IfThenElseFunctionExecutor
Executor class for ifThenElse function.
|
class |
InstanceOfBooleanFunctionExecutor
Executor class for instanceOf Boolean function.
|
class |
InstanceOfDoubleFunctionExecutor
Executor class for instanceOf Double function.
|
class |
InstanceOfFloatFunctionExecutor
Executor class for instanceOf Double function.
|
class |
InstanceOfIntegerFunctionExecutor
Executor class for instanceOf Integer function.
|
class |
InstanceOfLongFunctionExecutor
Executor class for instanceOf Long function.
|
class |
InstanceOfStringFunctionExecutor
Executor class for instanceOf String function.
|
class |
MaximumFunctionExecutor
Executor class for Maximum function.
|
class |
MinimumFunctionExecutor
Executor class for Minimum function.
|
class |
ScriptFunctionExecutor
Executor class for Script function.
|
class |
SizeOfSetFunctionExecutor
Executor class for sizeOfSet function.
|
class |
UUIDFunctionExecutor
Executor class for UUID function.
|
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor[] |
FunctionExecutor.attributeExpressionExecutors |
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 | Class and Description |
---|---|
class |
IncrementalAggregateBaseTimeFunctionExecutor
Executor class for finding the start time and end time of the within clause in incremental processing.
|
class |
IncrementalShouldUpdateFunctionExecutor
Execute class for shouldUpdate() function.
|
class |
IncrementalStartTimeEndTimeFunctionExecutor
Executor class for finding the start time and end time of the within clause in incremental processing.
|
class |
IncrementalTimeGetTimeZone
Executor class for retrieving the timezone from a string timeStamp.
|
class |
IncrementalUnixTimeFunctionExecutor
Executor class for converting string timestamp to unix time in incremental processing.
|
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) |
Modifier and Type | Class and Description |
---|---|
class |
AddExpressionExecutorDouble
Executor class for Double Add function.
|
class |
AddExpressionExecutorFloat
Executor class for Float Add function.
|
class |
AddExpressionExecutorInt
Executor class for Integer Add function.
|
class |
AddExpressionExecutorLong
Executor class for Long Add function.
|
Constructor and Description |
---|
AddExpressionExecutorDouble(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
AddExpressionExecutorFloat(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
AddExpressionExecutorInt(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
AddExpressionExecutorLong(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
DivideExpressionExecutorDouble
Executor class for Double Divide function.
|
class |
DivideExpressionExecutorFloat
Executor class for Float Divide function.
|
class |
DivideExpressionExecutorInt
Executor class for Integer Divide function.
|
class |
DivideExpressionExecutorLong
Executor class for Long Divide function.
|
Constructor and Description |
---|
DivideExpressionExecutorDouble(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
DivideExpressionExecutorFloat(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
DivideExpressionExecutorInt(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
DivideExpressionExecutorLong(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
ModExpressionExecutorDouble
Executor class for Double Modulus function.
|
class |
ModExpressionExecutorFloat
Executor class for Float Modulus function.
|
class |
ModExpressionExecutorInt
Executor class for Integer Modulus function.
|
class |
ModExpressionExecutorLong
Executor class for Long Modulus function.
|
Constructor and Description |
---|
ModExpressionExecutorDouble(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
ModExpressionExecutorFloat(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
ModExpressionExecutorInt(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
ModExpressionExecutorLong(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
MultiplyExpressionExecutorDouble
Executor class for Double Multiply function.
|
class |
MultiplyExpressionExecutorFloat
Executor class for Float Multiply function.
|
class |
MultiplyExpressionExecutorInt
Executor class for Integer Multiply function.
|
class |
MultiplyExpressionExecutorLong
Executor class for Long Multiply function.
|
Constructor and Description |
---|
MultiplyExpressionExecutorDouble(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
MultiplyExpressionExecutorFloat(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
MultiplyExpressionExecutorInt(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
MultiplyExpressionExecutorLong(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Modifier and Type | Class and Description |
---|---|
class |
SubtractExpressionExecutorDouble
Executor class for Double subtract function.
|
class |
SubtractExpressionExecutorFloat
Executor class for Float subtract function.
|
class |
SubtractExpressionExecutorInt
Executor class for Integer subtract function.
|
class |
SubtractExpressionExecutorLong
Executor class for Long subtract function.
|
Constructor and Description |
---|
SubtractExpressionExecutorDouble(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
SubtractExpressionExecutorFloat(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
SubtractExpressionExecutorInt(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
SubtractExpressionExecutorLong(ExpressionExecutor leftExpressionExecutor,
ExpressionExecutor rightExpressionExecutor) |
Constructor and Description |
---|
ValuePartitionExecutor(ExpressionExecutor expressionExecutor) |
Constructor and Description |
---|
FilterProcessor(ExpressionExecutor conditionExecutor) |
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor[] |
AbstractStreamProcessor.attributeExpressionExecutors |
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 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) |
Modifier and Type | Class and Description |
---|---|
class |
AndAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate sum based on an event attribute. |
class |
AttributeAggregatorExecutor<S extends State>
Abstract parent class for attribute aggregators.
|
class |
AvgAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate average based on an event attribute. |
class |
CountAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate count. |
class |
DistinctCountAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate distinct count based on an event attribute. |
class |
MaxAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate max value based on an event attribute. |
class |
MaxForeverAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate max value for life time based on an event attribute. |
class |
MinAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate min value based on an event attribute. |
class |
MinForeverAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate min value for life time based on an event attribute. |
class |
OrAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate sum based on an event attribute. |
class |
StdDevAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate standard deviation based on an event attribute. |
class |
SumAttributeAggregatorExecutor
AttributeAggregatorExecutor to calculate sum based on an event attribute. |
class |
UnionSetAttributeAggregatorExecutor
AttributeAggregatorExecutor to return a union of an aggregation of sets. |
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor[] |
AttributeAggregatorExecutor.attributeExpressionExecutors |
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 |
---|---|
ExpressionExecutor |
AttributeProcessor.getExpressionExecutor() |
Constructor and Description |
---|
AttributeProcessor(ExpressionExecutor expressionExecutor) |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
InMemoryCompiledCondition.getUpdateOrInsertExpressionExecutor() |
Modifier and Type | Method and Description |
---|---|
Map<Integer,ExpressionExecutor> |
InMemoryCompiledUpdateSet.getExpressionExecutorMap() |
Constructor and Description |
---|
InMemoryCompiledCondition(CompiledCondition operatorCompiledCondition,
ExpressionExecutor updateOrInsertExpressionExecutor,
int storeEventIndex) |
Constructor and Description |
---|
InMemoryCompiledUpdateSet(Map<Integer,ExpressionExecutor> expressionExecutorMap) |
Modifier and Type | Field and Description |
---|---|
protected Map<String,ExpressionExecutor> |
AbstractRecordTable.RecordStoreCompiledCondition.variableExpressionExecutorMap |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
ExpressionBuilder.getInMemorySetExpressionExecutor() |
Modifier and Type | Method and Description |
---|---|
Map<String,ExpressionExecutor> |
RecordTableCompiledUpdateSet.getExpressionExecutorMap() |
Modifier and Type | Method and Description |
---|---|
List<Object[]> |
UpdateOrInsertReducer.reduceEventsForInsert(List<Object[]> failedRecords,
Map<String,ExpressionExecutor> inMemorySetExecutors) |
void |
RecordTableCompiledUpdateSet.setExpressionExecutorMap(Map<String,ExpressionExecutor> expressionExecutorMap) |
Constructor and Description |
---|
UpdateOrInsertReducer(ExpressionExecutor inMemoryCompiledCondition,
MatchingMetaInfoHolder matchingMetaInfoHolder) |
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor |
CompareCollectionExecutor.expressionExecutor |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
CompareCollectionExecutor.getValueExpressionExecutor() |
Modifier and Type | Method and Description |
---|---|
List<ExpressionExecutor> |
AndMultiPrimaryKeyCollectionExecutor.getMultiPrimaryKeyExpressionExecutors() |
Constructor and Description |
---|
CompareCollectionExecutor(ExpressionExecutor expressionExecutor,
int storeEventIndex,
String attribute,
io.siddhi.query.api.expression.condition.Compare.Operator operator,
ExpressionExecutor valueExpressionExecutor,
CacheTable cacheTable) |
ExhaustiveCollectionExecutor(ExpressionExecutor expressionExecutor,
int storeEventIndex) |
NonAndCollectionExecutor(ExpressionExecutor valueExpressionExecutor,
CollectionExecutor aCollectionExecutor,
CollectionExpression.CollectionScope collectionScope) |
NonCollectionExecutor(ExpressionExecutor expressionExecutor) |
Constructor and Description |
---|
AndMultiPrimaryKeyCollectionExecutor(String compositePrimaryKey,
List<ExpressionExecutor> multiPrimaryKeyExpressionExecutors,
CacheTable cacheTable) |
Modifier and Type | Field and Description |
---|---|
protected ExpressionExecutor |
CollectionOperator.expressionExecutor |
protected ExpressionExecutor |
SnapshotableEventQueueOperator.expressionExecutor |
protected ExpressionExecutor |
EventChunkOperator.expressionExecutor |
Modifier and Type | Method and Description |
---|---|
ExpressionExecutor |
SnapshotableEventQueueOperator.getExpressionExecutor() |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
IncrementalAggregateCompileCondition.find(StateEvent matchingEvent,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
ExpressionExecutor shouldUpdateTimestamp) |
Modifier and Type | Method and Description |
---|---|
StreamEvent |
IncrementalAggregateCompileCondition.find(StateEvent matchingEvent,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,List<ExpressionExecutor>> aggregateProcessingExecutorsMap,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,GroupByKeyGenerator> groupByKeyGeneratorMap,
ExpressionExecutor shouldUpdateTimestamp) |
Constructor and Description |
---|
CollectionOperator(ExpressionExecutor expressionExecutor,
int storeEventPosition) |
EventChunkOperator(ExpressionExecutor expressionExecutor,
int storeEventPosition) |
IncrementalAggregateCompileCondition(boolean isOnDemandQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap,
List<ExpressionExecutor> outputExpressionExecutors,
boolean isOptimisedLookup,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition,
CompiledCondition onCompiledCondition,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
List<ExpressionExecutor> timestampFilterExecutors,
MetaStreamEvent aggregateMetaSteamEvent,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
MatchingMetaInfoHolder matchingHolderInfoForTableLookups,
List<VariableExpressionExecutor> variableExpExecutorsForTableLookups) |
MapOperator(ExpressionExecutor expressionExecutor,
int storeEventPosition) |
SnapshotableEventQueueOperator(ExpressionExecutor expressionExecutor,
int storeEventPosition) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isOnDemandQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap,
List<ExpressionExecutor> outputExpressionExecutors,
boolean isOptimisedLookup,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition,
CompiledCondition onCompiledCondition,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
List<ExpressionExecutor> timestampFilterExecutors,
MetaStreamEvent aggregateMetaSteamEvent,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
MatchingMetaInfoHolder matchingHolderInfoForTableLookups,
List<VariableExpressionExecutor> variableExpExecutorsForTableLookups) |
IncrementalAggregateCompileCondition(boolean isOnDemandQuery,
String aggregationName,
boolean isProcessingOnExternalTime,
boolean isDistributed,
List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTableMap,
List<ExpressionExecutor> outputExpressionExecutors,
boolean isOptimisedLookup,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledSelection> withinTableCompiledSelection,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableCompiledConditions,
CompiledCondition inMemoryStoreCompileCondition,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,CompiledCondition> withinTableLowerGranularityCompileCondition,
CompiledCondition onCompiledCondition,
List<io.siddhi.query.api.definition.Attribute> additionalAttributes,
ExpressionExecutor perExpressionExecutor,
ExpressionExecutor startTimeEndTimeExpressionExecutor,
List<ExpressionExecutor> timestampFilterExecutors,
MetaStreamEvent aggregateMetaSteamEvent,
MatchingMetaInfoHolder alteredMatchingMetaInfoHolder,
MatchingMetaInfoHolder matchingHolderInfoForTableLookups,
List<VariableExpressionExecutor> variableExpExecutorsForTableLookups) |
Modifier and Type | Method and Description |
---|---|
static void |
InputParameterValidator.validateExpressionExecutors(Object objectHavingAnnotation,
ExpressionExecutor[] attributeExpressionExecutors)
The method which validates the extension specific parameters of siddhi App with the pattern specified in the
ParameterOverload annotation in the extension class |
Modifier and Type | Method and Description |
---|---|
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
|
Copyright © 2019. All rights reserved.