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

Class ReduceTran<V>

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.CacheTran<HiveKey,V,HiveKey,org.apache.hadoop.io.BytesWritable>

org.apache.hadoop.hive.ql.exec.spark.ReduceTran<V>

All Implemented Interfaces:

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

public class ReduceTran<V>
extends CacheTran<HiveKey,V,HiveKey,org.apache.hadoop.io.BytesWritable>

Field Summary

Fields inherited from class org.apache.hadoop.hive.ql.exec.spark.CacheTran

name

Constructor Summary

Constructors

Constructor and Description
ReduceTran()
ReduceTran(boolean caching, String name)

Method Summary

Modifier and Type	Method and Description
org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable>	doTransform(org.apache.spark.api.java.JavaPairRDD<HiveKey,V> input)
void	setReduceFunction(HiveReduceFunction<V> redFunc)

Methods inherited from class org.apache.hadoop.hive.ql.exec.spark.CacheTran

getName, isCacheEnable, transform

Methods inherited from class java.lang.Object

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

Constructor Detail

ReduceTran

public ReduceTran()

ReduceTran

public ReduceTran(boolean caching,
                  String name)

Method Detail

doTransform

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

Specified by:

doTransform in class CacheTran<HiveKey,V,HiveKey,org.apache.hadoop.io.BytesWritable>

setReduceFunction

public void setReduceFunction(HiveReduceFunction<V> redFunc)