Hi Kostas,
Thank you for the answer and clarification.
If Side-outputs are treated in the same way and there is no significant
performance penalty then it seems that they are ok for my use case.
I can accept the name mismatch ;)
Regards,
Krzysztof
--
Sent from:
Hi Krzysztof,
If I get it correctly, your main reason behind not using side-outputs
is that it seems that "side-output", by the name, seems to be a
"second class citizen" compared to the main output.
I see your point but in terms of functionality, there is no difference
between the different
Kostas, thank you for your response,
Well although the Side Outputs would do the job, I was just surprised that
those are the replacements for stream splitting.
The thing is, and this is might be only a subjective opinion, it that I
would assume that Side Outputs should be used only to produce
Hi Kristoff,
The recommended alternative is to use SideOutputs as described in [1].
Could you elaborate why you think side outputs are not a good choice
for your usecase?
Cheers,
Kostas
[1]
https://ci.apache.org/projects/flink/flink-docs-stable/dev/stream/side_output.html
On Thu, Dec 19, 2019
Hi,
I've noticed that SplitStream class is marked as deprecated, although split
method of DataStream is not.
Also there is no alternative proposed in SplitStream doc for it.
In my use case I will have a stream of events that I have to split into two
separate streams based on some function. Events
