The LinearRegrWithSGDRun class defines a wrapper function that uses the Aster Spark API and implements the running phase of the Spark MLlib LinearRegressionWithSGD algorithm. The function uses a model that is typically generated by the LinearRegressionWithSGDTrain function.
Run Method Signature
run(input: RDD[DataRow], sparkFunctParams: String): RDD[DataRow]
Parameters
String representing the parameters specific to the function you are implementing. The string has this syntax:
'--option_value_pair [,...]'
option_value_pair is:
-
modelLocation model_location
Required. Specifies the file system or HDFS path to the location of the training model.
Returns
The input data and the predicted value.
Version
Spark 1.3 or later.