Flink working example
This section details a full working example using Flink. Towards the end of this section, it also brings a connection of our use case with Flink and how its features are used.
Note
At the time of authoring this book, we had Flink Release Candidate 3 source code available for download, while official release of Flink 1.3.0 was just about to be released. As we observed Flink Release Candidate 3 (RC3) was versioned as 1.3.0, and its implementation is expected to be very close to the official release of Flink 1.3.0.
Installation
Follow the steps for full installation of Flink:
- Download the latest source code for release candidate of flink 1.3.0, which was RC3 (release candidate 3) at the time of authoring this book, using the following command in your download directory,
${DOWNLOAD_DIR}
:
wget https://github.com/apache/flink/archive/release-1.3.0-rc3.zip
- Change to a user directory and extract the contents from the zip using the following command. Let us refer to the extracted...