Package | Description |
---|---|
io.siddhi.core.table | |
io.siddhi.core.table.record | |
io.siddhi.core.util.collection.operator |
Modifier and Type | Class and Description |
---|---|
class |
InMemoryCompiledCondition
Compiled condition created for
InMemoryTable |
Modifier and Type | Class and Description |
---|---|
class |
AbstractQueryableRecordTable.CompiledSelectionWithCache
class to hold both store compile selection and cache compile selection wrapped
|
class |
RecordStoreCompiledCondition
Compiled condition of the
AbstractRecordTable |
Modifier and Type | Method and Description |
---|---|
protected abstract CompiledExpression |
AbstractRecordTable.compileSetAttribute(ExpressionBuilder expressionBuilder)
Compiles the expression in a set clause
|
Modifier and Type | Method and Description |
---|---|
LinkedHashMap<String,CompiledExpression> |
RecordTableCompiledUpdateSet.getUpdateSetMap() |
Modifier and Type | Method and Description |
---|---|
void |
RecordTableCompiledUpdateSet.put(String attributeName,
CompiledExpression compiledExpression) |
Modifier and Type | Method and Description |
---|---|
void |
RecordTableHandlerCallback.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps) |
protected abstract void |
AbstractRecordTable.update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps)
Update all matching records
|
void |
RecordTableHandler.update(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps) |
abstract void |
RecordTableHandler.update(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
void |
RecordTableHandlerCallback.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
protected abstract void |
AbstractRecordTable.updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords)
Try updating the records if they exist else add the records
|
void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
abstract void |
RecordTableHandler.updateOrAdd(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords,
RecordTableHandlerCallback recordTableHandlerCallback) |
Modifier and Type | Interface and Description |
---|---|
interface |
CompiledCondition
Represent a logical expression
|
interface |
CompiledSelection
Represent a selection
|
interface |
Operator
Interface for Operators related to collection of events.
|
Modifier and Type | Class and Description |
---|---|
class |
CollectionOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
EventChunkOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
IncrementalAggregateCompileCondition
Defines the logic to find a matching event from an incremental aggregator (retrieval from incremental aggregator),
based on the logical conditions defined herewith.
|
class |
IndexOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
IndexOperatorForCache
Extension of IndexOperator that implements handleCachePolicyAttributeUpdate for cache usage
|
class |
MapOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
OverwriteTableIndexOperator
Operator which is related to non-indexed In-memory table operations.
|
class |
OverwriteTableIndexOperatorForCache
Extension of IndexOperatorForCache with overwrite for update or add
|
class |
SnapshotableEventQueueOperator
Operator which is related to non-indexed In-memory table operations.
|
Copyright © 2021. All rights reserved.