Flink Python Packages

statefun-tasks

Tasks API for Stateful Functions on Flink

fluxmeter

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

data-rentgen

NextGen DataMotion Lineage

pyalink-flink-1-9

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

pyalink

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

dl-on-flink-tensorflow-2-x

No description available

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.

lakesoul

Python APIs for using LakeSoul

pyalink-flink-1-10

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

dbt-decodable

A dbt adapter for Decodable

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.

pyalink-flink-1-11

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

flink-scrat

Python client to deploy flink applications to remote clusters via the flink cluster API

dl-on-flink-tensorflow

No description available

flink-ml-tensorflow

No description available

pyalink-flink-1-12

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

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.

dl-on-flink-framework

No description available

flink-ml-tensorflow-nightly

No description available

flink-ml-framework

No description available

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.

dl-on-flink-pytorch

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.

iflow-mcp-jovezhong-mcp-timeplus

An MCP server for Timeplus.