org.apache.flink.util.Collector
时间: 2023-11-17 18:06:48 浏览: 250
apache-flink
org.apache.flink.util.Collector是Flink框架中的一个接口,用于收集数据并将其发送到下游任务。它定义了一个collect()方法,用于将单个数据元素添加到Collector中。在Flink中,数据流是以数据包的形式进行传输的,Collector可以将这些数据包发送到下游任务。通常,在Flink中,数据包的大小是有限的,因此,Collector还提供了一个close()方法,用于通知下游任务不再有数据包发送。
阅读全文