开发者社区> 问答> 正文

flink1.7.1 dataStream table API 的 distinc问题

冷丰 2019-01-23 20:23:23 531
  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
分享到
取消 提交回答
全部回答(1)

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

推荐文章
相似问题