public class InsertIntoStreamCallback extends OutputCallback
OutputCallback
to receive processed Siddhi events from
Siddhi queries and put them into StreamJunction
.Modifier and Type | Field and Description |
---|---|
protected io.siddhi.query.api.definition.StreamDefinition |
outputStreamDefinition |
protected StreamJunction.Publisher |
publisher |
Constructor and Description |
---|
InsertIntoStreamCallback(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
String queryName) |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.StreamDefinition |
getOutputStreamDefinition() |
void |
init(StreamJunction outputStreamJunction) |
void |
send(ComplexEventChunk complexEventChunk,
int noOfEvents) |
constructMatchingStateEventChunk, setSiddhiDebugger
protected io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition
protected StreamJunction.Publisher publisher
public InsertIntoStreamCallback(io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition, String queryName)
public void init(StreamJunction outputStreamJunction)
public void send(ComplexEventChunk complexEventChunk, int noOfEvents)
send
in class OutputCallback
public io.siddhi.query.api.definition.StreamDefinition getOutputStreamDefinition()
Copyright © 2019. All rights reserved.