Translate Flink scala into java

Question

Flink文档给出了SVM算法的scala示例:

val trainingDS: DataSet[LabeledVector] = env.readLibSVM(pathToTrainingFile)
val svm = SVM()
.setBlocks(10)
// Learn the SVM model
svm.fit(trainingDS)

对"fit"的调用如何转换为java?

(java表达式"svm.fit(trainingDS)"给出java编译器错误:

" SVM类型中的fit(DataSet, ParameterMap, FitOperation)方法不适用于参数(DataSet)")

Answer 1

目前，FlinkML只能与Scala一起使用。原因是FlinkML带有灵活的管道机制，允许您轻松构建数据分析管道。这些管道可以由任意数量的Estimators和单个尾随的Predictor组成。

该机制的实现依赖于封装程序逻辑的类型类。通过将类型类声明为隐式值来自动检索和链接它们。因此，Scala编译器将确保执行正确的程序逻辑。

理论上，可以手工构建这些管道。然而，这是一个费力的过程，因此，如果您想与FlinkML交互，我建议您使用Flink的Scala API。