public class LoadTableDesc extends LoadDesc implements Serializable
Modifier and Type | Class and Description |
---|---|
static class |
LoadTableDesc.LoadFileType |
Constructor and Description |
---|
LoadTableDesc(LoadTableDesc o) |
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)
For DDL operations that are not ACID compliant.
|
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) |
LoadTableDesc(org.apache.hadoop.fs.Path sourcePath,
TableDesc table,
Map<String,String> partitionSpec,
LoadTableDesc.LoadFileType loadFileType,
Long writeId)
For use with non-ACID compliant operations, such as LOAD
|
Modifier and Type | Method and Description |
---|---|
DynamicPartitionCtx |
getDPCtx() |
boolean |
getInheritTableSpecs() |
ListBucketingCtx |
getLbCtx() |
LoadTableDesc.LoadFileType |
getLoadFileType() |
Map<String,String> |
getPartitionSpec() |
boolean |
getReplace() |
int |
getStmtId() |
TableDesc |
getTable() |
long |
getWriteId() |
boolean |
isInsertOverwrite() |
boolean |
isMmTable() |
Boolean |
isMmTableExplain() |
void |
setDPCtx(DynamicPartitionCtx dpCtx) |
void |
setInheritTableSpecs(boolean inheritTableSpecs) |
void |
setInsertOverwrite(boolean v) |
void |
setLbCtx(ListBucketingCtx lbCtx) |
void |
setLoadFileType(LoadTableDesc.LoadFileType loadFileType) |
void |
setPartitionSpec(Map<String,String> partitionSpec) |
void |
setStmtId(int stmtId) |
void |
setTable(TableDesc table) |
getSourcePath, getWriteType, getWriteTypeString, setSourcePath
public LoadTableDesc(LoadTableDesc o)
public LoadTableDesc(org.apache.hadoop.fs.Path sourcePath, TableDesc table, Map<String,String> partitionSpec, LoadTableDesc.LoadFileType loadFileType, AcidUtils.Operation writeType, Long currentWriteId)
public LoadTableDesc(org.apache.hadoop.fs.Path sourcePath, TableDesc table, Map<String,String> partitionSpec, LoadTableDesc.LoadFileType loadFileType, Long writeId)
sourcePath
- table
- partitionSpec
- loadFileType
- writeId
- public LoadTableDesc(org.apache.hadoop.fs.Path sourcePath, TableDesc table, Map<String,String> partitionSpec, AcidUtils.Operation writeType, Long currentWriteId)
public LoadTableDesc(org.apache.hadoop.fs.Path sourcePath, TableDesc table, Map<String,String> partitionSpec)
sourcePath
- table
- partitionSpec
- public LoadTableDesc(org.apache.hadoop.fs.Path sourcePath, TableDesc table, DynamicPartitionCtx dpCtx, AcidUtils.Operation writeType, boolean isReplace, Long writeId)
public TableDesc getTable()
public void setTable(TableDesc table)
public boolean getReplace()
public LoadTableDesc.LoadFileType getLoadFileType()
public Boolean isMmTableExplain()
public boolean isMmTable()
public void setLoadFileType(LoadTableDesc.LoadFileType loadFileType)
public DynamicPartitionCtx getDPCtx()
public void setDPCtx(DynamicPartitionCtx dpCtx)
public boolean getInheritTableSpecs()
public void setInheritTableSpecs(boolean inheritTableSpecs)
public boolean isInsertOverwrite()
public void setInsertOverwrite(boolean v)
public ListBucketingCtx getLbCtx()
public void setLbCtx(ListBucketingCtx lbCtx)
lbCtx
- the lbCtx to setpublic long getWriteId()
public int getStmtId()
public void setStmtId(int stmtId)
Copyright © 2022 The Apache Software Foundation. All rights reserved.