Using Bloom and Java to implement a new MapReduce for real-time data stream, is it a good idea?

[Dillon Peng]

hi, all

   Thank all!

    I have already implemented a Chord (based on Implementing Declarative Overlays ), next I will upload the source code to my github.

    As I mentioned in previous post, I thought whether I can design a Stream Processing Engine like storm, but,  after reading and practicing some storm and HOP,

I have a new idea that whether I can use Bloom and Java  to implement a real-time MapReduce( as title described ) based on the BOOM Analytics paper, Or said whether I can re-implement HOP and modify HOP to process external real-time data stream (not depending HDFS like the stock Hadoop).?

   Maybe my idea is crazy, any advice will be appreciated!  Thanks a lot in advance!

BEST REGARDS

PengCZ