Flink中的Broadcast广播变量

在Flink中,同一个算子可能存在若干个不一样的并行实例,计算过程可能不在同一个Slot中进行,不一样算子之间更是如此,所以不一样算子的计算数据之间不能像Java数组之间同样互相访问,而广播变量Broadcast即是解决这种状况的。以下代码所示:javascript val env = ExecutionEnvironment.getExecutionEnvironment val ds1
相关文章
相关标签/搜索