apache-flink - 動的出力キーの SplitStream (選択)

Question

これは私のコードです。

    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、温度:30...

上記のコードでは、stream 、eventType ごと、つまり temperatureStream と pressureStream を分割しています。

問題は、eventType がわかっている場合、splitStream のように選択できることです。

splitStream.select('temperatureStream')

しかし、eventType は動的であり、事前定義されていません。

この動的ストリームに CEP を適用する方法を教えてください。CEP は次のようになります。

temperate is > 90 for past 10 minutes ...

pressure is > 90 for past 10 minutes ...