org.apache.hadoop.hive.ql.exec.spark

Class ShuffleTran

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.ShuffleTran

All Implemented Interfaces:

SparkTran<HiveKey,org.apache.hadoop.io.BytesWritable,HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>

public class ShuffleTran
extends Object
implements SparkTran<HiveKey,org.apache.hadoop.io.BytesWritable,HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>

Constructor Summary

Constructors

Constructor and Description
ShuffleTran(SparkPlan sparkPlan, SparkShuffler sf, int n)
ShuffleTran(SparkPlan sparkPlan, SparkShuffler sf, int n, boolean toCache)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.api.java.JavaPairRDD<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>	transform(org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> input)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ShuffleTran

public ShuffleTran(SparkPlan sparkPlan,
           SparkShuffler sf,
           int n)

ShuffleTran

public ShuffleTran(SparkPlan sparkPlan,
           SparkShuffler sf,
           int n,
           boolean toCache)

Method Detail

transform

public org.apache.spark.api.java.JavaPairRDD<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>> transform(org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> input)

Specified by:

transform in interface SparkTran<HiveKey,org.apache.hadoop.io.BytesWritable,HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>>