public class InsertIntoWindowCallback extends OutputCallback
StreamJunction
and Window
.
It receives ComplexEventChunk
s and insert them into Window
.Modifier and Type | Field and Description |
---|---|
protected io.siddhi.query.api.definition.StreamDefinition |
outputStreamDefinition
StreamDefinition of the window.
|
protected Window |
window
Window to which the events have to be inserted.
|
Constructor and Description |
---|
InsertIntoWindowCallback(Window window,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
String queryName) |
Modifier and Type | Method and Description |
---|---|
io.siddhi.query.api.definition.StreamDefinition |
getOutputStreamDefinition()
Return the StreamDefinition of the corresponding window.
|
Window |
getWindow()
Return the
Window associated with this callback. |
void |
send(ComplexEventChunk complexEventChunk,
int noOfEvents)
Add the event into the
Window |
constructMatchingStateEventChunk, setSiddhiDebugger
protected final Window window
protected final io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition
public void send(ComplexEventChunk complexEventChunk, int noOfEvents)
Window
send
in class OutputCallback
complexEventChunk
- the event to addnoOfEvents
- number of eventspublic io.siddhi.query.api.definition.StreamDefinition getOutputStreamDefinition()
Copyright © 2021. All rights reserved.