Flink的廣播變量和廣播狀態

一、dataStreaming中的broadcast 把元素廣播給全部的分區,數據會被重複處理php dataStream.broadcast()java 二、機器級別的廣播 廣播變量容許編程人員在每臺機器上保持1個只讀的緩存變量,而不是傳送變量的副本給tasks。 廣播變量建立後,它能夠運行在集羣中的任何function上,而不須要屢次傳遞給集羣節點。另外須要記住,不該該修改廣播變量,這樣才能確
相關文章
相關標籤/搜索