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 <kiranhr...@gmail.com> 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.* >
