Constructor and Description |
---|
RecordTableHandler() |
Modifier and Type | Method and Description |
---|---|
void |
add(long timestamp,
List<Object[]> records) |
abstract void |
add(long timestamp,
List<Object[]> records,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
boolean |
contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
abstract boolean |
contains(long timestamp,
Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
void |
delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
abstract void |
delete(long timestamp,
List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
Iterator<Object[]> |
find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
abstract Iterator<Object[]> |
find(long timestamp,
Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
String |
getId() |
abstract StateFactory<S> |
init(String id,
io.siddhi.query.api.definition.TableDefinition tableDefinition)
Initialize the Record Table Handler
|
protected void |
init(io.siddhi.query.api.definition.TableDefinition tableDefinition,
RecordTableHandlerCallback recordTableHandlerCallback,
SiddhiAppContext siddhiAppContext) |
Iterator<Object[]> |
query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
Iterator<Object[]> |
query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
abstract Iterator<Object[]> |
query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
abstract Iterator<Object[]> |
query(long timestamp,
Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
RecordTableHandlerCallback recordTableHandlerCallback,
S state)
Deprecated.
|
void |
update(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps) |
abstract void |
update(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
RecordTableHandlerCallback recordTableHandlerCallback,
S state) |
void |
updateOrAdd(long timestamp,
CompiledCondition compiledCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetMap,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
abstract void |
updateOrAdd(long timestamp,
CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
LinkedHashMap<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords,
RecordTableHandlerCallback recordTableHandlerCallback) |
protected final void init(io.siddhi.query.api.definition.TableDefinition tableDefinition, RecordTableHandlerCallback recordTableHandlerCallback, SiddhiAppContext siddhiAppContext)
public String getId()
public abstract StateFactory<S> init(String id, io.siddhi.query.api.definition.TableDefinition tableDefinition)
id
- is the generated id for the record table handlertableDefinition
- is the definition of the table with annotations if anypublic void add(long timestamp, List<Object[]> records) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract void add(long timestamp, List<Object[]> records, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the last event in the event chunkrecords
- records that need to be added to the table, each Object[] represent a
record and it will match the attributes of the Table Definition.recordTableHandlerCallback
- call back to do operations on the record tablestate
- current stateConnectionUnavailableException
public void delete(long timestamp, List<Map<String,Object>> deleteConditionParameterMaps, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract void delete(long timestamp, List<Map<String,Object>> deleteConditionParameterMaps, CompiledCondition compiledCondition, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the last event in the event chunkdeleteConditionParameterMaps
- map of matching StreamVariable Ids and their values corresponding to the
compiled conditioncompiledCondition
- the compiledCondition against which records should be matched for deletionrecordTableHandlerCallback
- call back to do operations on the record tablestate
- current stateConnectionUnavailableException
public void update(long timestamp, CompiledCondition compiledCondition, List<Map<String,Object>> updateConditionParameterMaps, LinkedHashMap<String,CompiledExpression> updateSetMap, List<Map<String,Object>> updateSetParameterMaps) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract void update(long timestamp, CompiledCondition updateCondition, List<Map<String,Object>> updateConditionParameterMaps, LinkedHashMap<String,CompiledExpression> updateSetExpressions, List<Map<String,Object>> updateSetParameterMaps, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the last event in the event chunkupdateCondition
- the compiledCondition against which records should be matched for updateupdateConditionParameterMaps
- map of matching StreamVariable Ids and their values corresponding to the
compiled condition based on which the records will be updatedupdateSetExpressions
- the set of updates mappings and related complied expressionsupdateSetParameterMaps
- map of matching StreamVariable Ids and their values corresponding to therecordTableHandlerCallback
- call back to do operations on the record tablestate
- current stateConnectionUnavailableException
public void updateOrAdd(long timestamp, CompiledCondition compiledCondition, List<Map<String,Object>> updateConditionParameterMaps, LinkedHashMap<String,CompiledExpression> updateSetMap, List<Map<String,Object>> updateSetParameterMaps, List<Object[]> addingRecords) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract void updateOrAdd(long timestamp, CompiledCondition updateCondition, List<Map<String,Object>> updateConditionParameterMaps, LinkedHashMap<String,CompiledExpression> updateSetExpressions, List<Map<String,Object>> updateSetParameterMaps, List<Object[]> addingRecords, RecordTableHandlerCallback recordTableHandlerCallback) throws ConnectionUnavailableException
timestamp
- the timestamp of the last event in the event chunkupdateCondition
- the compiledCondition against which records should be matched for updateupdateConditionParameterMaps
- map of matching StreamVariable Ids and their values corresponding to the
compiled condition based on which the records will be updatedupdateSetExpressions
- the set of updates mappings and related complied expressionsupdateSetParameterMaps
- map of matching StreamVariable Ids and their values corresponding to the
update setaddingRecords
- the values for adding new records if the update condition did not matchrecordTableHandlerCallback
- call back to do operations on the record tableConnectionUnavailableException
public Iterator<Object[]> find(long timestamp, Map<String,Object> findConditionParameterMap, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract Iterator<Object[]> find(long timestamp, Map<String,Object> findConditionParameterMap, CompiledCondition compiledCondition, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the event used to match from record tablefindConditionParameterMap
- map of matching StreamVariable Ids and their values
corresponding to the compiled conditioncompiledCondition
- the compiledCondition against which records should be matchedrecordTableHandlerCallback
- call back to do operations on the record tablestate
- ConnectionUnavailableException
public boolean contains(long timestamp, Map<String,Object> containsConditionParameterMap, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public abstract boolean contains(long timestamp, Map<String,Object> containsConditionParameterMap, CompiledCondition compiledCondition, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the event used to match from record tablecontainsConditionParameterMap
- map of matching StreamVariable Ids and their values corresponding to the
compiled conditioncompiledCondition
- the compiledCondition against which records should be matchedrecordTableHandlerCallback
- call back to do operations on the record tablestate
- current stateConnectionUnavailableException
@Deprecated public Iterator<Object[]> query(long timestamp, Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection) throws ConnectionUnavailableException
ConnectionUnavailableException
public Iterator<Object[]> query(long timestamp, Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection, io.siddhi.query.api.definition.Attribute[] outputAttributes) throws ConnectionUnavailableException
ConnectionUnavailableException
@Deprecated public abstract Iterator<Object[]> query(long timestamp, Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
timestamp
- the timestamp of the event used to match from record tableparameterMap
- map of matching StreamVariable Ids and their values
corresponding to the compiled condition and selectioncompiledCondition
- the compiledCondition against which records should be matchedcompiledSelection
- the compiledSelection which maps the events based on selectionrecordTableHandlerCallback
- call back to do operations on the record tablestate
- current stateConnectionUnavailableException
public abstract Iterator<Object[]> query(long timestamp, Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection, io.siddhi.query.api.definition.Attribute[] outputAttributes, RecordTableHandlerCallback recordTableHandlerCallback, S state) throws ConnectionUnavailableException
ConnectionUnavailableException
Copyright © 2019. All rights reserved.