Apache Flink中的广播状态实用指南

自版本1.5.0以来，ApacheF 提供了一种新的状态类型，称为广播状态（Broadcast State）。在本文中，我们会解释什么是广播状态，并通过一个例子，演示如何将其应用于一个用来评估基于事件流的动态模式的应用程序。本文将指导大家学习广播状态的处理步骤和相关的源代码，以便在今后的实践中能实现此类的应用。

什么是广播状态？

广播状态可以用于通过一个特定的方式来组合并共同处理两个事件流。第一个流的事件被广播到另一个operator的所有并发实例，这些事件将被保存为状态。另一个流的事件不会被广播，而是发送给同一个operator的各个实例，并与广播流的事件一起处理。广播状态非常适合两个流中一个吞吐大，一个吞吐小，或者需要动态修改处理逻辑的情况。我们将使用后者的一个具体实例来解释广播状态，并在本文的其余部分里对详细的API加以说