Initial version of storm streaming code.