使用Java OutputFormat发出Scala元组

Question

我正在尝试为ArangoDB编写一个自定义的ArangoDB。我使用CassandraOutputFormat.java作为灵感，交换了相关的驱动程序和调用等等。我用Java编写了这篇文章，因为我找不到OutputFormat的Scala示例。因此，该类的定义如下：

public class ArangoOutputFormat<OUT extends Tuple> extends RichOutputFormat<OUT>

现在，我想要写入ArangoDB的Flink程序是用Scala编写的。dataset test是DataSet[Tuple2[Long, Long]]。写到ArangoDB的调用如下所示：

test.output(
  new ArangoOutputFormat[(Long, Long)]()
);

但是，在编译时，我会得到以下错误：

错误：(47，11)类型参数(长、长)不符合类ArangoOutputFormat的类型参数界限<：org.apache.flink.api.java.tuple.Tuple新ArangoOutputFormat(Long，Long)

在使用Scala和Java类时，我通常对类型系统感到有点困惑，有人能解释一下这里发生了什么吗？

谢谢你，罗伯

Answer 1

ArangoOutputFormat被输入到Flink的Java (org.apache.flink.api.java.tuple.Tuple)，而您的Scala程序则使用Scala的元组。Flink的Java元组与Scala的元组不兼容。您需要显式地创建Java元组，例如在接收器之前的Mapper中。