Hello,
Following QuickStart guide in FlinkML, I have to do the following:
val astroTrain:DataSet[LabeledVector] = MLUtils.readLibSVM(env,
"src/main/resources/svmguide1")
Instead of:
val astroTrain:DataSet[LabeledVector] = MLUtils.readLibSVM(
"src/main/resources/svmguide1")
Nonetheless, this implicit class in ml/packages
implicit class RichExecutionEnvironment(executionEnvironment:
ExecutionEnvironment) {
def readLibSVM(path: String): DataSet[LabeledVector] = {
MLUtils.readLibSVM(executionEnvironment, path)
}
}
is supposed to pimp MLUtils in the way we want.
Does it mean that RichExecutionEnvironment is not imported in the scope ?
What can be done to solve this ?
Thanks
Regards
Thomas