如何在 flink 中使用 multiset？
How to use multiset in flink?
我在flinksql中使用collect()函数，return类型是multiset。
但是，cardinality、char_length、multiset[item]等常用函数都不能用于multiset。
如何获取 multiset 中的元素？
目前对多重集的支持有限。不过，你可以自己定义user-defined functions来对付它们。只要可以使用 Map<X, Integer>，就可以使用 @DataTypeHint("MULTISET<X>")。
我在flinksql中使用collect()函数，return类型是multiset。 但是，cardinality、char_length、multiset[item]等常用函数都不能用于multiset。 如何获取 multiset 中的元素？
目前对多重集的支持有限。不过，你可以自己定义user-defined functions来对付它们。只要可以使用 Map<X, Integer>，就可以使用 @DataTypeHint("MULTISET<X>")。