shuiqiangchen opened a new pull request #16: URL: https://github.com/apache/flink-playgrounds/pull/16
This is a walkthrough for PyFlink, you will learn how to manage and run PyFlink Jobs. The pipeline of this walkthrough reads data from Kafka, performs aggregations and writes results to Elasticsearch visualized via Kibana. The environment is managed by Docker so that all you need is a docker on your computer. It contains: - A data generator - Kafka - ElasticSearch - Kibana - Skeleton code for a PyFlink Table application. For more details, please refer to the README.md. ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
