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

Class MapTran

java.lang.Object

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

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

All Implemented Interfaces:

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

public class MapTran
extends CacheTran<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,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
MapTran()
MapTran(boolean cache, 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<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable> input)
void	setMapFunction(HiveMapFunction mapFunc)

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

MapTran

public MapTran()

MapTran

public MapTran(boolean cache,
               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<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable> input)

Specified by:

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

setMapFunction

public void setMapFunction(HiveMapFunction mapFunc)