flink1.7.1 dataStream table API 的 distinc问题-问答-阿里云开发者社区-阿里云

开发者社区> 问答> 正文

flink1.7.1 dataStream table API 的 distinc问题

冷丰 2019-01-23 20:23:23 1570
  tenv.registerDataStream("data", dataStream, 'a, 'b, 'c, 'time.rowtime)
  import org.apache.flink.table.api.scala._
  import org.apache.flink.streaming.api.scala._
  order
      .groupBy('a)
      .select('a, 'b.sum.distinct  as 'd )
      .toRetractStream[Row]
    .print()

参照官网文档写的代码,但是distinct 却不能用,求解.

image

Error:(119, 26) method distinct in class DistinctAgg cannot be accessed in org.apache.flink.table.expressions.DistinctAgg

  .select('a, 'b.sum.distinct  as 'd )
API
分享到
取消 提交回答
全部回答(2)
  • IT喵看视界
    2019-10-24 10:04:07

    这个问题我也遇见了,报的是什么不支持操作,但是官网的的确就是这么说的,请问楼主解决了吗?我现在不知道怎么去解决这个问题。自定义有太麻烦了。

    0 0
  • 1426694731350515
    2019-07-17 23:26:46

    路过

    0 0
添加回答
开发与运维
使用钉钉扫一扫加入圈子
+ 订阅

集结各类场景实战经验,助你开发运维畅行无忧

推荐文章
相似问题
推荐课程