Flink编程模型

Flink抽象的层次 Flink为流式计算和批处理计算编程提供了不同层次的抽象。 最底层的抽象仅仅提供有状态的流处理,通过Process Function嵌入到DataStream API中。开发者可以处理来自多个数据流的事件,使用Flink提供的容错机制,此外也允许开发者注册事件时间和处理时间回调,以便实现复杂的计算逻辑。 事实上大部分程序并不会直接使用Statefull Stream Proc
相关文章
相关标签/搜索