public class DeleteTableCallback extends OutputCallback
OutputCallback
to receive processed Siddhi events from
Siddhi queries and delete data in a Table
based on received events
and condition.Constructor and Description |
---|
DeleteTableCallback(Table table,
CompiledCondition compiledCondition,
int matchingStreamIndex,
boolean convertToStreamEvent,
StateEventFactory stateEventFactory,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
Modifier and Type | Method and Description |
---|---|
void |
send(ComplexEventChunk deletingEventChunk,
int noOfEvents) |
constructMatchingStateEventChunk, setSiddhiDebugger
public DeleteTableCallback(Table table, CompiledCondition compiledCondition, int matchingStreamIndex, boolean convertToStreamEvent, StateEventFactory stateEventFactory, StreamEventFactory streamEventFactory, StreamEventConverter streamEventConverter, String queryName)
public void send(ComplexEventChunk deletingEventChunk, int noOfEvents)
send
in class OutputCallback
Copyright © 2021. All rights reserved.