flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jamie Grier <ja...@data-artisans.com>
Subject Re: Categorize or GroupBy datastream data and process with CEP separately
Date Tue, 03 Jan 2017 16:55:40 GMT
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.kumard@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>
jamie@data-artisans.com

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message