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