public class HiveReduceFunction<V> extends HivePairFlatMapFunction<Iterator<scala.Tuple2<HiveKey,V>>,HiveKey,org.apache.hadoop.io.BytesWritable>
jobConf, sparkReporter
Constructor and Description |
---|
HiveReduceFunction(byte[] buffer,
SparkReporter sparkReporter) |
Modifier and Type | Method and Description |
---|---|
Iterator<scala.Tuple2<HiveKey,org.apache.hadoop.io.BytesWritable>> |
call(Iterator<scala.Tuple2<HiveKey,V>> it) |
protected boolean |
isMap() |
initJobConf
Copyright © 2022 The Apache Software Foundation. All rights reserved.