@DedicatedKeyPerElement public final class DedicatedKeyPerElementPartitioner extends Object implements Partitioner<Integer>
Partitionerwhich assigns a dedicated key per an output data from a task. WARNING: Because this partitioner assigns a dedicated key per element, it should be used under specific circumstances that the number of output element is not that many. For example, every output element of
RelayTransforminserted by large shuffle optimization is always a partition. In this case, assigning a key for each element can be useful.
|Constructor and Description|
|Modifier and Type||Method and Description|
Divides the output data from a task into multiple blocks.
Copyright © 2019 The Apache Software Foundation. All rights reserved.