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

This project extends support for AI computing framework on Flink

License	The Apache Software License, Version 2.0
GroupId	com.alibaba.flink.ml
ArtifactId	flink-ml-operator
Last Version	0.2.1
Release Date	Apr 23, 2020
Type	jar
Description	This project extends support for AI computing framework on Flink
Project Organization	Alibaba Group

Download flink-ml-operator

Filename	Size
flink-ml-operator-0.2.1.pom
flink-ml-operator-0.2.1.jar	41 KB
flink-ml-operator-0.2.1-tests.jar	15 KB
flink-ml-operator-0.2.1-sources.jar	30 KB
flink-ml-operator-0.2.1-javadoc.jar	191 KB

How to add to project

Apache Maven

<!-- 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>

Gradle Groovy

// https://jarcasting.com/artifacts/com.alibaba.flink.ml/flink-ml-operator/
implementation 'com.alibaba.flink.ml:flink-ml-operator:0.2.1'

Gradle Kotlin

// https://jarcasting.com/artifacts/com.alibaba.flink.ml/flink-ml-operator/
implementation ("com.alibaba.flink.ml:flink-ml-operator:0.2.1")

Apache Buildr

'com.alibaba.flink.ml:flink-ml-operator:jar:0.2.1'

Apache Ivy

<dependency org="com.alibaba.flink.ml" name="flink-ml-operator" rev="0.2.1">
  <artifact name="flink-ml-operator" type="jar" />
</dependency>

Groovy Grape

@Grapes(
@Grab(group='com.alibaba.flink.ml', module='flink-ml-operator', version='0.2.1')
)

Scala SBT

libraryDependencies += "com.alibaba.flink.ml" % "flink-ml-operator" % "0.2.1"

Leiningen

[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:

Alibaba

Alibaba Open Source

Versions

Version
0.2.1 Apr 23, 2020
0.2.0 Apr 22, 2020
0.1.0 Jul 12, 2019