public class UpdateTableCallback extends OutputCallback
OutputCallback
to receive processed Siddhi events from
Siddhi queries and update data into a Table
based on received events and condition.Constructor and Description |
---|
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 |
---|---|
void |
send(ComplexEventChunk updatingEventChunk,
int noOfEvents) |
constructMatchingStateEventChunk, setSiddhiDebugger
public UpdateTableCallback(Table table, CompiledCondition compiledCondition, CompiledUpdateSet compiledUpdateSet, int matchingStreamIndex, boolean convertToStreamEvent, StateEventFactory stateEventFactory, StreamEventFactory streamEventFactory, StreamEventConverter streamEventConverter, String queryName)
public void send(ComplexEventChunk updatingEventChunk, int noOfEvents)
send
in class OutputCallback
Copyright © 2019. All rights reserved.