我在flink sql中使用了collect（）函数，返回类型为multiset，但是常用的函数如**cardinality、char_length、multiset[item]**都不能用于multiset，如何获取multiset中的元素？
ekqde3dh1#
目前对多重集的支持是有限的。但是，你可以定义你自己的user-defined functions来处理它们。使用@DataTypeHint("MULTISET<X>")可以在任何可以使用Map<X, Integer>的地方使用。
@DataTypeHint("MULTISET<X>")
Map<X, Integer>
1条答案
按热度按时间ekqde3dh1#
目前对多重集的支持是有限的。但是，你可以定义你自己的user-defined functions来处理它们。使用
@DataTypeHint("MULTISET<X>")可以在任何可以使用Map<X, Integer>的地方使用。