FlumeJava Port to Hadoop (github.com)

The most interesting thing is the way DoFn serialization serialization works, allowing you to escape MapReduceBase hell for every single tranformation in a MapReduce job chain.