hazelcast-jet
hazelcast-jet copied to clipboard
Distribute-to-one edge support for Pipeline API
As a follow up to #2394, it should also be possible to use the distribute to one edge when using Pipeline API. SinkImpl currently supports only a few of the edge types. This is required for the QuestDB sink, because the writer needs to be local to the machine QuestDB is running on, but could be useful in other situations as well.