I work on Streams at IBM. We target streaming, not MapReduce, but we may be closer to what you're thinking of. Our language, SPL, has three main abstractions: o

I work on Streams at IBM. We target streaming, not MapReduce, but we may be closer to what you're thinking of. Our language, SPL, has three main abstractions: operators, tuples and streams. Development resources: https://developer.ibm.com/streamsdev/ https://developer.ibm.com/streamsdev/ Academic paper on the language, SPL: http://www.scott-a-s.com/files/ibm_tr_2014.pdf http://www.scott-a-s.com/files/ibm_tr_2014.pdf Some code, to give you more of a feel what it looks like; project head: https://github.com/scotts/streamsx.demo.logwatch; https://github.com/scotts/streamsx.demo.logwatch; actual source code: https://github.com/scotts/streamsx.demo.logwatch/blob/master/language/com.ibm.streamsx.demo.logwatch.language/LogWatch.spl https://github.com/scotts/streamsx.demo.logwatch/blob/master...