flink-udf 开源项目推荐（5 个）

threeknowbigdata /flink_second_understand

该 仓 库 专 注 于 让 读 者 了解 F link 组 件 ， 包括 F link 实 战 代 码 和 文 档 ，200 个 F link 教 程 知识 点 ， F link Dat astre am ， F link Table ， F link Window ， F link State ， F link Check point ， F link Met rics ， F link Memory ， F link on stand al one/yar n/k 8 s ， F link SQL ， F link CE P ， F link CDC ， F link U DF ， P y F link ， F link New Fe atures ， F link Part ition ， F link Memory 等 知识 点 。 详 细 链 接 请 参 见 ： htt ps ：//mp.weixin.qq.com/mp/ app ms gal bum ？ _ _我们 是 M zg 5 ND Y 3 Nz I w MA == & action = get album & album _ id = 203 80 88 6 22 68 7 46 95 75 # we chat _ red irect

j3-signalroom /confluent-kafka-isotope

End-to-end tracing and provenance for Kafka pipelines. Kafka Interceptors and Flink UDFs stamp an "isotope" into record headers; Flink SQL turns it into latency, topology, lineage and state-level provenance, Prometheus into live metrics, and an Iceberg lakehouse keeps the history. Runs on Confluent Platform and Confluent Cloud for Apache Flink.

hpgrahsl /current24-udf-examples

Examples Repo for my Current'24 talk "So you want to write a UDF for Flink?"

superbear /flink-udf-in-go

Apache Flink UDF Example in Go

salingnh /flink-etl-udfs

Reusable PyFlink UDFs for ETL normalization, masking, fingerprinting, and data quality.