Modifier and Type | Field and Description |
---|---|
protected ProcessingMode |
FunctionExecutor.processingMode |
Modifier and Type | Method and Description |
---|---|
void |
FunctionExecutor.initExecutor(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
ConfigReader configReader,
boolean groupBy,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
StreamRuntime.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
JoinStreamRuntime.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
SingleStreamRuntime.getProcessingMode() |
Constructor and Description |
---|
SingleStreamRuntime(ProcessStreamReceiver processStreamReceiver,
Processor processorChain,
ProcessingMode overallProcessingMode,
MetaComplexEvent metaComplexEvent) |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
StateStreamRuntime.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
static ProcessingMode |
ProcessingMode.findUpdatedProcessingMode(ProcessingMode currentProcessingMode,
ProcessingMode updatingProcessingMode) |
static ProcessingMode |
ProcessingMode.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ProcessingMode[] |
ProcessingMode.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static ProcessingMode |
ProcessingMode.findUpdatedProcessingMode(ProcessingMode currentProcessingMode,
ProcessingMode updatingProcessingMode) |
Modifier and Type | Method and Description |
---|---|
abstract ProcessingMode |
AbstractStreamProcessor.getProcessingMode()
Defines the behaviour of the processing, will be called after the init
|
ProcessingMode |
LogStreamProcessor.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
StreamFunctionProcessor.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
WindowWindowProcessor.getProcessingMode() |
ProcessingMode |
BatchingWindowProcessor.getProcessingMode() |
ProcessingMode |
GroupingWindowProcessor.getProcessingMode() |
ProcessingMode |
SlidingWindowProcessor.getProcessingMode() |
ProcessingMode |
HopingWindowProcessor.getProcessingMode() |
Modifier and Type | Method and Description |
---|---|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinAttributeAggregatorExecutor.MinAggregatorState> |
MinAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory |
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.MaxForeverAttributeAggregatorExecutor.MaxAggregatorState> |
MaxForeverAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected abstract StateFactory<S> |
AttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.CountAttributeAggregatorExecutor.AggregatorState> |
CountAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.MinForeverAttributeAggregatorExecutor.MinAggregatorState> |
MinForeverAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.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.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.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.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.UnionSetAttributeAggregatorExecutor.AggregatorState> |
UnionSetAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.AvgAttributeAggregatorExecutor.AvgAttributeState> |
AvgAttributeAggregatorExecutor.init(ExpressionExecutor[] attributeExpressionExecutors,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
ConfigReader configReader,
SiddhiQueryContext siddhiQueryContext)
The initialization method for FunctionExecutor
|
protected StateFactory<io.siddhi.core.query.selector.attribute.aggregator.SumAttributeAggregatorExecutor.AggregatorState> |
SumAttributeAggregatorExecutor.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 |
---|---|
static CollectionExecutor |
CollectionExpressionParser.buildCollectionExecutor(CollectionExpression collectionExpression,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
boolean isFirst,
ProcessingMode processingMode,
boolean outputExpectsExpiredEvents,
SiddhiQueryContext siddhiQueryContext) |
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
|
Modifier and Type | Method and Description |
---|---|
ProcessingMode |
Window.getProcessingMode() |
Copyright © 2019. All rights reserved.