AHeise commented on pull request #17061: URL: https://github.com/apache/flink/pull/17061#issuecomment-931463319
It's very similar to [HybridSource](https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-base/src/main/java/org/apache/flink/connector/base/source/hybrid/HybridSource.java#L89-L89), and as such should live in flink-connector-base. I'm not entirely sure how to call it. Technically it's a `DemultiplexingSink` (it demultiplexes one stream into several sinks by some criteria). It could be a bit simpler called `SplittingSink`. However, both names sound like you could also implement it by using a static topology with several sinks by demultiplexing in a map with side outputs. So, actually `DynamicSink` captures the dynamic nature better but I'm missing a bit the splitting part... -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
