Minor Description
This ticket adds a ComplementStream to the Streaming API and Streaming Expression language.
The ComplementStream will wrap two TupleStreams (StreamA, StreamB) and emit Tuples from StreamA that are not in StreamB.
Streaming API Syntax:
ComplementStream cstream = new ComplementStream(streamA, streamB, comp);
Streaming Expression syntax:
complement(search(...), search(...), on(...))
Internal implementation will rely on the ReducerStream. The ComplementStream can be parallelized using the ParallelStream.
