Package | Description |
---|---|
org.apache.hadoop.hive.ql.exec |
Hive QL execution tasks, operators, functions and other handlers.
|
org.apache.hadoop.hive.ql.io.rcfile.truncate | |
org.apache.hadoop.hive.ql.parse | |
org.apache.hadoop.hive.ql.plan |
Modifier and Type | Field and Description |
---|---|
protected DynamicPartitionCtx |
FileSinkOperator.dpCtx |
protected DynamicPartitionCtx |
AbstractFileMergeOperator.dpCtx |
Modifier and Type | Method and Description |
---|---|
static List<LinkedHashMap<String,String>> |
Utilities.getFullDPSpecs(org.apache.hadoop.conf.Configuration conf,
DynamicPartitionCtx dpCtx)
Construct a list of full partition spec from Dynamic Partition Context and the directory names
corresponding to these dynamic partitions.
|
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) |
static ArrayList<String> |
Utilities.removeTempOrDuplicateFiles(org.apache.hadoop.fs.FileSystem fs,
org.apache.hadoop.fs.Path path,
DynamicPartitionCtx dpCtx)
Remove all temporary files and duplicate (double-committed) files from a given directory.
|
Modifier and Type | Method and Description |
---|---|
DynamicPartitionCtx |
ColumnTruncateWork.getDynPartCtx() |
Modifier and Type | Method and Description |
---|---|
static void |
ColumnTruncateMapper.jobClose(org.apache.hadoop.fs.Path outputPath,
boolean success,
org.apache.hadoop.mapred.JobConf job,
SessionState.LogHelper console,
DynamicPartitionCtx dynPartCtx,
org.apache.hadoop.mapred.Reporter reporter) |
void |
ColumnTruncateWork.setDynPartCtx(DynamicPartitionCtx dynPartCtx) |
Constructor and Description |
---|
ColumnTruncateWork(List<Integer> droppedColumns,
org.apache.hadoop.fs.Path inputDir,
org.apache.hadoop.fs.Path outputDir,
boolean hasDynamicPartitions,
DynamicPartitionCtx dynPartCtx) |
Modifier and Type | Method and Description |
---|---|
DynamicPartitionCtx |
QBMetaData.getDPCtx(String alias) |
Modifier and Type | Method and Description |
---|---|
void |
QBMetaData.setDPCtx(String alias,
DynamicPartitionCtx dpCtx) |
Modifier and Type | Method and Description |
---|---|
DynamicPartitionCtx |
FileMergeDesc.getDpCtx() |
DynamicPartitionCtx |
LoadTableDesc.getDPCtx() |
DynamicPartitionCtx |
ConditionalResolverMergeFiles.ConditionalResolverMergeFilesCtx.getDPCtx() |
DynamicPartitionCtx |
FileSinkDesc.getDynPartCtx() |
Modifier and Type | Method and Description |
---|---|
void |
FileMergeDesc.setDpCtx(DynamicPartitionCtx dpCtx) |
void |
LoadTableDesc.setDPCtx(DynamicPartitionCtx dpCtx) |
void |
ConditionalResolverMergeFiles.ConditionalResolverMergeFilesCtx.setDPCtx(DynamicPartitionCtx dp) |
void |
FileSinkDesc.setDynPartCtx(DynamicPartitionCtx dpc) |
Constructor and Description |
---|
DynamicPartitionCtx(DynamicPartitionCtx dp) |
FileMergeDesc(DynamicPartitionCtx dynPartCtx,
org.apache.hadoop.fs.Path outputDir) |
FileSinkDesc(org.apache.hadoop.fs.Path dirName,
TableDesc tableInfo,
boolean compressed,
int destTableId,
boolean multiFileSpray,
boolean canBeMerged,
int numFiles,
int totalFiles,
ArrayList<ExprNodeDesc> partitionCols,
DynamicPartitionCtx dpCtx) |
LoadTableDesc(org.apache.hadoop.fs.Path sourcePath,
TableDesc table,
DynamicPartitionCtx dpCtx,
AcidUtils.Operation writeType) |
OrcFileMergeDesc(DynamicPartitionCtx dpCtx,
org.apache.hadoop.fs.Path outPath) |
RCFileMergeDesc(DynamicPartitionCtx dpCtx,
org.apache.hadoop.fs.Path outPath) |
Copyright © 2017 The Apache Software Foundation. All rights reserved.