Constructor and Description |
---|
ReduceTran() |
ReduceTran(boolean caching) |
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,Iterable<org.apache.hadoop.io.BytesWritable>> input) |
String |
getName() |
void |
setName(String name) |
void |
setReduceFunction(HiveReduceFunction redFunc) |
isCacheEnable, transform
public org.apache.spark.api.java.JavaPairRDD<HiveKey,org.apache.hadoop.io.BytesWritable> doTransform(org.apache.spark.api.java.JavaPairRDD<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>> input)
doTransform
in class CacheTran<HiveKey,Iterable<org.apache.hadoop.io.BytesWritable>,HiveKey,org.apache.hadoop.io.BytesWritable>
public void setReduceFunction(HiveReduceFunction redFunc)
public String getName()
public void setName(String name)
Copyright © 2016 The Apache Software Foundation. All rights reserved.