public class InsertIntoWindowEndPartitionCallback extends InsertIntoWindowCallback
StreamJunction
and Window
.
It receives ComplexEventChunk
s from partitioned queries and insert them into Window
.outputStreamDefinition, window
Constructor and Description |
---|
InsertIntoWindowEndPartitionCallback(Window window,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
String queryName) |
Modifier and Type | Method and Description |
---|---|
void |
send(ComplexEventChunk complexEventChunk,
int noOfEvents)
Add the event into the
Window |
getOutputStreamDefinition, getWindow
constructMatchingStateEventChunk, setSiddhiDebugger
public void send(ComplexEventChunk complexEventChunk, int noOfEvents)
Window
send
in class InsertIntoWindowCallback
complexEventChunk
- the event to addnoOfEvents
- number of eventsCopyright © 2019. All rights reserved.