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.