Example for "A short one: Reactive streaming from HDFS" article on my blog. The app takes two command line arguments:

• name of HDFS user
• path to the file on HDFS

There is no input validation. You need to have hadoop running.