Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec.spark |
Modifier and Type | Class and Description |
---|---|
class |
SparkMapRecordHandler
Clone from ExecMapper.
|
class |
SparkMergeFileRecordHandler
Copied from MergeFileMapper.
|
class |
SparkReduceRecordHandler
Clone from ExecReducer, it is the bridge between the spark framework and
the Hive operator pipeline at execution time.
|
Constructor and Description |
---|
HiveMapFunctionResultList(Iterator<scala.Tuple2<org.apache.hadoop.io.BytesWritable,org.apache.hadoop.io.BytesWritable>> inputIterator,
SparkRecordHandler handler)
Instantiate result set Iterable for Map function output.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.