Flink 广播流、广播状态和广播变量的区别 - 深入解析

Flink 中的广播流、广播状态和广播变量都可以用于在任务并行执行期间共享数据，但它们在功能和使用方式上有所不同。

1. 广播流（Broadcast Stream）： 广播流是一种特殊的流，它将数据广播到所有并行任务中。广播流可以通过调用broadcast()方法将数据广播到下游算子中，这样每个并行任务都可以获取到相同的广播数据。广播流适用于在任务并行执行期间共享较小的数据集，如配置参数、静态数据等。

2. 广播状态（Broadcast State）： 广播状态是一种特殊的状态，它可以在任务并行执行期间共享数据。广播状态是通过调用broadcastState()方法将数据广播到下游算子中，这样每个并行任务都可以访问相同的广播状态。广播状态适用于需要在任务并行执行期间共享较大的数据集，如维度表、字典等。

3. 广播变量（Broadcast Variable）： 广播变量是一种特殊的变量，它可以在任务并行执行期间共享数据。广播变量可以通过调用withBroadcastSet()方法将数据广播到下游算子中，这样每个并行任务都可以访问相同的广播变量。广播变量适用于需要在任务并行执行期间共享较小的数据集，如配置参数、静态数据等。

总结： 广播流、广播状态和广播变量都可以用于在任务并行执行期间共享数据，但广播流适用于较小的数据集，广播状态适用于较大的数据集，而广播变量适用于较小的数据集。