hadoop自学要多久 Flink中与sparkPairFunction对应的是什么?

Flink中与sparkPairFunction对应的是什么?Flink是一个类似于spark的开源技术栈,因为它还提供批处理、流式计算、图形计算、交互式查询、机器学习等功能。Flink也是内存计算,

Flink中与sparkPairFunction对应的是什么?

Flink是一个类似于spark的开源技术栈,因为它还提供批处理、流式计算、图形计算、交互式查询、机器学习等功能。Flink也是内存计算,与spark类似,但不同的是spark的计算模型是基于RDD的,即流式计算作为一种特殊的批处理,其数据流实际上是RDD。而Flink把批处理看作是一种特殊的流计算,而批处理和流计算的引擎是两个:抽象数据集和数据流。弗林克的表演也很好。流计算的时延小于spark,可以实现真正的流计算,而spark只能是准流计算。此外,在批处理中,当迭代次数增加时,Flink的速度比spark快。因此,如果Flink出现得更早,它可能会比spark更受欢迎。

开发Flink应用选择Java还是Scala?

根据个人编程习惯,可以使用Java和scala。