Package | Description |
---|---|
org.apache.hadoop.hive.ql.io | |
org.apache.hadoop.hive.ql.metadata | |
org.apache.hadoop.hive.ql.plan |
Modifier and Type | Method and Description |
---|---|
static AcidUtils.Operation |
AcidUtils.Operation.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AcidUtils.Operation[] |
AcidUtils.Operation.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
static DataOperationType |
AcidUtils.toDataOperationType(AcidUtils.Operation op)
Logically this should have been defined in Operation but that causes a dependency
on metastore package from exec jar (from the cluster) which is not allowed.
|
Modifier and Type | Method and Description |
---|---|
Map<Map<String,String>,Partition> |
Hive.loadDynamicPartitions(org.apache.hadoop.fs.Path loadPath,
String tableName,
Map<String,String> partSpec,
LoadTableDesc.LoadFileType loadFileType,
int numDP,
int numLB,
boolean isAcid,
long writeId,
int stmtId,
boolean hasFollowingStatsTask,
AcidUtils.Operation operation,
boolean isInsertOverwrite)
Given a source directory name of the load path, load all dynamically generated partitions
into the specified table and return a list of strings that represent the dynamic partition
paths.
|
Modifier and Type | Method and Description |
---|---|
AcidUtils.Operation |
FileSinkDesc.getWriteType() |
AcidUtils.Operation |
LoadDesc.getWriteType() |
AcidUtils.Operation |
ReduceSinkDesc.getWriteType() |
Modifier and Type | Method and Description |
---|---|
static ReduceSinkDesc |
PlanUtils.getReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
ArrayList<ExprNodeDesc> valueCols,
List<String> outputColumnNames,
boolean includeKeyCols,
int tag,
ArrayList<ExprNodeDesc> partitionCols,
String order,
String nullOrder,
int numReducers,
AcidUtils.Operation writeType)
Create the reduce sink descriptor.
|
static ReduceSinkDesc |
PlanUtils.getReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
ArrayList<ExprNodeDesc> valueCols,
List<String> outputColumnNames,
boolean includeKey,
int tag,
int numPartitionFields,
int numReducers,
AcidUtils.Operation writeType)
Create the reduce sink descriptor.
|
static ReduceSinkDesc |
PlanUtils.getReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
int numKeys,
ArrayList<ExprNodeDesc> valueCols,
List<List<Integer>> distinctColIndices,
List<String> outputKeyColumnNames,
List<String> outputValueColumnNames,
boolean includeKeyCols,
int tag,
ArrayList<ExprNodeDesc> partitionCols,
String order,
String nullOrder,
int numReducers,
AcidUtils.Operation writeType)
Create the reduce sink descriptor.
|
static ReduceSinkDesc |
PlanUtils.getReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
int numKeys,
ArrayList<ExprNodeDesc> valueCols,
List<List<Integer>> distinctColIndices,
List<String> outputKeyColumnNames,
List<String> outputValueColumnNames,
boolean includeKey,
int tag,
int numPartitionFields,
int numReducers,
AcidUtils.Operation writeType)
Create the reduce sink descriptor.
|
void |
FileSinkDesc.setWriteType(AcidUtils.Operation type) |
Constructor and Description |
---|
LoadFileDesc(CreateTableDesc createTableDesc,
CreateViewDesc createViewDesc,
org.apache.hadoop.fs.Path sourcePath,
org.apache.hadoop.fs.Path targetDir,
boolean isDfsDir,
String columns,
String columnTypes,
AcidUtils.Operation writeType,
boolean isMmCtas) |
LoadTableDesc(org.apache.hadoop.fs.Path sourcePath,
TableDesc table,
DynamicPartitionCtx dpCtx,
AcidUtils.Operation writeType,
boolean isReplace,
Long writeId) |
LoadTableDesc(org.apache.hadoop.fs.Path sourcePath,
TableDesc table,
Map<String,String> partitionSpec,
AcidUtils.Operation writeType,
Long currentWriteId) |
LoadTableDesc(org.apache.hadoop.fs.Path sourcePath,
TableDesc table,
Map<String,String> partitionSpec,
LoadTableDesc.LoadFileType loadFileType,
AcidUtils.Operation writeType,
Long currentWriteId) |
ReduceSinkDesc(ArrayList<ExprNodeDesc> keyCols,
int numDistributionKeys,
ArrayList<ExprNodeDesc> valueCols,
ArrayList<String> outputKeyColumnNames,
List<List<Integer>> distinctColumnIndices,
ArrayList<String> outputValueColumnNames,
int tag,
ArrayList<ExprNodeDesc> partitionCols,
int numReducers,
TableDesc keySerializeInfo,
TableDesc valueSerializeInfo,
AcidUtils.Operation writeType) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.