複数のキーにデータセットをグループ化する方法は？

Question

私はHashMapsのDatasetを持っており、私はgroupByをそのキーの1つで実行しました。

data.groupBy(_("a")).groupBy(_("b")).reducegroup {....} 

方法：今、私はすでにグループ化されたDataSet（すなわち、ネストされたかgroupByの連鎖一種）例えば

上にもう1つ（または複数）groupByを実行したい、私はこのような何かをしたいと思います私はこれを行うことができるでしょうか？

Answer 1

ネストされたgroupByは、Flinkではサポートされていません。 あなたはしかし、あなたは、複合キーで使用することはできませんKeySelectorsをあなたの例では、複合キー

val data: (Int, Int, Long) = ??? 
val res = data.groupBy(0, 1).reduce(...) 

上のグループを使用していることができます。代わりに、両方のキーをTuple2として返すKeySelectorを定義できます。

data.groupBy(d => (d("a"), d("b"))).reduce(...)