Flink SQL Examples in Confluent Manager for Apache Flink
The following examples are complete, runnable walkthroughs for Flink SQL in
Confluent Manager for Apache Flink® (CMF). Each one starts from an artifact or a CREATE TABLE and ends
with real query output, so you can follow along on your own cluster and confirm
the result. They build on the concepts in
User-Defined Functions and
Custom Connectors and Formats.
Examples
Redact a Column with a User-Defined Function: register a scalar Java function and call it in a query to redact a column.
Round-Trip an Apache Iceberg Table: load the Apache Iceberg™ connector as an artifact and run a full write-then-read round trip against object storage.
Read CSV Files from Object Storage: read CSV files from object storage with the filesystem connector.
Read and Write MongoDB: write to and read from MongoDB with the off-the-shelf
flink-sql-connector-mongodbconnector.
Before you begin
Complete the one-time environment setup first. It
installs object storage, enables artifact management and the environment catalog,
and creates an environment named test and a compute pool named pool. The
examples submit statements with the confluent CLI and the CMF REST API
against that environment and pool at http://cmf:8080. Substitute your own
environment, pool, and endpoint. Each example lists any extra setup it needs.