Package | Description |
---|---|
io.siddhi.core.query | |
io.siddhi.core.query.output.callback | |
io.siddhi.core.query.output.ratelimit | |
io.siddhi.core.util.parser |
Modifier and Type | Method and Description |
---|---|
OutputCallback |
QueryRuntime.getOutputCallback() |
Constructor and Description |
---|
QueryRuntime(io.siddhi.query.api.execution.query.Query query,
StreamRuntime streamRuntime,
QuerySelector selector,
OutputRateLimiter outputRateLimiter,
OutputCallback outputCallback,
MetaComplexEvent metaComplexEvent,
SiddhiQueryContext siddhiQueryContext) |
Modifier and Type | Class and Description |
---|---|
class |
DeleteTableCallback
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and delete data in a Table based on received events
and condition. |
class |
InsertIntoStreamCallback
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and put them into StreamJunction . |
class |
InsertIntoStreamEndPartitionCallback
Implementation of
OutputCallback to receive processed Siddhi events from partitioned
Siddhi queries and put them into StreamJunction . |
class |
InsertIntoTableCallback
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and insert data into a Table
based on received events and condition. |
class |
InsertIntoWindowCallback
This callback is an adapter between
StreamJunction and Window . |
class |
InsertIntoWindowEndPartitionCallback
This callback is an adapter between
StreamJunction and Window . |
class |
UpdateOrInsertTableCallback
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and insert/update data into a Table
based on received events and condition. |
class |
UpdateTableCallback
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and update data into a Table
based on received events and condition. |
Modifier and Type | Field and Description |
---|---|
protected OutputCallback |
OutputRateLimiter.outputCallback |
Modifier and Type | Method and Description |
---|---|
OutputCallback |
OutputRateLimiter.getOutputCallback() |
Modifier and Type | Method and Description |
---|---|
void |
OutputRateLimiter.setOutputCallback(OutputCallback outputCallback) |
Modifier and Type | Method and Description |
---|---|
static OutputCallback |
OutputParser.constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
Map<String,Table> tableMap,
Map<String,Window> eventWindowMap,
boolean convertToStreamEvent,
SiddhiQueryContext siddhiQueryContext) |
static OutputCallback |
OutputParser.constructOutputCallback(io.siddhi.query.api.execution.query.output.stream.OutputStream outStream,
String key,
ConcurrentMap<String,StreamJunction> streamJunctionMap,
io.siddhi.query.api.definition.StreamDefinition outputStreamDefinition,
SiddhiQueryContext siddhiQueryContext) |
Copyright © 2019. All rights reserved.