一个基于 Apache Flink 二次开发、易扩展的一站式开发运维 FlinkSQL 及 SQL 的实时计算平台
The Lineage Analysis system for FlinkSQL supports advanced syntax such as Watermark, UDTF, CEP, Windowing TVFs, and CTAS.
FlinkSQL数据脱敏和行级权限解决方案及源码，支持面向用户级别的数据脱敏和行级数据访问控制，即特定用户只能访问到脱敏后的数据或授权过的行。此方案是实时领域Flink的解决方案，类似于离线数仓Hive Ranger中的Row-level Filter和Column Masking方案。
Kryptonite for Kafka is a client-side 🔒 field level 🔓 cryptography library for Apache Kafka® offering a Kafka Connect SMT, ksqlDB UDFs, Flink UDFs, and a standalone HTTP API service. It's an UNOFFIC...
One bite-sized tip or trick for Apache Flink practitioners every day leading up to Christmas Eve 2024.
基于flink1.12，使用java，flink sql的demo，包含Mylsql， flinkcdc内置的Mysqlcdc
Apache Flink examples designed to be run by AWS Kinesis Data Analytics (KDA).
flink job compose 从 directshow和graphedit的概念，衍生的一套flink任务编排机制。
Flink SQL connector for OSS database
Data lake implementation demo, include iceberg on flink, iceberg on spark, hudi on flink, hudi on spark
This sample gets you started to run Flink SQL on AWS.
Dockerized runner, utilities, and functions for FlinkSQL applications
