【文件属性】：
文件名称：flink-memory-buffer:Apache Flink的内存缓冲区
文件大小：10KB
文件格式：ZIP
更新时间：2021-03-07 03:02:44
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)