I have read the source code , and found that the JoinedStreams' implementation 
code is almost the same with CoGroupedStreams' (internally JoinedStreams' 
implementation is based on CoGroupedStreams). So why we provide two different 
interface `DataStream.join()` and `DataStream.coGroup()` which are exactly the 
same ?  And the document[1] has not indicated they are doing the same thing. Or 
is there any differences between `DataStream.join()` and `DataStream.coGroup()` 
which I missed ? 
-- Jark Wu

Reply via email to