You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by Frank <fr...@qq.com.INVALID> on 2022/09/21 02:03:40 UTC
如何停止一个CEP Pattern?
一般而言,我这么开始一个Pattern:
Pattern<Event, ?> patternA = getPattern();
PatternStream<Event> patternStreamA = CEP.pattern(keyedStream, patternA).inProcessingTime();
DataStream<String> resultStream = patternStreamA.process(getProcessFunc());
resultStream.print();
这样,patternStreamA就开始运行了。
那么,有一天我由于patternA CEP规则变了,想要停掉patternStreamA(然后重新创建一个patternB)
请问我如何才能停掉patternStreamA(不再耗资源)?
--Frank