Modifier and Type | Class and Description |
---|---|
class |
MetaStateEvent
Class to hold mapping between StreamEvents and respective StateEvent.
|
Modifier and Type | Method and Description |
---|---|
static StateEventPopulator |
StateEventPopulatorFactory.constructEventPopulator(MetaComplexEvent metaComplexEvent)
Constructs StateEventPopulator according to MetaStateEvent
|
Modifier and Type | Class and Description |
---|---|
class |
MetaStreamEvent
Class to hold meta info about StreamEvent.
|
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
QueryRuntime.getMetaComplexEvent() |
Constructor and Description |
---|
QueryRuntime(io.siddhi.query.api.execution.query.Query query,
StreamRuntime streamRuntime,
QuerySelector selector,
OutputRateLimiter outputRateLimiter,
OutputCallback outputCallback,
MetaComplexEvent metaComplexEvent,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
StreamRuntime.getMetaComplexEvent() |
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
JoinStreamRuntime.getMetaComplexEvent() |
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
SingleStreamRuntime.getMetaComplexEvent() |
Constructor and Description |
---|
SingleStreamRuntime(ProcessStreamReceiver processStreamReceiver,
Processor processorChain,
ProcessingMode overallProcessingMode,
MetaComplexEvent metaComplexEvent) |
Modifier and Type | Method and Description |
---|---|
MetaComplexEvent |
StateStreamRuntime.getMetaComplexEvent() |
Modifier and Type | Method and Description |
---|---|
void |
WrappedSnapshotOutputRateLimiter.init(int outPutAttributeSize,
List<AttributeProcessor> attributeProcessorList,
MetaComplexEvent metaComplexEvent) |
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) |
Modifier and Type | Method and Description |
---|---|
static MatchingMetaInfoHolder |
MatcherParser.constructMatchingMetaStateHolder(MetaComplexEvent matchingMetaComplexEvent,
int defaultStreamEventIndex,
io.siddhi.query.api.definition.AbstractDefinition candsidateDefinition,
int currentState) |
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 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 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,
SiddhiQueryContext siddhiQueryContext)
Parse single InputStream and return SingleStreamRuntime
|
Modifier and Type | Method and Description |
---|---|
static void |
QueryParserHelper.initStreamRuntime(StreamRuntime runtime,
MetaComplexEvent metaComplexEvent,
LockWrapper lockWrapper,
String queryName) |
static void |
QueryParserHelper.reduceMetaComplexEvent(MetaComplexEvent metaComplexEvent) |
static void |
QueryParserHelper.updateVariablePosition(MetaComplexEvent metaComplexEvent,
List<VariableExpressionExecutor> variableExpressionExecutorList) |
Copyright © 2019. All rights reserved.