| Package | Description |
|---|---|
| org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
| org.apache.hadoop.hive.ql.io | |
| org.apache.hadoop.hive.ql.optimizer | |
| org.apache.hadoop.hive.ql.parse | |
| org.apache.hadoop.hive.ql.plan |
| Modifier and Type | Method and Description |
|---|---|
boolean |
FetchTask.isFetchFrom(FileSinkDesc fs) |
static void |
Utilities.mvFileToFinalPath(org.apache.hadoop.fs.Path specPath,
org.apache.hadoop.conf.Configuration hconf,
boolean success,
org.apache.commons.logging.Log log,
DynamicPartitionCtx dpCtx,
FileSinkDesc conf,
org.apache.hadoop.mapred.Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
static RecordUpdater |
HiveFileFormatUtils.getAcidRecordUpdater(org.apache.hadoop.mapred.JobConf jc,
TableDesc tableInfo,
int bucket,
FileSinkDesc conf,
org.apache.hadoop.fs.Path outPath,
ObjectInspector inspector,
org.apache.hadoop.mapred.Reporter reporter,
int rowIdColNum) |
static FileSinkOperator.RecordWriter |
HiveFileFormatUtils.getHiveRecordWriter(org.apache.hadoop.mapred.JobConf jc,
TableDesc tableInfo,
Class<? extends org.apache.hadoop.io.Writable> outputClass,
FileSinkDesc conf,
org.apache.hadoop.fs.Path outPath,
org.apache.hadoop.mapred.Reporter reporter) |
| Modifier and Type | Method and Description |
|---|---|
Map<FileSinkDesc,Task<? extends Serializable>> |
GenMRProcContext.getLinkedFileDescTasks() |
| Modifier and Type | Method and Description |
|---|---|
static MapWork |
GenMapRedUtils.createMergeTask(FileSinkDesc fsInputDesc,
org.apache.hadoop.fs.Path finalName,
boolean hasDynamicPartitions)
Create a block level merge task for RCFiles or stripe level merge task for
ORCFiles
|
static boolean |
GenMapRedUtils.isSkewedStoredAsDirs(FileSinkDesc fsInputDesc)
check if it is skewed table and stored as dirs.
|
| Modifier and Type | Method and Description |
|---|---|
void |
GenMRProcContext.setLinkedFileDescTasks(Map<FileSinkDesc,Task<? extends Serializable>> linkedFileDescTasks) |
| Modifier and Type | Field and Description |
|---|---|
protected Set<FileSinkDesc> |
BaseSemanticAnalyzer.acidFileSinks
A set of FileSinkOperators being written to in an ACID compliant way.
|
Map<org.apache.hadoop.fs.Path,List<FileSinkDesc>> |
GenTezProcContext.linkedFileSinks |
| Modifier and Type | Method and Description |
|---|---|
Set<FileSinkDesc> |
BaseSemanticAnalyzer.getAcidFileSinks() |
| Modifier and Type | Method and Description |
|---|---|
List<FileSinkDesc> |
FileSinkDesc.getLinkedFileSinkDesc() |
| Modifier and Type | Method and Description |
|---|---|
void |
FileSinkDesc.setLinkedFileSinkDesc(List<FileSinkDesc> linkedFileSinkDesc) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.