The easy way to build and run Flink SQL jobs using Cloudera SQL Stream Builder
summary
Demo shows SQL Stream Builder running on Apache Flink inside Cloudera, using DDL to create tables from a faker connector and Kafka topics, auto-detecting schema and launching live Flink jobs that actually run. It builds materialized views backed by an internal Postgres-indexed engine with REST and PostgreSQL wire access for Grafana, supports integrated CDC via embedded Debezium without requiring Kafka, and lets users add Java and JavaScript UDFs. Jobs execute and materialized views serve pull queries with automatic indexing and pruning.
AI-written summary · about
chapters (20)
- 0:00Introduction
- 0:18Demo overview
- 1:02Why do we need SQL
- 1:58What is SQL Stream Builder
- 2:55Typical data flow
- 4:27Complex data flow
- 5:02materialized views
- 6:13architecture
- 7:48Integrated change data capture
- 9:32Demo
- 11:54Running the job
- 13:05Creating a view
- 15:28Kafka
- 18:14Summary
- 18:37Output
- 19:42File systems
- 23:46Create a materialized view
- 25:02Ignore nulls
- 26:42Connecting via Postgres
- 28:34Advanced features
related talks
39mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
46mFlink SQL in 2020: Time to show off!
43mContinuous SQL with Kafka and Flink
23mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
23mBetter, Faster, Stronger Streaming: Your First Dive into Flink SQL
21mFlink's application at Didi
43mLeverage the power and simplicity of SQL on Apache Flink
39mChangelog Stream Processing with Apache Flink
