📃
[Lab] Flink lab
  • Introduction -- Flink
  • Prepare your Flink Java program
  • Pack your Flink program to JAR
  • Start your Flink cluster with docker
  • Submit your program through Flink UI
Powered by GitBook
On this page

Was this helpful?

Introduction -- Flink

NextPrepare your Flink Java program

Last updated 1 year ago

Was this helpful?

Apache Flink is a framework and distributed processing engine for stateful computations over unbounded and bounded data streams.

In this lab, we are going to build a word count program for a stream of text data. We will write a Java program using Flink's DataSteamAPI.