HDFS endpoint collecting and aggregating data flows - View it on GitHub