跳转至

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)