This has to do with not doing a wildcard import of the Scala api, it was reported and already fixed on master [1]
[1] http://apache-flink-mailing-list-archive.1008284.n3.nabble.com/jira-Created-FLINK-4792-Update-documentation-QuickStart-FlinkML-td13936.html -- Sent from a mobile device. May contain autocorrect errors. On Oct 20, 2016 2:06 PM, "Thomas FOURNIER" <thomasfournier...@gmail.com> wrote: > 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 >
