Table#
Represents a tabular data structure. |
|
Stream tables are tables that support real-time data ingestion |
|
Abstract base class representing a streaming engine. |
StreamEngine#
The stream broadcast engine distributes the same data stream to different target tables. |
|
The time-series streaming engine conducts real-time time-series calculations with moving windows. |
|
The cross-sectional streaming engine is used for real-time computing on cross-sectional data, which is a collection of observations (behaviors) for multiple subjects (entities such as different stocks) at a single point in time. |
|
The reactive state streaming engine maintains and updates states for stateful computations, ensuring efficient processing of continuous data streams. |