api接口

最近更新时间: 2026-03-13 09:03:00

TBDS 大数据平台上的 Flink 访问接口与开源兼容,可参考:

  • Table API & SQL :Table API 一般与 DataSet 或者 DataStream 紧密关联,可以通过一个 DataSet 或者 DataStream 创建出一个 Table,然后再使用类似 filter、sum、join、select 等这种操作。最近还可以将一个 Table 对象转换成 DataSet 或者 DataStream。SQL API 的底层是基于 Apache Calcite,Apache Calcite 实现了标准 SQL,使用起来比其它 API 更加灵活,因为可以直接使用 SQL 语句。Table API 和 SQL API 可以很容易地结合在一块使用。因为它们都返回 Table 对象。
  • DataStream API & DataSet API :主要提供针对流数据和批数据的处理,是对低级 API 进行了一些封装,提供了 filter、sum、max、min等高阶函数,简单易用,所以这些 API 在实际生产中应用还是比较广泛的。
  • Stateful Stream Processing :提供了对时间和状态的细粒度控制,简洁性和易用性较差,主要应用在一些复杂事件处理逻辑上。