Yeah !This is same question .. thank you for you detailed explanation On Thu, 25 Jul 2019 at 9:32 PM, Kenneth Knowles <[email protected]> wrote:
> Is this the same question as your other email about your StackOverflow > question? If it is, then please see my answer on StackOverflow. If it is > not, can you explain a little more? > > Kenn > > On Wed, Jul 24, 2019 at 10:48 PM Kiran Hurakadli <[email protected]> > wrote: > >> I have 2 kafka streams , i want to merge by some key and on top of the >> merged stream i want to perform stateful operation so that i can sum up >> counts from both streams >> >> this what i tried, but dint work .. >> >> PCollection<String> stream1 = .. read from kafka >> >> PCollection<String> stream2 = .. read from kafka >> >> PCollection<String,Long> wonrdCount1 = stream1.apply(...) >> >> PCollection<String,Long> wonrdCount2 = stream2.apply(...) >> >> PCollection<String,Long> merged = merge wordcount1 and wordcount2 using >> CoGroupByKey >> >> >> >> Pcolection<String,Long> finalStream = mergred.apply(...) >> >> >> for finalstream apply state.. >> >> Please suggest solution .. >> >> -- >> Regards, >> *Kiran M Hurakadli.* >> > -- Regards, *Kiran M Hurakadli.*
