Support dynamic partition and ad-hoc cep runtime

haoch / flink-siddhi

A CEP library to run Siddhi within Apache Flink™ Streaming Application (Not maintained)

Apache License 2.0

243 stars 96 forks source link

Closed wujinhu closed 5 years ago

wujinhu commented 5 years ago

Add dynamic partition for dynamic added rules

Related Issue: #19 #2

wujinhu commented 5 years ago

@haoch Please help to review this PR, thanks

haoch commented 5 years ago

@wujinhu Please keep the original API for backward compasibility and add some new API for multiple stream output.

wujinhu commented 5 years ago

@haoch OK, I have brought interfaces back and added new interfaces.

haoch commented 5 years ago

haoch commented 5 years ago

LGTM @wujinhu. Do you think it's ready to merge now?