OpenViSTAI · Agents · Blockchain · Crypto
Submit a project
Menu
AI Developer Tools & SDKs

Alink

Alink is an open-source machine-learning algorithm framework built around Apache Flink, with Java and Python interfaces for composing data-processing and model workflows.

Explore the practical guide ↓

Independent OpenViST project profile, based on linked sources.

Alink — OpenViST project profile in AI Developer Tools & SDKs.
OpenViST project illustration. See the linked sources for product details.
Understand the project

Practical overview

When it fits

Use Alink when your machine-learning workflow is intended to run with Apache Flink and you want to compose algorithm components through Java or PyAlink.

Who it is for

  • Developers building machine-learning workflows with Apache Flink
  • Java developers using Alink algorithm components and pipelines
  • Python developers who want to use PyAlink in Jupyter notebooks

Documented uses

  • Assemble features and connect them to a machine-learning algorithm in a pipeline.
  • Build batch or streaming workflows using Alink operators.
  • Develop classification, clustering, data-mining or graph-algorithm jobs.
Before you choose

Requirements & limits

The repository is public and identifies the project license as Apache-2.0. PyAlink setup documentation lists Python 3.6–3.8 and Java 8 prerequisites.

  • PyAlink packages are separated by supported Flink version, so choose the package for the target environment.
  • The documented interfaces distinguish batch execution from streaming execution.
  • The repository provides Java and Python tutorials, while the README also lists component documentation and a plugin downloader.

Check current requirements in the official documentation. Source-based guidance does not mean OpenViST has run or independently tested this project.

Source-based practical guide

Prepare a PyAlink environment

Install the PyAlink package that corresponds to the intended Flink version.

Before you start

  • Python 3.6, 3.7 or 3.8
  • Java 8
  • Choose one PyAlink package appropriate to the Flink version

Steps

  1. Select pyalink for the documented latest supported Flink version, or choose a pyalink-flink package for a listed older version.

  2. Install the selected package with pip, such as the command below or the command below.

    Documented command
    pip install pyalink
    Documented command
    pip install pyalink-flink-1.12

Expected outcome

The selected PyAlink package is installed in the Python environment.

Guide limitations

  • pyalink and pyalink-flink-* packages must not be installed together or alongside an older version; remove an existing package before switching.
Documentation 1 ↗
Source-based practical guide

Start a PyAlink notebook session

Initialize a local PyAlink environment in a Python notebook.

Before you start

  • A PyAlink installation
  • Python 3.6, 3.7 or 3.8
  • Java 8
  • Jupyter Notebook

Steps

  1. Start Jupyter Notebook and create a Python 3 notebook.

  2. Import the package with from pyalink.alink import *.

  3. Initialize a local environment with useLocalEnv(parallism, flinkHome=None, config=None).

Expected outcome

The documented initialization output is `JVM listening on ***` when the environment initializes successfully.

Guide limitations

  • The guide covers environment initialization; it does not verify a particular installation or workload.
Documentation 1 ↗
Evidence and transparency

Sources & review

Official repository ↗
Source record details
Source availability
Active
Sources checked
12 October 2026
Original website title
alibaba/Alink · Official homepage title · retained in its source language
How we review sourcesSuggest a correction