a toolkit for InfoSphere Streams