Dinky is an out of the box one-stop real-time computing platform dedicated to the construction and practice of Unified Streaming & Batch and Unified Data Lake & Data Warehouse. Based on Apache Flink, Dinky provides the ability to connect many big data frameworks including OLAP and Data Lake.

FlinkSQL字段血缘解决方案及源码。FlinkSQL field lineage solution and source code, The core idea is to parse SQL through Calcite to generate a RelNode tree of relational expressions. Then get the optimized logical paln through optimization stage, and finally call Calcite RelMetadataQuery to get the lineage relationship at the field level.

Data lake implementation demo, include iceberg on flink, iceberg on spark, hudi on flink, hudi on spark

SQL languages for monaco-editor

FlinkSQL数据脱敏和行级权限解决方案及源码，支持面向用户级别的数据脱敏和行级数据访问控制，即特定用户只能访问到脱敏后的数据或授权过的行。此方案是实时领域Flink的解决方案，类似于离线数仓Hive Ranger中的Row-level Filter和Column Masking方案。

This sample gets you started to run Flink SQL on AWS.

A tiny Flink-SQL job execution shim.

Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).

基于flink1.12，使用java，flink sql的demo，包含Mylsql， flinkcdc内置的Mysqlcdc

flink job compose 从 directshow和graphedit的概念，衍生的一套flink任务编排机制。

Apache Flink SQL