Apache flink Dataset

Question

Ich habe DataSet-Datenobjekt, das Resultset von 50 Spalten Daten haben wird. Jetzt möchte ich die Ergebnismenge DataSet filteredData filtern, die nur 2 Spalten Daten haben sollte. Wie macht man Apache Flink Java?

Answer 1

val intNumbers: DataSet [Int] = // [...] val naturalNumbers = intNumbers.filter {row1, row2}