Support Dynamic Route Partitioner

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

Open haoch opened 5 years ago

haoch commented 5 years ago

Source ~> <Route, Event> ~> RoutePartitioner ~> CepOperator

haoch commented 5 years ago

@wujinhu keep our discussion here.