Flink的广播变量和广播状态

一、dataStreaming中的broadcast 把元素广播给全部的分区,数据会被重复处理php dataStream.broadcast()java 二、机器级别的广播 广播变量容许编程人员在每台机器上保持1个只读的缓存变量,而不是传送变量的副本给tasks。 广播变量建立后,它能够运行在集群中的任何function上,而不须要屡次传递给集群节点。另外须要记住,不该该修改广播变量,这样才能确
相关文章
相关标签/搜索