Open Source Implementation of IBM Infosphere Streams