11Python Flink Examples
22=====================
33
4- ![ Flink UI] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/flink_ui.png )
4+ ![ Flink UI] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/flink_ui.png )
55
66A collection of examples using Apache Flink's new python API. To set up your local environment with
77the latest Flink build, see the guide:
@@ -28,7 +28,7 @@ Word Count
2828An extremely simple analysis program uses a source from a simple string, counts the occurrences of each word
2929and outputs to a file on disk (using the overwrite functionality).
3030
31- ![ Word Count Plan] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/word_count_plan.png )
31+ ![ Word Count Plan] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/word_count_plan.png )
3232
3333Trending Hashtags
3434-----------------
@@ -37,7 +37,7 @@ A very similar example to word count, but includes a filter step to only include
3737The input data in this case is read off of disk, and the output is written as a csv. The file is generated dynamically
3838at run time, so you can play with different volumes of tweets to get an idea of Flink's scalability and performance.
3939
40- ![ Trending Hashtags Plan] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/trending_hashtags_plan.png )
40+ ![ Trending Hashtags Plan] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/trending_hashtags_plan.png )
4141
4242Data Enrichment
4343---------------
@@ -46,22 +46,22 @@ In this example, we have row-wise json in one file, with an attribute field that
4646colors. So we load both datasets in, convert the json data into a ordered and typed tuple, and join then two together
4747to get a nice dataset of cars and their colors.
4848
49- ![ Data Enrichment Plan] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/data_enrichment_plan.png )
49+ ![ Data Enrichment Plan] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/data_enrichment_plan.png )
5050
5151Mean Values
5252-----------
5353
5454Takes in a csv with two columns and finds the mean of each column, using a custom reducer function. Afterwards, it
5555formats a string nicely with the output and dumps that onto disk.
5656
57- ![ Mean Values Plan] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/mean_values_plan.png )
57+ ![ Mean Values Plan] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/mean_values_plan.png )
5858
5959Mandelbrot Set
6060--------------
6161
6262Creates a Mandelbrot set from a set of candidates. Inspired by [ this post] ( http://1oclockbuzz.com/2015/11/24/pyspark-and-the-mandelbrot-set-overkill-indeed/ )
6363
64- ![ Mandelbrot Plan] ( https://github. com/wdm0006/flink-python-examples/tree /master/images/mandelbrot_plan.png )
64+ ![ Mandelbrot Plan] ( https://raw.githubusercontent. com/wdm0006/flink-python-examples/master/images/mandelbrot_plan.png )
6565
6666Features
6767========
0 commit comments