I cant find any place to specify the parallelism for the join here. 

stream1.join( stream2 )
                     .where( .. )
                    .equalTo( .. )
                    .window( .. )
                    .apply( .. );

How can we specify that ? 

-roshan

Reply via email to