首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    FlinkTable语法的聚合操作

    常用方法 Flink Table 内置的聚合方法包括: sum():求和 count():计数 avg():平均值 min():最小值 max():最大值 stddevPop():计算整个波动总体的标准偏差...stddevSamp():计算样本数据的标准偏差 varPop():计算整个波动总体的方差 varSamp():计算样本数据的方差 另外,Flink Table 还支持自定义聚合方法。...示例 示例: import org.apache.flink.table.api._ import org.apache.flink.table.api.bridge.scala._ import org.apache.flink.api.scala...MyCountAccumulator, id: Long) = acc.count += 1 } class MyCountAccumulator { var count: Long = 0L } } 该示例展示了...Flink Table内置的count/sum/max/min/avg等聚合方法的使用,并在最后展示了如何使用自定义聚合函数。

    56610
    领券