Apache flinkデータセット

Question

私は50カラムデータの結果セットを持つDataSetデータオブジェクトを持っています。今私は2列のデータだけを持つべき結果セットDataSet filteredDataをフィルタリングしたいと思います。どのようにこのApache Flink Javaを行うには？

Answer 1

ヴァルのintNumbers：データセット[INT] = // [...] ヴァルnaturalNumbers = intNumbers.filter {ROW1、ROW2}