org.apache.hadoop.hive.ql.plan
Class DynamicPartitionCtx

java.lang.Object
  org.apache.hadoop.hive.ql.plan.DynamicPartitionCtx

All Implemented Interfaces:

Serializable

public class DynamicPartitionCtx
extends Object
implements Serializable

See Also:

Serialized Form

Constructor Summary

DynamicPartitionCtx()

DynamicPartitionCtx(DynamicPartitionCtx dp)

DynamicPartitionCtx(Table tbl, Map<String,String> partSpec, String defaultPartName, int maxParts)

Method Summary

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)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DynamicPartitionCtx

public DynamicPartitionCtx()

DynamicPartitionCtx

public DynamicPartitionCtx(Table tbl,
                           Map<String,String> partSpec,
                           String defaultPartName,
                           int maxParts)

DynamicPartitionCtx

public DynamicPartitionCtx(DynamicPartitionCtx dp)

Method Detail

mapInputToDP

public void mapInputToDP(List<ColumnInfo> fs)

getMaxPartitionsPerNode

public int getMaxPartitionsPerNode()

setMaxPartitionsPerNode

public void setMaxPartitionsPerNode(int maxParts)

getDefaultPartitionName

public String getDefaultPartitionName()

setDefaultPartitionName

public void setDefaultPartitionName(String pname)

setNumBuckets

public void setNumBuckets(int bk)

getNumBuckets

public int getNumBuckets()

setRootPath

public void setRootPath(org.apache.hadoop.fs.Path root)

getRootPath

public org.apache.hadoop.fs.Path getRootPath()

getDPColNames

public List<String> getDPColNames()

setDPColNames

public void setDPColNames(List<String> dp)

getSPColNames

public List<String> getSPColNames()

setPartSpec

public void setPartSpec(Map<String,String> ps)

getPartSpec

public Map<String,String> getPartSpec()

setSPColNames

public void setSPColNames(List<String> sp)

getInputToDPCols

public Map<String,String> getInputToDPCols()

setInputToDPCols

public void setInputToDPCols(Map<String,String> map)

setNumDPCols

public void setNumDPCols(int dp)

getNumDPCols

public int getNumDPCols()

setNumSPCols

public void setNumSPCols(int sp)

getNumSPCols

public int getNumSPCols()

setSPPath

public void setSPPath(String sp)

getSPPath

public String getSPPath()