动机Flink提供了三种主要的sdk/API来编写程序:TableAPI/SQL、DataStreamAPI和DataSetAPI。我们认为这个API太多了,建议弃用DataSetAPI,而使用TableAPI/SQL和DataStreamAPI。当然,这说起来容易做起来难,所以在下面,我们将概述为什么我们认为太多的api对项目和社区有害。然后,我们将描述如何增强TableAPI/SQL和DataStreamAPI以包含DataSetAPI的功能。在本FLIP中,我们将不描述如何增强TableAPI/SQL和DataStream的所有技术细节。目标是在弃用DataSetAPI的想法上达成共识。
动机Flink提供了三种主要的sdk/API来编写程序:TableAPI/SQL、DataStreamAPI和DataSetAPI。我们认为这个API太多了,建议弃用DataSetAPI,而使用TableAPI/SQL和DataStreamAPI。当然,这说起来容易做起来难,所以在下面,我们将概述为什么我们认为太多的api对项目和社区有害。然后,我们将描述如何增强TableAPI/SQL和DataStreamAPI以包含DataSetAPI的功能。在本FLIP中,我们将不描述如何增强TableAPI/SQL和DataStream的所有技术细节。目标是在弃用DataSetAPI的想法上达成共识。
found:org.apache.spark.sql.Dataset[(Double,Double)]required:org.apache.spark.rdd.RDD[(Double,Double)]我收到以下错误123 found :org.apache.spark.sql.Dataset[(Double,Double)] required:org.apache.spark.rdd.RDD[(Double,Double)] valtestMetrics=newBinaryClassificationMetrics(testScoreAndLabel)关于以下代码:1234valtestS
found:org.apache.spark.sql.Dataset[(Double,Double)]required:org.apache.spark.rdd.RDD[(Double,Double)]我收到以下错误123 found :org.apache.spark.sql.Dataset[(Double,Double)] required:org.apache.spark.rdd.RDD[(Double,Double)] valtestMetrics=newBinaryClassificationMetrics(testScoreAndLabel)关于以下代码:1234valtestS