flinksql

一个基于 Apache Flink 二次开发、易扩展的一站式开发运维 FlinkSQL 及 SQL 的实时计算平台

The Lineage Analysis system for FlinkSQL supports advanced syntax such as Watermark, UDTF, CEP, Windowing TVFs, and CTAS.

SQL languages for monaco-editor

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.

Dockerized runner, utilities, and functions for FlinkSQL applications

基于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任务编排机制。

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

Flink SQL connector for OSS database

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

A tiny Flink SQL runtime shim

Apache Flink SQL