Repository navigation

#

flinksql

DataLinkDC/dinky

Dinky is a real-time data development platform based on Apache Flink, enabling agile data development, deployment and operation.

Java
3523
11 小时前

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

Java
402
7 天前

SQL languages for monaco-editor

TypeScript
269
19 天前

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

Java
142
2 年前

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 UNOFFICIAL community project

Java
89
3 个月前

One bite-sized tip or trick for Apache Flink practitioners every day leading up to Christmas Eve 2024.

26
8 个月前

Dockerized runner, utilities, and functions for FlinkSQL applications

Java
21
1 天前

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

Java
12
4 年前

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

Python
10
2 年前

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

Java
8
4 年前

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

Java
6
2 年前

Flink SQL connector for OSS database

Java
5
2 年前

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

Python
5
2 年前

A tiny Flink SQL runtime shim

Java
3
2 年前