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