文件名称：flink-memory-buffer:Apache Flink的内存缓冲区
文件大小：10KB
文件格式：ZIP
更新时间：2024-03-26 20:49:24
Scala
flink内存缓冲区 Apache Flink的内存中缓冲区，可用于在某些数据偏斜情况下实现更高的吞吐量。 写出： : 用法： import org . apache . flink . streaming . api . scala . _ import extensions . _ import FlinkOps . _ val env : StreamExecutionEnvironment = ??? val words = Seq ( " this " , " is " , " a " , " list " , " of " , " words " ) env.fromCollection(words) .map(word => (word, 1 )) .keyingBy { case (word, _) => word } .buffer( Tim
【文件预览】：
flink-memory-buffer-main
----project()
--------build.properties(18B)
--------plugins.sbt(56B)
----src()
--------test()
--------main()
----LICENSE(1KB)
----build.sbt(613B)
----README.md(785B)
----.gitignore(19B)
----.scalafmt.conf(242B)