Search code examples
apache-flink

Apache flink dataset

I have DataSet data object which will have result set of 50 columns data. Now I want to filter the result set DataSet filteredData which should have only 2 columns data. How to do this Apache Flink java?

Solution

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