Stream SQL 的执行原理与 Flink 的实现

在数据仓库应用中，执行 ETL 过程是一种常见的需求。咱们但愿经过 ETL 过程预处理咱们的原始数据， 从而达到抽取有用信息和将数据转换为适合进一步查询的格式等目的。MapReduce 和 Spark 等批数据处理系统已经很好地解决了在高延迟的场景下的需求，目前低延迟的流式处理和增量计算是主要的发展方向。 本文将结合 Apache Flink 系统讨论相关技术课题。算法 伴随着流处理系统的发展，S

>>阅读原文<<