这是我的密码。

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;
}

我有一连串的监控事件以随机顺序出现温度：80，压力：70，湿度：80，temp:30...
使用上面的代码，我将拆分流，按事件类型，即temperaturestream、pressuresestream。
问题是，如果我知道eventtype，我可以从splitstream中选择它，比如

splitStream.select('temperatureStream')

但是eventtype是动态的，不是预定义的。
我将如何为这个动态流应用cep。cep会是这样的，如果

temperate is > 90 for past 10 minutes ...

pressure is > 90 for past 10 minutes ...