Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.exec.spark | |
org.apache.hadoop.hive.ql.parse.spark |
Class and Description |
---|
SparkTask |
Class and Description |
---|
CacheTran |
HiveBaseFunctionResultList
Base class for
- collecting Map/Reduce function output and
- providing an Iterable interface for fetching output records.
|
HiveMapFunction |
HivePairFlatMapFunction |
HiveReduceFunction |
HiveSparkClient |
HiveVoidFunction
Implementation of a voidFunction that does nothing.
|
LocalHiveSparkClient
LocalSparkClient submit Spark job in local driver, it's responsible for build spark client
environment and execute spark work.
|
SparkPlan |
SparkRecordHandler |
SparkReduceRecordHandler
Clone from ExecReducer, it is the bridge between the spark framework and
the Hive operator pipeline at execution time.
|
SparkReporter
Implement SparkReporter for Hive operator level statistics collection, and throw
UnsupportedOperationException for other unrelated methods, so if any Hive feature
depends on these unimplemented methods, we could go back here quickly and enable it.
|
SparkShuffler |
SparkTask |
SparkTran |
Class and Description |
---|
SparkTask |
Copyright © 2022 The Apache Software Foundation. All rights reserved.