Project over window(项目窗口(Project over window))¶
Supported in: Batch, Faster, Streaming
Performs the specified aggregations on the data within the window. Emits one row each time a new row is received.
Transform categories: Aggregate
Declared arguments¶
- Dataset: Dataset to perform aggregations on.
Table - Expressions: List of expressions to evaluate over the window.
List\> - Window: Window to group data by.
Window
中文翻译¶
项目窗口(Project over window)¶
支持:批处理(Batch)、快速处理(Faster)、流处理(Streaming)
对窗口内的数据执行指定的聚合操作。每次接收到新行时输出一行。
转换类别:聚合(Aggregate)
声明的参数¶
- 数据集(Dataset): 要执行聚合操作的数据集。
表(Table) - 表达式(Expressions): 要在窗口内评估的表达式列表。
列表\<表达式\<任意类型>>(List\>) - 窗口(Window): 用于对数据进行分组的窗口。
窗口(Window)