MapInput(SparkPlan sparkPlan,
org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD) |
MapInput(SparkPlan sparkPlan,
org.apache.spark.api.java.JavaPairRDD<org.apache.hadoop.io.WritableComparable,org.apache.hadoop.io.Writable> hadoopRDD,
boolean toCache) |
ShuffleTran(SparkPlan sparkPlan,
SparkShuffler sf,
int n) |
ShuffleTran(SparkPlan sparkPlan,
SparkShuffler sf,
int n,
boolean toCache) |
SortByShuffler(boolean totalOrder,
SparkPlan sparkPlan) |