但问题是RegressionMetrics接受RDD[(Double, Double)],而output的格式是DStream[Double,Double]。如何将output转换为RDD[(Double, Double)]以便能够使用RegressionMetrics
val model = new StreamingLinearRegressionWithSGD
我已经尝试了这个中的步骤,但没有成功,而且我得到了一个no known conversion for argument 4 from ‘Function {aka std::function<double(double)>}’ to ‘double (*)(double)’错误。# include <functional>
typedef std::function<dou
open Systemopen MathNet.Numerics.LinearAlgebra.Double
This expression was expected to have type Func<float, 'a> but here has type double ->double
但是我需要能够传递映射函数,而不是像m3那样内联地定义它。