Registry / other / flink-scala-2-12

flink-scala-2-12

library1.20.3javamavenunverified

Apache Flink's Scala API and utilities compiled for Scala 2.12, enabling stream and batch processing.

<dependency>
  <groupId>org.apache.flink</groupId>
  <artifactId>flink-scala_2.12</artifactId>
  <version>1.20.3</version>
</dependency>

github ↗homepage ↗docs ↗

INSTALL

IMPORT

SIG · FLINK-SCALA-2-12

flink-scala-2-12

otherjavav1.20.3

harness data pending

Install & Compatibility

Where this runs

No compatibility data collected yet for this library.

Code

Verified usage

Verified import paths — ran on the pinned version, not inferred.

StreamExecutionEnvironment

✓ org.apache.flink.streaming.api.scala.StreamExecutionEnvironment

Create a simple word count streaming job using Flink's Scala API.

import org.apache.flink.streaming.api.scala._ object WordCount { def main(args: Array[String]): Unit = { val env = StreamExecutionEnvironment.getExecutionEnvironment val text = env.fromElements("hello world", "hello flink") val counts = text.flatMap(_.toLowerCase.split("\\W+")) .map((_, 1)) .keyBy(0) .sum(1) counts.print() env.execute("WordCount") } }

Debug

Known issues

breakingFlink 1.20.x may have breaking changes from earlier versions, especially in the Scala API.

fix

Review the Flink 1.20 migration guide and update your Scala code accordingly.

affects: >=1.20.0

Upgrade

Version history

1.20.3latest on Maven

Audit

Dependencies

No dependency data recorded yet.

Agent activity

4 hits · last 30 days

node

Resources

githubhttps://github.com/apache/flink ↗

homepagehttps://flink.apache.org ↗

docshttps://appdoc.app/artifact/org.apache.flink/flink-scala_2.12/ ↗