/flink-python-demos

Flink Python Demos

Primary LanguagePythonMIT LicenseMIT

flink-python-demos

A collection of demos using Apache Flink™'s python Table API.

Getting Started

Prerequisites

  • Flink (v1.10.1+).
  • Python3 or python3.*.
  • PyFlink python module should be installed.

Demos

  1. word_count

An extremely simple analysis program uses a source from a simple string, counts the occurrences of each word and outputs to a file on disk.