com.alibaba.flink.ml:flink-ml-operator

This project extends support for AI computing framework on Flink

License

License

GroupId

GroupId

com.alibaba.flink.ml
ArtifactId

ArtifactId

flink-ml-operator
Last Version

Last Version

0.2.1
Release Date

Release Date

Type

Type

jar
Description

Description

This project extends support for AI computing framework on Flink
Project Organization

Project Organization

Alibaba Group

Download flink-ml-operator

How to add to project

<!-- https://jarcasting.com/artifacts/com.alibaba.flink.ml/flink-ml-operator/ -->
<dependency>
    <groupId>com.alibaba.flink.ml</groupId>
    <artifactId>flink-ml-operator</artifactId>
    <version>0.2.1</version>
</dependency>
// https://jarcasting.com/artifacts/com.alibaba.flink.ml/flink-ml-operator/
implementation 'com.alibaba.flink.ml:flink-ml-operator:0.2.1'
// https://jarcasting.com/artifacts/com.alibaba.flink.ml/flink-ml-operator/
implementation ("com.alibaba.flink.ml:flink-ml-operator:0.2.1")
'com.alibaba.flink.ml:flink-ml-operator:jar:0.2.1'
<dependency org="com.alibaba.flink.ml" name="flink-ml-operator" rev="0.2.1">
  <artifact name="flink-ml-operator" type="jar" />
</dependency>
@Grapes(
@Grab(group='com.alibaba.flink.ml', module='flink-ml-operator', version='0.2.1')
)
libraryDependencies += "com.alibaba.flink.ml" % "flink-ml-operator" % "0.2.1"
[com.alibaba.flink.ml/flink-ml-operator "0.2.1"]

Dependencies

compile (7)

Group / Artifact Type Version
com.alibaba.flink.ml : flink-ml-framework jar 0.2.1
org.apache.flink : flink-clients_2.11 jar 1.10.0
org.apache.flink : flink-streaming-java_2.11 jar 1.10.0
org.apache.flink : flink-streaming-scala_2.11 jar 1.10.0
org.apache.flink : flink-table-planner_2.11 jar 1.10.0
org.apache.flink : flink-scala_2.11 jar 1.10.0
org.apache.flink : flink-core jar 1.10.0

provided (2)

Group / Artifact Type Version
org.apache.flink : flink-table-api-java jar 1.10.0
org.apache.flink : flink-table-api-java-bridge_2.11 jar 1.10.0

test (4)

Group / Artifact Type Version
com.alibaba.flink.ml : flink-ml-framework test-jar 0.2.1
junit : junit jar 4.12
org.apache.curator : curator-test jar 2.7.1
org.scalatest : scalatest_2.11 jar 3.0.5

Project Modules

There are no modules declared in this project.

Flink AI Extended

Flink AI Extended is a project extending Flink to various machine learning scenarios. Currently it contains the following two subprojects.

Flink AI Flow

Flink AI Flow is an open source framework that bridges big data and AI. It manages the entire machine learning project lifecycle as a unified workflow, including feature engineering, model training, model evaluation, model service, model inference, monitoring, etc. Throughout the entire workflow, Flink is used as the general purpose computing engine.

In addition to the capability of orchestrating a group of batch jobs, by leveraging an event-based scheduler(enhanced version of Airflow), Flink AI Flow also supports workflows that contain streaming jobs. Such capability is quite useful for complicated real-time machine learning systems as well as other real-time workflows in general.

For more details, please check the flink-ai-flow sub project.

Deep Learning on Flink

Deep Learning on Flink aims to integrate Flink and deep learning frameworks (e.g. TensorFlow, PyTorch, etc). It runs the deep learning tasks inside a Flink operator, so that Flink can help establish a distributed environment, manage the resource, read/write the records and handle the failures.

Currently Deep Learning on Flink only supports TensorFlow.

For more details, please check the deep-learning-on-flink sub project.

Contact Us

For more information, you can join the Flink AI Flow Users Group on DingTalk to contact us. The number of the DingTalk group is 35876083.

You can also join the group by scanning the QR code below:

com.alibaba.flink.ml

Alibaba

Alibaba Open Source

Versions

Version
0.2.1
0.2.0
0.1.0