API 层主要实现了面向无界 Stream 的流处理和面向 Batch 的批处理 API。

其中面向流处理对应 DataStream API，面向批处理对应 DataSet API。

Flink 提供了不同层级的 API 抽象

  • Stateful Stream Processing
  • DataSteam/DataSet API
  • Table API
  • SQL

DataSet

DataStream

Table API

Reference