如何在flink中使用多集?

  • 本文关键字:flink apache-flink
  • 更新时间 :
  • 英文 :


我在 flink sql 中使用collect()函数,返回类型是多集。 但是,诸如基数、char_length、多集[项]等常用函数都不能用于多集。 如何获取多集元素?

目前对多集的支持有限。但是,您可以定义自己的用户定义函数来处理它们。使用@DataTypeHint("MULTISET<X>")可以在任何可以使用Map<X, Integer>的地方使用。

相关内容

  • 没有找到相关文章