Question

有限的喷口

在 Flink 中，流处理源可以是有限的，即发出有限数量的记录并在发出最后一条记录后停止。但是，Spouts 通常会发出无限的流。两种方法之间的桥接是 FiniteSpout 除了 IRichSpout 包含 reachedEnd() 方法之外的接口，其中用户可以指定停止条件。用户可以通过实现此接口而不是（或另外）来创建有限 Spout IRichSpout ，并 reachedEnd() 另外实现该方法。与 SpoutWrapper 配置为发出有限数量的元组的 FiniteSpout 接口相比，接口允许实现更复杂的终止标准。

尽管有限的 Spout 不需要将 Spouts 嵌入到 Flink 流程序中或向 Flink 提交整个 Storm 拓扑，但有些情况下它们可能会派上用场：

• 实现原生 Spout 的行为与有限 Flink 源相同，只需要很少的修改
• 用户想要只处理一段时间; 之后，Spout 可以自动停止
• 将文件读入流中
• 用于测试目的

有限 Spout 的示例，仅发出 10 秒的记录：

• Java

public class TimedFiniteSpout extends BaseRichSpout implements FiniteSpout {
  [...] // implement open(), nextTuple(), ...

  private long starttime = System.currentTimeMillis();

  public boolean reachedEnd() {
    return System.currentTimeMillis() - starttime > 10000l;
  }
}