public class RecordTableHandlerCallback extends Object
AbstractRecordTable
after being handled by
RecordTableHandler
.Modifier and Type | Method and Description |
---|---|
void |
add(List<Object[]> records) |
boolean |
contains(Map<String,Object> containsConditionParameterMap,
CompiledCondition compiledCondition) |
void |
delete(List<Map<String,Object>> deleteConditionParameterMaps,
CompiledCondition compiledCondition) |
RecordIterator<Object[]> |
find(Map<String,Object> findConditionParameterMap,
CompiledCondition compiledCondition) |
Iterator<Object[]> |
query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection)
Deprecated.
|
Iterator<Object[]> |
query(Map<String,Object> parameterMap,
CompiledCondition compiledCondition,
CompiledSelection compiledSelection,
io.siddhi.query.api.definition.Attribute[] outputAttributes) |
void |
update(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps) |
void |
updateOrAdd(CompiledCondition updateCondition,
List<Map<String,Object>> updateConditionParameterMaps,
Map<String,CompiledExpression> updateSetExpressions,
List<Map<String,Object>> updateSetParameterMaps,
List<Object[]> addingRecords) |
public void add(List<Object[]> records) throws ConnectionUnavailableException
ConnectionUnavailableException
public RecordIterator<Object[]> find(Map<String,Object> findConditionParameterMap, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public boolean contains(Map<String,Object> containsConditionParameterMap, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public void delete(List<Map<String,Object>> deleteConditionParameterMaps, CompiledCondition compiledCondition) throws ConnectionUnavailableException
ConnectionUnavailableException
public void update(CompiledCondition updateCondition, List<Map<String,Object>> updateConditionParameterMaps, Map<String,CompiledExpression> updateSetExpressions, List<Map<String,Object>> updateSetParameterMaps) throws ConnectionUnavailableException
ConnectionUnavailableException
public void updateOrAdd(CompiledCondition updateCondition, List<Map<String,Object>> updateConditionParameterMaps, Map<String,CompiledExpression> updateSetExpressions, List<Map<String,Object>> updateSetParameterMaps, List<Object[]> addingRecords) throws ConnectionUnavailableException
ConnectionUnavailableException
public Iterator<Object[]> query(Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection, io.siddhi.query.api.definition.Attribute[] outputAttributes) throws ConnectionUnavailableException
ConnectionUnavailableException
@Deprecated public Iterator<Object[]> query(Map<String,Object> parameterMap, CompiledCondition compiledCondition, CompiledSelection compiledSelection) throws ConnectionUnavailableException
ConnectionUnavailableException
Copyright © 2021. All rights reserved.