Flink Python Packages

statefun-tasks

Tasks API for Stateful Functions on Flink

data-rentgen

NextGen DataMotion Lineage

khaos-cli

Kafka data generator and load testing tool - generate fake messages, simulate producers and consumers, test broker failures, and run chaos engineering scenarios

mcp-timeplus

Execute SQL queries and manage databases seamlessly with Timeplus. Leverage powerful tools to interact with your data, Kafka topics, and Iceberg tables efficiently. Enhance your data workflows with a user-friendly interface and robust backend capabilities.

pyalink-flink-1-9

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

pyalink

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

fluxmeter

Streaming metering engine for LLM token billing | Real-time budget enforcement | Built with Flink

dbt-decodable

A dbt adapter for Decodable

iflow-mcp-jovezhong-mcp-timeplus

Execute SQL queries and manage databases seamlessly with Timeplus. Leverage powerful tools to interact with your data, Kafka topics, and Iceberg tables efficiently. Enhance your data workflows with a user-friendly interface and robust backend capabilities.

pyalink-flink-1-10

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

flink-scrat

A python client to deploy JVM flink applications to a remote cluster

lakesoul

LakeSoul is an end-to-end, realtime cloud-native Lakehouse framework for fast data ingestion, concurrent updates, incremental analytics, multimodal data processing and vector search — powering next-generation BI and AI workloads.

pyalink-flink-1-11

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

pyalink-flink-1-12

Alink is the Machine Learning algorithm platform based on Flink, developed by the PAI team of Alibaba computing platform.

cohestra-sdk

Open-source deployment management for Apache Flink on any Kubernetes cluster

dl-on-flink-framework

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

dl-on-flink-tensorflow-2-x

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-framework

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-framework-nightly

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-tensorflow-2-x

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

dl-on-flink-tensorflow

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-tensorflow-nightly

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-tensorflow

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.

flink-ml-tensorflow-2-x-nightly

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc) to enable distributed deep learning training and inference on a Flink cluster.