flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From madhairsilence <harish.kum...@tcs.com>
Subject Re: Categorize or GroupBy datastream data and process with CEP separately
Date Wed, 04 Jan 2017 11:32:21 GMT

This is my code.

*    SplitStream<MonitoringEvent> splitStream =  inputStream.split(new
OutputSelector<MonitoringEvent>() {

    @Override
    public Iterable<String> select(MonitoringEvent me) {

        List<String> ml = new ArrayList<String>();              
        ml.add(me.getEventType());                              
        return ml;
}*
I have stream of Monitoring Events coming in random order temp : 80,
pressure : 70 , humidity :80, temp:30...

With the above code, am splitting the stream , eventType wise i.e
temperatureStream, pressureStream.

The problem is , if I know the eventType, i can select it from the
splitStream like

*splitStream.select('temperatureStream')*
but the eventType is dynamic and not pre-defined.

How will I apply CEP for this dynamic stream. The CEP would be like, if the

*temperate is > 90 for past 10 minutes ...

pressure is > 90 for past 10 minutes ...*



--
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-tp15139p15148.html
Sent from the Apache Flink Mailing List archive. mailing list archive at Nabble.com.

Mime
View raw message