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
Hi all,
I have a question regarding partitioning.
Does calling the withPartitioner() method on a coGroup operation has the same
effect as performing partitionCustom on both datasets beforehand?
i.e.
Is
1. a.coGroup(b).where(…).equalTo(…).withPartitioner(…).with(…)
equivalent to:
1. Da
