experimental.count() 函数

experimental.count() 返回每个输入表中的记录数。

计数在 _value 列中返回，并计算空值和非空值记录。

空表计数

experimental.count() 对于空表返回 0。要在数据中保留空表，请在使用以下函数时设置以下参数

filter(onEmpty: "keep")
window(createEmpty: true)
aggregateWindow(createEmpty: true)

函数类型签名

(<-tables: stream[{A with _value: B}]) => stream[{A with _value: int}]

参数

tables

输入数据。默认为管道转发数据 (<-)。

示例

计算表中的行数

import "experimental"
import "sampledata"

sampledata.int()
    |> experimental.count()