阿帕奇flink数据集
问题描述:
我有DataSet数据对象,它将有50列数据的结果集。现在我想过滤结果集DataSet filteredData,它应该只有2列数据。如何做到这一点Apache Flink的Java?阿帕奇flink数据集
答
val intNumbers:DataSet [Int] = // [...] val naturalNumbers = intNumbers.filter {row1,row2}