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

Class CacheTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>

java.lang.Object

org.apache.hadoop.hive.ql.exec.spark.CacheTran<KI,VI,KO,VO>

All Implemented Interfaces:

SparkTran<KI,VI,KO,VO>

Direct Known Subclasses:

MapTran, ReduceTran

public abstract class CacheTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>
extends Object
implements SparkTran<KI,VI,KO,VO>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CacheTran(boolean cache)

Method Summary

Modifier and Type	Method and Description
protected abstract org.apache.spark.api.java.JavaPairRDD<KO,VO>	doTransform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)
Boolean	isCacheEnable()
org.apache.spark.api.java.JavaPairRDD<KO,VO>	transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hive.ql.exec.spark.SparkTran

getName, setName

Constructor Detail

CacheTran

protected CacheTran(boolean cache)

Method Detail

transform

public org.apache.spark.api.java.JavaPairRDD<KO,VO> transform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)

Specified by:

transform in interface SparkTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>

isCacheEnable

public Boolean isCacheEnable()

Specified by:

isCacheEnable in interface SparkTran<KI extends org.apache.hadoop.io.WritableComparable,VI,KO extends org.apache.hadoop.io.WritableComparable,VO>

doTransform

protected abstract org.apache.spark.api.java.JavaPairRDD<KO,VO> doTransform(org.apache.spark.api.java.JavaPairRDD<KI,VI> input)