Hi Till,
Thank you for your answer.
Giannis
From: Till Rohrmann
Sent: Monday, December 3, 2018 1:46 PM
To: dev@flink.apache.org
Subject: Re: withPartitioner() vs calling partitionCustom() beforehand
Hi Giannis,
logically the resulting plans should be
Hi Giannis,
logically the resulting plans should be identical, meaning that they both
will use the custom partitioner to create the partitions and then co group
both inputs.
Physically, the latter plan adds an additional partition operator before
the coGroup operator. You can see this is you call
