FlumeJava - Easy, Efficient Data-Parallel Pipelines