Flink运行时之统一的数据交换对象

统一的数据交换对象 在Flink的执行引擎中，流动的元素主要有两种：缓冲（Buffer）和事件（Event）。Buffer主要针对用户数据交换，而Event则用于一些特殊的控制标识。但在实现时，为了在通讯层统一数据交换，Flink提供了数据交换对象——BufferOrEvent。它是一个既能够表示Buffer又能够表示Event的类。上层使用者只需调用isBuffer和isEvent方法便可判断当

>>阅读原文<<