与 "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()
返回指定列中包含唯一值的所有记录。