Modifier and Type | Method and Description |
---|---|
Collection<Table> |
SiddhiAppRuntime.getTables() |
Constructor and Description |
---|
SiddhiAppRuntime(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,
InputManager inputManager,
Map<String,QueryRuntime> queryProcessorMap,
Map<String,StreamJunction> streamJunctionMap,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
ConcurrentMap<String,AggregationRuntime> aggregationMap,
Map<String,List<Source>> sourceMap,
Map<String,List<Sink>> sinkMap,
Map<String,PartitionRuntime> partitionMap,
SiddhiAppContext siddhiAppContext,
Map<String,SiddhiAppRuntime> siddhiAppRuntimeMap) |
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) |
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 |
---|
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) |
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) |
IncrementalExecutorsInitialiser(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
boolean isDistributed,
String shardId,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
IncrementalExecutorsInitialiser(List<io.siddhi.query.api.aggregation.TimePeriod.Duration> incrementalDurations,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,Table> aggregationTables,
Map<io.siddhi.query.api.aggregation.TimePeriod.Duration,IncrementalExecutor> incrementalExecutorMap,
boolean isDistributed,
String shardId,
SiddhiAppContext siddhiAppContext,
MetaStreamEvent metaStreamEvent,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
Constructor and Description |
---|
InConditionExpressionExecutor(Table table,
CompiledCondition compiledCondition,
int streamEventSize,
boolean isMatchingEventAStateEvent,
int matchingStreamIndex) |
Constructor and Description |
---|
FindStoreQueryRuntime(Table table,
CompiledCondition compiledCondition,
String queryName,
MetaStreamEvent metaStreamEvent) |
Constructor and Description |
---|
DeleteTableCallback(Table table,
CompiledCondition compiledCondition,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
InsertIntoTableCallback(Table table,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
boolean convertToStreamEvent,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateOrInsertTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
UpdateTableCallback(Table table,
CompiledCondition compiledCondition,
CompiledUpdateSet compiledUpdateSet,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
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 |
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 |
TableWindowProcessor.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 |
WindowWindowProcessor.compileCondition(io.siddhi.query.api.expression.Expression condition,
MatchingMetaInfoHolder matchingMetaInfoHolder,
List<VariableExpressionExecutor> variableExpressionExecutors,
Map<String,Table> tableMap,
SiddhiQueryContext siddhiQueryContext) |
CompiledCondition |
SlidingFindableWindowProcessor.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 |
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 |
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 |
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.
|
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.
|
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 |
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) |
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) |
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.
|
Constructor and Description |
---|
TableWindowProcessor(Table table) |
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 | Class and Description |
---|---|
class |
CacheTable
common interface for FIFO, LRU, and LFU cache tables
|
class |
CacheTableFIFO
cache table with FIFO entry removal
|
class |
CacheTableLFU
cache table with FIFO entry removal
|
class |
CacheTableLRU
cache table with LRU entry removal
|
class |
InMemoryTable
In-memory event table implementation of SiddhiQL.
|
Modifier and Type | Field and Description |
---|---|
Map<String,Table> |
Table.tableMap |
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) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueryableRecordTable
An abstract implementation of table.
|
class |
AbstractRecordTable
An abstract implementation of table.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Table> |
ExpressionBuilder.getTableMap() |
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) |
Modifier and Type | Method and Description |
---|---|
ConcurrentMap<String,Table> |
SiddhiAppRuntimeBuilder.getTableMap() |
Constructor and Description |
---|
CacheExpirer(long retentionPeriod,
InMemoryTable cacheTable,
Map<String,Table> tableMap,
AbstractQueryableRecordTable storeTable,
SiddhiAppContext siddhiAppContext) |
Constructor and Description |
---|
IncrementalAggregateCompileCondition(boolean isStoreQuery,
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 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> |
StoreQueryParser.buildExpectedOutputAttributes(io.siddhi.query.api.execution.query.StoreQuery storeQuery,
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 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 AggregationRuntime |
AggregationParser.parse(io.siddhi.query.api.definition.AggregationDefinition aggregationDefinition,
SiddhiAppContext siddhiAppContext,
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,
SiddhiAppRuntimeBuilder siddhiAppRuntimeBuilder) |
static StreamRuntime |
InputStreamParser.parse(io.siddhi.query.api.execution.query.input.stream.InputStream inputStream,
List<io.siddhi.query.api.expression.Variable> queryGroupByList,
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 QueryRuntime |
QueryParser.parse(io.siddhi.query.api.execution.query.Query query,
SiddhiAppContext siddhiAppContext,
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,AggregationRuntime> aggregationMap,
Map<String,Window> windowMap,
LockSynchronizer lockSynchronizer,
String queryIndex,
boolean partitioned,
String partitionId)
Parse a query and return corresponding QueryRuntime.
|
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 StoreQueryRuntime |
StoreQueryParser.parse(io.siddhi.query.api.execution.query.StoreQuery storeQuery,
SiddhiAppContext siddhiAppContext,
Map<String,Table> tableMap,
Map<String,Window> windowMap,
Map<String,AggregationRuntime> aggregationMap) |
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,
List<io.siddhi.query.api.expression.Variable> queryGroupByList,
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,
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 |
---|---|
static void |
DefinitionParserHelper.addTable(io.siddhi.query.api.definition.TableDefinition tableDefinition,
ConcurrentMap<String,Table> tableMap,
SiddhiAppContext siddhiAppContext) |
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.
|
void |
Window.init(Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
String windowName,
boolean findToBeExecuted)
Initialize the WindowEvent table by creating
WindowProcessor to handle the events. |
Copyright © 2019. All rights reserved.