Flink Tutorials

English | 中文

Introduction

This is a tutorial repo based on Flink v1.12.4. You can clone it and learn some basic ideas about Flink. I use Java and Scala to demonstrate how to use Flink. You need to install Intellij Idea and Maven in your local environment.

Please star this repo if you find it useful.

I also wrote a book (in Chinese) about Flink.

Project Structure

chapter2_basics gives some basic examples on overloading, types, functional programming.

chapter4_api shows Flink transformation APIs without time or state.

chapter5_time shows how to use time and window.

chapter6_state gives example on state.

chapter7_connector gives example on Connector (Source and Sink).

chapter7_sql shows Table API & SQL.

exercise are projects using Flink.

Contact

Feel free to reach out via email.