public class SortByShuffler extends Object implements SparkShuffler
Constructor and Description |
---|
SortByShuffler(boolean totalOrder) |
public SortByShuffler(boolean totalOrder)
totalOrder
- whether this shuffler provides total order shuffle.public org.apache.spark.api.java.JavaPairRDD<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>> shuffle(org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> input, int numPartitions)
shuffle
in interface SparkShuffler
Copyright © 2017 The Apache Software Foundation. All rights reserved.