与 "Selectors" 相关
aggregateWindow() 函数
aggregateWindow() 通过将数据分组到固定的时间窗口中,并将聚合或选择器函数应用于每个窗口,从而对数据进行降采样。
bottom() 函数
bottom() 按指定的列对每个输入表进行排序,并在每个表中保留最底部的 n 条记录。
distinct() 函数
distinct() 返回指定列中的所有唯一值。
experimental.distinct() 函数
experimental.distinct() 从 _value 列返回唯一值。
experimental.first() 函数
experimental.first() 为每个输入表返回 _value 列中第一个非空值的记录。
experimental.last() 函数
experimental.last() 为每个输入表返回 _value 列中最后一个非空值的记录。
experimental.max() 函数
experimental.max() 为每个输入表返回 _value 列中值最高的记录。
experimental.min() 函数
experimental.min() 为每个输入表返回 _value 列中值最低的记录。
experimental.quantile() 函数
experimental.quantile() 返回 _value 列中值落在指定分位数内或表示指定分位数的非空记录。
experimental.unique() 函数
experimental.unique() 返回 _value 列中包含唯一值的所有记录。
first() 函数
first() 从每个输入表返回第一个非空记录。
highestAverage() 函数
highestAverage() 计算每个输入表的平均值,并返回最高的 n 个平均值。
highestCurrent() 函数
highestCurrent() 从每个输入表选择最后一条记录,并返回最高的 n 条记录。
highestMax() 函数
highestMax() 从每个输入表的指定 column 中选择值最高的记录,并返回最高的 n 条记录。
last() 函数
last() 从每个输入表返回具有非空值的最后一行。
limit() 函数
limit() 从每个输入表返回指定 offset 之后的第一个 n 行。
lowestAverage() 函数
lowestAverage() 计算每个输入表的平均值,并返回最低的 n 个平均值。
lowestCurrent() 函数
lowestCurrent() 从每个输入表选择最后一条记录,并返回最低的 n 条记录。
lowestMin() 函数
lowestMin() 从每个输入表的指定 column 中选择值最低的记录,并返回最底部的 n 条记录。
max() 函数
max() 从每个输入表返回指定列中具有最大值的行。
median() 函数
median() 返回输入表的中间 _value 值,或输入表中所有值落在 0.5 分位数(第 50 百分位数)内的非空记录。
min() 函数
min() 从每个输入表返回指定列中具有最小值的行。
quantile() 函数
quantile() 从每个输入表返回值落在指定分位数内的行,或返回具有表示指定分位数的值的行。
sample() 函数
sample() 从每个输入表中选择行的子集。
top() 函数
top() 按指定的列对每个输入表进行排序,并在每个表中保留最顶部的 n 条记录。
unique() 函数
unique() 返回指定列中包含唯一值的所有记录。