Class | Description |
---|---|
DeleteTableCallback |
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and delete data in a Table based on received events
and condition. |
InsertIntoStreamCallback |
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and put them into StreamJunction . |
InsertIntoStreamEndPartitionCallback |
Implementation of
OutputCallback to receive processed Siddhi events from partitioned
Siddhi queries and put them into StreamJunction . |
InsertIntoTableCallback |
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and insert data into a Table
based on received events and condition. |
InsertIntoWindowCallback |
This callback is an adapter between
StreamJunction and Window . |
InsertIntoWindowEndPartitionCallback |
This callback is an adapter between
StreamJunction and Window . |
OutputCallback |
Abstract class to represent parent callback implementation which allows users to get processed events from Siddhi
queries.
|
QueryCallback |
Query Callback is used to get resulting output events from a Siddhi query.
|
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. |
UpdateTableCallback |
Implementation of
OutputCallback to receive processed Siddhi events from
Siddhi queries and update data into a Table
based on received events and condition. |
Copyright © 2019. All rights reserved.