public class InsertIntoTableCallback extends OutputCallback
OutputCallback
to receive processed Siddhi events from
Siddhi queries and insert data into a Table
based on received events and condition.Constructor and Description |
---|
InsertIntoTableCallback(Table table,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
boolean convertToStreamEvent,
StreamEventFactory streamEventFactory,
StreamEventConverter streamEventConverter,
String queryName) |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.StreamDefinition |
getOutputStreamDefinition() |
void |
send(ComplexEventChunk complexEventChunk,
int noOfEvents) |
constructMatchingStateEventChunk, setSiddhiDebugger
public InsertIntoTableCallback(Table table, io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition, boolean convertToStreamEvent, StreamEventFactory streamEventFactory, StreamEventConverter streamEventConverter, String queryName)
public void send(ComplexEventChunk complexEventChunk, int noOfEvents)
send
in class OutputCallback
public io.siddhi.query.api.definition.StreamDefinition getOutputStreamDefinition()
Copyright © 2021. All rights reserved.