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
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