I think what you want here is to apply CEP processing on a KeyedStream - see the last CEP Example here: https://ci.apache.org/projects/flink/flink-docs-release-1.1/apis/streaming/libs/cep.html#examples
On Tue, Jan 3, 2017 at 3:30 AM, madhairsilence <harish.kum...@tcs.com> wrote: > Assume I have a datastream > > *x:1, y:2 , z:3 , x:7 , y:-1, z:0, z:3 , z:2, y:3 ,x: 2 ,y:6* > How do I put x,y,z in their own bucket and apply my CEP rule on it. > > *x:1, x:7,x: 2 > y:2, y:-1, y:3 , y:6 > z:3, z:0 , z:3, z:2* > Or to put it in other way. How do I split the stream in to these > categories(one stream for each x,y,z). I would get 3 sub streams which has > their own CEP processing. > > The challenge here is , the x,y,z are not pre-defined.So I cannot > pre-create > streams and assign using an if or switch statement. > > > > -- > View this message in context: http://apache-flink-mailing- > list-archive.1008284.n3.nabble.com/Categorize-or- > GroupBy-datastream-data-and-process-with-CEP-separately-tp15139.html > Sent from the Apache Flink Mailing List archive. mailing list archive at > Nabble.com. > -- Jamie Grier data Artisans, Director of Applications Engineering @jamiegrier <https://twitter.com/jamiegrier> ja...@data-artisans.com
