Cloudera Docs

Flink API Support

Cloudera Streaming Analytics (CSA) offers support for three fundamental layers of the Apache Flink API. You can use DataStream API, the ProcessFunction API and a selected subset of the SQL API to develop your Flink streaming applications.

From the DataStream and ProcessFunction APIs, the following are supported based on the support annotations provided by the Apache Flink community.
Stable (@Public) Evolving (@PublicEvolving)
  • DataStream API
  • ProcessFunction
  • Stream Join
  • Interval Join
  • Stateful operators
  • FsStatebackend with HDFS
  • RocksDBStateBackend with HDFS