在fink source中，有 flink-stream-java 以及 flink-stream-scala 模块。为什么flink流媒体需要两个模块？
https://github.com/apache/flink/tree/master/flink-streaming-java
https://github.com/apache/flink/tree/master/flink-streaming-scala
在fink source中，有 flink-stream-java 以及 flink-stream-scala 模块。为什么flink流媒体需要两个模块？
https://github.com/apache/flink/tree/master/flink-streaming-java
https://github.com/apache/flink/tree/master/flink-streaming-scala
2条答案
按热度按时间wb1gzix01#
两者
flink-stream-java以及flink-stream-scala提供一个类似的api来管理flink流；你只需要使用其中一种，这取决于你的语言。请注意，无论您选择什么，一些依赖项
flink-runtime以及flink-clients依赖于scala（2.11或2.12），因为flink是基于scala， akka 。目前正在努力消除
akka依赖于更高级别的api，flink-table（flink-11063）。55ooxyrt2#
flinkstreamjava是流的javaapi实现。flink stream scala是scala api for stream的实现。所以您可以在flink stream java中找到datastream.java，在flink stream scala中找到datastream.scala。