[FLINK-9507] Introduce ReduceFunction to CEP to minor the cost for IterativeCondition

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.5.0
• Component/s: Library / CEP
• Labels: auto-deprioritized-major auto-deprioritized-minor auto-unassigned
• Assignee: Unassigned
• Reporter: WenJun Min
• Created: 03/Jun/18 15:56
• Updated: 29/Dec/21 22:38

Description

When we use the cep to describe a condition about the events that has been matched, we have to call the method "getEventsForPattern" to extract the partly matched elements from the sharedBuffer in RocksDB, which is very cost, I think we can introduce a ReduceFunction on the pattern desc to allow us to aggregate the value in advance. Is this practical ？ What's your guys opinion? kkl0u dawidwys