public class DynamicPartitionCtx extends Object implements Serializable
Constructor and Description |
---|
DynamicPartitionCtx() |
DynamicPartitionCtx(DynamicPartitionCtx dp) |
DynamicPartitionCtx(Table tbl,
Map<String,String> partSpec,
String defaultPartName,
int maxParts) |
Modifier and Type | Method and Description |
---|---|
String |
getDefaultPartitionName() |
List<String> |
getDPColNames() |
Map<String,String> |
getInputToDPCols() |
int |
getMaxPartitionsPerNode() |
int |
getNumBuckets() |
int |
getNumDPCols() |
int |
getNumSPCols() |
Map<String,String> |
getPartSpec() |
org.apache.hadoop.fs.Path |
getRootPath() |
List<String> |
getSPColNames() |
String |
getSPPath() |
void |
mapInputToDP(List<ColumnInfo> fs) |
void |
setDefaultPartitionName(String pname) |
void |
setDPColNames(List<String> dp) |
void |
setInputToDPCols(Map<String,String> map) |
void |
setMaxPartitionsPerNode(int maxParts) |
void |
setNumBuckets(int bk) |
void |
setNumDPCols(int dp) |
void |
setNumSPCols(int sp) |
void |
setPartSpec(Map<String,String> ps) |
void |
setRootPath(org.apache.hadoop.fs.Path root) |
void |
setSPColNames(List<String> sp) |
void |
setSPPath(String sp) |
public DynamicPartitionCtx()
public DynamicPartitionCtx(Table tbl, Map<String,String> partSpec, String defaultPartName, int maxParts)
public DynamicPartitionCtx(DynamicPartitionCtx dp)
public void mapInputToDP(List<ColumnInfo> fs)
public int getMaxPartitionsPerNode()
public void setMaxPartitionsPerNode(int maxParts)
public String getDefaultPartitionName()
public void setDefaultPartitionName(String pname)
public void setNumBuckets(int bk)
public int getNumBuckets()
public void setRootPath(org.apache.hadoop.fs.Path root)
public org.apache.hadoop.fs.Path getRootPath()
public void setNumDPCols(int dp)
public int getNumDPCols()
public void setNumSPCols(int sp)
public int getNumSPCols()
public void setSPPath(String sp)
public String getSPPath()
Copyright © 2017 The Apache Software Foundation. All rights reserved.