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