0
DataSet<Tuple2<Integer, Point>>をtuple2の整数値に従ってn個のDataSetsに分割したいと思います。flinkデータセットをキーで複数に分割し、別々のファイルに書き込む
現在、私は基本的にデータセットをn回フィルタリングし、各結果を別々のファイルに保存しています。私はより良い、より多様な方法を持っていることを好むでしょう。また、これはフリンク能力を利用していないようです。
詳細情報が必要な場合はお知らせください。