hadoop - 在Nifi中，FirstInFirstOutPrioritizer和OldestFlowFileFirstPrioritizer有什么区别

Question

用户指南 https://nifi.apache.org/docs/nifi-docs/html/user-guide.html有以下关于优先级排序器的详细信息，能否请您帮助我了解它们的不同之处并提供任何实时示例。

FirstInFirstOutPrioritizer:给定两个 FlowFile，第一个到达连接的将首先被处理。

OldestFlowFileFirstPrioritizer:给定两个 FlowFile，数据流中最旧的将首先处理。 “如果没有选择优先顺序，这是使用的默认方案。”

Answer 1

假设两个处理器 A 和 B 都连接到漏斗，然后漏斗连接到处理器 C。

场景 1 - 漏斗和处理器 C 之间的连接具有先进先出的优先级。

在这种情况下，漏斗和连接C之间的队列中的流文件将严格按照它们到达队列的顺序进行处理。

场景 2 - 漏斗和处理器 C 之间的连接具有最旧流文件优先优先级。

在这种情况下，漏斗和连接 C 之间的队列中可能已经有流文件，但是其中一个处理器将流传输到该队列，该队列比该队列中的所有流文件都旧，它将跳转到前面。

你可以想象一些流文件来自流的不同部分，比其他流文件处理时间更长，但它们最终都汇集到同一个队列中，所以这些来自较长处理部分的流文件是被认为年龄较大。