Apache flink dataset



我有数据集数据对象,它将具有50列数据的结果集。现在我想过滤结果集数据集过滤数据,它应该只有 2 列数据。如何做这个 Apache Flink java?

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

相关内容

  • 没有找到相关文章

最新更新