Ruby code for streaming processing in hadoop