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

Reply via email to