草庐IT

chickenpox_dataset

全部标签

Flink整合面向用户的数据流SDKs/API(Flink关于弃用Dataset API的论述)

动机Flink提供了三种主要的sdk/API来编写程序:TableAPI/SQL、DataStreamAPI和DataSetAPI。我们认为这个API太多了,建议弃用DataSetAPI,而使用TableAPI/SQL和DataStreamAPI。当然,这说起来容易做起来难,所以在下面,我们将概述为什么我们认为太多的api对项目和社区有害。然后,我们将描述如何增强TableAPI/SQL和DataStreamAPI以包含DataSetAPI的功能。在本FLIP中,我们将不描述如何增强TableAPI/SQL和DataStream的所有技术细节。目标是在弃用DataSetAPI的想法上达成共识。

Flink整合面向用户的数据流SDKs/API(Flink关于弃用Dataset API的论述)

动机Flink提供了三种主要的sdk/API来编写程序:TableAPI/SQL、DataStreamAPI和DataSetAPI。我们认为这个API太多了,建议弃用DataSetAPI,而使用TableAPI/SQL和DataStreamAPI。当然,这说起来容易做起来难,所以在下面,我们将概述为什么我们认为太多的api对项目和社区有害。然后,我们将描述如何增强TableAPI/SQL和DataStreamAPI以包含DataSetAPI的功能。在本FLIP中,我们将不描述如何增强TableAPI/SQL和DataStream的所有技术细节。目标是在弃用DataSetAPI的想法上达成共识。

关于 scala:found: org.apache.spark.sql.Dataset[(Double, Double)] 需要: org.apache.spark.rdd.RDD[(Double, Double)]

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

关于 scala:found: org.apache.spark.sql.Dataset[(Double, Double)] 需要: org.apache.spark.rdd.RDD[(Double, Double)]

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