为什么我们在flink源代码中有flink-streaming-java和flink-streaming-scala模块

Question

在Fink源中，有flink-stream-java和flink-stream-scala模块。为什么我们需要两个模块才能进行弗林链接？

https://github.com/apache/flink/tree/master/master/flink-streaming-java

https://github.com/apache/flink/tree/master/master/flink-streaming-scala

Answer 1

flink-stream-java和flink-stream-scala都提供了类似的API来管理Flink Streams；您只需要使用其中一种，具体取决于您的语言。

请注意，无论您选择哪种选择， flink-runtime和 flink-clients之类的依赖项都取决于scala（2.11或2.12）的版本，因为Flink基于scala中编写的框架，AKKA。

。

持续不断从更高级别的API中删除scala的依赖性，flink-table（Flink-111063）。

Answer 2

flink-stream-java 是流的Java API的实现。 Flink-Stream-Scala 是Scala API的流动。因此，您可以在 flink-stream-java 中找到datastream.java，以及 flink-stream-scala 中的datastream.scala。

Answer 3

这两个模块将完成相同的功能，但是不同的开发人员会收到不同的语言，而个人任务Scala更适合在大数据，flink Spark等语言中使用的操作员描述。