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
3585
9 天前

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

Java
404
1 个月前

SQL languages for monaco-editor

TypeScript
272
2 个月前

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

Java
144
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
5 天前

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

26
9 个月前

Dockerized runner, utilities, and functions for FlinkSQL applications

Java
23
2 天前

基于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 年前