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:
Streaming Expression syntax:
Internal implementation will rely on the ReducerStream. The ComplementStream can be parallelized using the ParallelStream.