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

In the CSA 1.2 release, support for a subset of the SQL API is introduced. Cloudera encourages users to interact with the SQL API through the SQL client or embedding it into DataStream applications. However, Cloudera only provides production support for the latter method due to limitations of the SQL client. For a complete list of supported features in the SQL API, see the Release Notes.