将 Flink scala 转换为 java

Question

将 Flink scala 转换为 java

4

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)”会导致编译器错误：

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

- sthiers

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Till Rohrmann · Accepted Answer

目前，FlinkML仅支持使用Scala。原因是FlinkML配备了灵活的管道机制，允许您轻松构建数据分析管道。这些管道可以包含任意数量的Estimators和单个尾随的Predictor。

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

理论上，可以手动构建这些管道。但是，这是一个繁琐的过程，因此，如果要与FlinkML交互，请建议您简单地使用Flink的Scala API。