public class MapTran extends CacheTran<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,HiveKey,org.apache.hadoop.io.BytesWritable>
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) |
String |
getName() |
void |
setMapFunction(HiveMapFunction mapFunc) |
void |
setName(String name) |
isCacheEnable, transform
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)
doTransform
in class CacheTran<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable,HiveKey,org.apache.hadoop.io.BytesWritable>
public void setMapFunction(HiveMapFunction mapFunc)
public String getName()
public void setName(String name)
Copyright © 2016 The Apache Software Foundation. All rights reserved.