Flink流处理之迭代案例

当前Flink将迭代的重心集中在批处理上，以前咱们谈及了批量迭代和增量迭代主要是针对批处理（DataSet）API而言的，而且Flink为批处理中的迭代提供了针对性的优化。可是对于流处理（DataStream），Flink一样提供了对迭代的支持，这一节咱们主要来分析流处理中的迭代，咱们将会看到流处理中的迭代相较于批处理有类似之处，但差别也是十分之明显。php 可迭代的流处理程序容许定义“步函数”（

>>阅读原文<<