stateCount() 函数

stateCount() 返回给定状态下连续行数。

状态由 fn 谓词函数定义。对于每个评估结果为 true 的连续记录，状态计数会递增。当记录评估结果为 false 时，该值设置为 -1 并且状态计数重置。如果记录在评估期间生成错误，则该点将被丢弃，并且不影响状态计数。状态计数作为附加列添加到每个记录中。

函数类型签名

(<-tables: stream[A], fn: (r: A) => bool, ?column: string) => stream[B] where A: Record, B: Record

参数

fn

（必需） 标识记录状态的谓词函数。

column

存储状态计数的列。默认为 stateCount。

tables

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

示例

计算特定状态下的行数

import "sampledata"

sampledata.int()
    |> stateCount(fn: (r) => r._value < 10)