阿帕奇flink數據集

Question

我有DataSet數據對象，它將有50列數據的結果集。現在我想過濾結果集DataSet filteredData，它應該只有2列數據。如何做到這一點Apache Flink的Java？

Answer 1

val intNumbers：DataSet [Int] = // [...] val naturalNumbers = intNumbers.filter {row1，row2}