GitHub user dominikriemer added a comment to the discussion: Structure of Sinks
I think the question has two parts: - The `DataSinkType` refers to the category of the data sink (there is a similar class for processors as well). This is only used in the pipeline editor to better find pipeline elements of a certain group (select `group` in the pipeline element selection panel). We can extend the list but need to be careful when removing items due to backwards compatibility. - We have some modules with `flink` appendix which can be only used with the Flink wrapper. Anyways, we haven't maintained the Flink wrapper for quite some time and most recent pipeline elements use the default JVM wrapper. We can rework the distributed wrappers in the future, and then I'd be in favor of reusing the same set of processors for distributed and standalone wrappers instead of having separate implementations. GitHub link: https://github.com/apache/streampipes/discussions/1314#discussioncomment-5057381 ---- This is an automatically sent email for [email protected]. To unsubscribe, please send an email to: [email protected]
