A port of the Google Flume Data-Parallel Pipeline system to Julia - View it on GitHub