Name | Description | Type | Package | Framework |
GroupByShuffler | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HashTableLoader | HashTableLoader for Spark to load the hashtable for MapJoins. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
HiveBaseFunctionResultList | - collecting Map/Reduce function output and - providing an Iterable interface for fetching output records. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
HiveMapFunction | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveMapFunctionResultList | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HivePairFlatMapFunction | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveReduceFunction | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveReduceFunctionResultList | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveSparkClient | Interface | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveSparkClientFactory | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
HiveVoidFunction | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
JobMetricsListener | Class | org.apache.hadoop.hive.ql.exec.spark.status.impl | Apache Hive | |
KryoSerializer | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
LocalHiveSparkClient | LocalSparkClient submit Spark job in local driver, it's responsible for build spark client environment and execute spark work. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
LocalSparkJobMonitor | LocalSparkJobMonitor monitor a single Spark job status in a loop until job finished/failed/killed. | Class | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive |
LocalSparkJobRef | Class | org.apache.hadoop.hive.ql.exec.spark.status.impl | Apache Hive | |
LocalSparkJobStatus | Class | org.apache.hadoop.hive.ql.exec.spark.status.impl | Apache Hive | |
MapInput | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
MapTran | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
ReduceTran | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
RemoteHiveSparkClient | RemoteSparkClient is a wrapper of SparkClient, which wrap a spark job request and send to an remote SparkContext. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
RemoteSparkJobMonitor | RemoteSparkJobMonitor monitor a RSC remote job status in a loop until job finished/failed/killed. | Class | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive |
RemoteSparkJobRef | Class | org.apache.hadoop.hive.ql.exec.spark.status.impl | Apache Hive | |
RemoteSparkJobStatus | Used with remove spark client. | Class | org.apache.hadoop.hive.ql.exec.spark.status.impl | Apache Hive |
ShuffleTran | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SortByShuffler | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkHashTableSinkOperator | Class | org.apache.hadoop.hive.ql.exec | Apache Hive | |
SparkJobRef | Interface | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive | |
SparkJobState | Class | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive | |
SparkJobStatus | SparkJobStatus identify what Hive want to know about the status of a Spark job. | Interface | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive |
SparkMapRecordHandler | Clone from ExecMapper. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
SparkMergeFileRecordHandler | Copied from MergeFileMapper. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
SparkPlan | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkPlanGenerator | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkRecordHandler | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkReduceRecordHandler | Clone from ExecReducer, it is the bridge between the spark framework and the Hive operator pipeline at execution time. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
SparkReporter | UnsupportedOperationException for other unrelated methods, so if any Hive feature depends on these unimplemented methods, we could go back here quickly and enable it. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |
SparkSession | Interface | org.apache.hadoop.hive.ql.exec.spark.session | Apache Hive | |
SparkSessionImpl | Class | org.apache.hadoop.hive.ql.exec.spark.session | Apache Hive | |
SparkSessionManager | Defines interface for managing multiple SparkSessions in Hive when multiple users are executing queries simultaneously on Spark execution engine. | Interface | org.apache.hadoop.hive.ql.exec.spark.session | Apache Hive |
SparkSessionManagerImpl | Simple implementation of SparkSessionManager - returns SparkSession when requested through getSession and keeps track of | Class | org.apache.hadoop.hive.ql.exec.spark.session | Apache Hive |
SparkShuffler | Interface | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkStageProgress | Class | org.apache.hadoop.hive.ql.exec.spark.status | Apache Hive | |
SparkStatistic | Class | org.apache.hadoop.hive.ql.exec.spark.Statistic | Apache Hive | |
SparkStatisticGroup | Class | org.apache.hadoop.hive.ql.exec.spark.Statistic | Apache Hive | |
SparkStatistics | Class | org.apache.hadoop.hive.ql.exec.spark.Statistic | Apache Hive | |
SparkStatisticsBuilder | Class | org.apache.hadoop.hive.ql.exec.spark.Statistic | Apache Hive | |
SparkTask | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkTran | Interface | org.apache.hadoop.hive.ql.exec.spark | Apache Hive | |
SparkUtilities | Contains utilities methods used as part of Spark tasks. | Class | org.apache.hadoop.hive.ql.exec.spark | Apache Hive |