@Override
    public void update(ComplexEventChunk<StateEvent> updatingEventChunk, CompiledCondition compiledCondition,
                       CompiledUpdateSet compiledUpdateSet) {
        RecordStoreCompiledCondition recordStoreCompiledCondition =
                ((RecordStoreCompiledCondition) compiledCondition);
        RecordTableCompiledUpdateSet recordTableCompiledUpdateSet = (RecordTableCompiledUpdateSet) compiledUpdateSet;
        List<Map<String, Object>> updateConditionParameterMaps = new ArrayList<>();
        List<Map<String, Object>> updateSetParameterMaps = new ArrayList<>();
        updatingEventChunk.reset();
        long timestamp = 0L;
        while (updatingEventChunk.hasNext()) {
            StateEvent stateEvent = updatingEventChunk.next();

            Map<String, Object> variableMap = new HashMap<>();
            for (Map.Entry<String, ExpressionExecutor> entry :
                    recordStoreCompiledCondition.variableExpressionExecutorMap.entrySet()) {
                variableMap.put(entry.getKey(), entry.getValue().execute(stateEvent));
            }
            updateConditionParameterMaps.add(variableMap);

            Map<String, Object> variableMapForUpdateSet = new HashMap<>();
            for (Map.Entry<String, ExpressionExecutor> entry :
                    recordTableCompiledUpdateSet.getExpressionExecutorMap().entrySet()) {
                variableMapForUpdateSet.put(entry.getKey(), entry.getValue().execute(stateEvent));
            }
            updateSetParameterMaps.add(variableMapForUpdateSet);
            timestamp = stateEvent.getTimestamp();
        }
        try {
            if (recordTableHandler != null) {
                recordTableHandler.update(timestamp, recordStoreCompiledCondition.getCompiledCondition(),
                        updateConditionParameterMaps, recordTableCompiledUpdateSet.getUpdateSetMap(),
                        updateSetParameterMaps);
            } else {
                update(recordStoreCompiledCondition.getCompiledCondition(), updateConditionParameterMaps,
                        recordTableCompiledUpdateSet.getUpdateSetMap(), updateSetParameterMaps);
            }
        } catch (ConnectionUnavailableException | DatabaseRuntimeException e) {
            onUpdateError(updatingEventChunk, compiledCondition, compiledUpdateSet, e
            );
        }
    }
Delete all matching records

@param deleteConditionParameterMaps map of matching StreamVariable Ids and their values corresponding to the
                                    compiled condition
@param compiledCondition            the compiledCondition against which records should be matched for deletion
@throws ConnectionUnavailableException
modules/siddhi-core/src/main/java/io/siddhi/core/table/record/AbstractRecordTable.java