public class Table
extends java.lang.Object
implements java.io.Serializable
Constructor and Description |
---|
Table()
Used only for serialization.
|
Table(java.lang.String databaseName,
java.lang.String tableName) |
Table(Table table) |
Modifier and Type | Method and Description |
---|---|
boolean |
canDrop() |
boolean |
canWrite() |
void |
checkValidity() |
void |
clearSerDeInfo() |
Table |
copy() |
protected void |
copyFiles(Path srcf)
Inserts files specified into the partition.
|
java.util.LinkedHashMap<java.lang.String,java.lang.String> |
createSpec(Partition tp)
Creates a partition name -> value spec map object
|
boolean |
equals(java.lang.Object obj) |
java.util.List<FieldSchema> |
getAllCols()
Returns a list of all the columns of the table (data columns + partition
columns in that order.
|
java.util.List<Index> |
getAllIndexes(short max) |
java.util.List<java.lang.String> |
getBucketCols() |
java.lang.String |
getBucketingDimensionId() |
java.util.List<FieldSchema> |
getCols() |
java.lang.String |
getCompleteName() |
java.net.URI |
getDataLocation() |
java.lang.String |
getDbName() |
Deserializer |
getDeserializer() |
StructField |
getField(java.lang.String fld) |
java.util.ArrayList<StructField> |
getFields() |
java.lang.Class<? extends InputFormat> |
getInputFormatClass() |
int |
getLastAccessTime() |
java.util.Properties |
getMetadata() |
int |
getNumBuckets() |
java.lang.Class<? extends HiveOutputFormat> |
getOutputFormatClass() |
java.lang.String |
getOwner() |
java.util.Map<java.lang.String,java.lang.String> |
getParameters() |
java.util.List<FieldSchema> |
getPartCols() |
java.util.List<FieldSchema> |
getPartitionKeys() |
Path |
getPath() |
java.lang.String |
getProperty(java.lang.String name) |
ProtectMode |
getProtectMode() |
int |
getRetention() |
java.lang.String |
getSerdeParam(java.lang.String param) |
java.lang.String |
getSerializationLib() |
java.util.List<java.lang.String> |
getSkewedColNames() |
java.util.Map<java.util.List<java.lang.String>,java.lang.String> |
getSkewedColValueLocationMaps() |
java.util.List<java.util.List<java.lang.String>> |
getSkewedColValues() |
SkewedInfo |
getSkewedInfo() |
java.util.List<Order> |
getSortCols() |
FileStatus[] |
getSortedPaths() |
HiveStorageHandler |
getStorageHandler() |
java.lang.String |
getTableName() |
TableType |
getTableType() |
Table |
getTTable()
This function should only be used in serialization.
|
java.lang.String |
getViewExpandedText() |
java.lang.String |
getViewOriginalText() |
int |
hashCode() |
boolean |
isIndexTable() |
boolean |
isNonNative() |
boolean |
isOffline() |
boolean |
isPartitioned() |
boolean |
isPartitionKey(java.lang.String colName) |
boolean |
isStoredAsSubDirectories() |
boolean |
isValidSpec(java.util.Map<java.lang.String,java.lang.String> spec) |
boolean |
isView() |
protected void |
replaceFiles(Path srcf)
Replaces the directory corresponding to the table by srcf.
|
void |
setBucketCols(java.util.List<java.lang.String> bucketCols) |
void |
setCreateTime(int createTime) |
void |
setDataLocation(java.net.URI uri) |
void |
setDbName(java.lang.String databaseName) |
void |
setFields(java.util.List<FieldSchema> fields) |
void |
setInputFormatClass(java.lang.Class<? extends InputFormat> inputFormatClass) |
void |
setInputFormatClass(java.lang.String name) |
void |
setLastAccessTime(int lastAccessTime) |
void |
setNumBuckets(int nb) |
void |
setOutputFormatClass(java.lang.Class<? extends HiveOutputFormat> outputFormatClass) |
void |
setOutputFormatClass(java.lang.String name) |
void |
setOwner(java.lang.String owner) |
void |
setPartCols(java.util.List<FieldSchema> partCols) |
void |
setProperty(java.lang.String name,
java.lang.String value) |
void |
setProtectMode(ProtectMode protectMode) |
void |
setRetention(int retention) |
java.lang.String |
setSerdeParam(java.lang.String param,
java.lang.String value) |
void |
setSerializationLib(java.lang.String lib) |
void |
setSkewedColNames(java.util.List<java.lang.String> skewedColNames) |
void |
setSkewedColValues(java.util.List<java.util.List<java.lang.String>> skewedValues) |
void |
setSkewedInfo(SkewedInfo skewedInfo) |
void |
setSkewedValueLocationMap(java.util.List<java.lang.String> valList,
java.lang.String dirName) |
void |
setSortCols(java.util.List<Order> sortOrder) |
void |
setStoredAsSubDirectories(boolean storedAsSubDirectories) |
void |
setTableName(java.lang.String tableName) |
void |
setTableType(TableType tableType) |
void |
setTTable(Table tTable)
This function should only be called by Java serialization.
|
void |
setViewExpandedText(java.lang.String viewExpandedText) |
void |
setViewOriginalText(java.lang.String viewOriginalText) |
java.lang.String |
toString() |
void |
unsetDataLocation() |
public Table()
public Table(Table table)
public Table(java.lang.String databaseName, java.lang.String tableName)
public Table getTTable()
public void setTTable(Table tTable)
public void checkValidity() throws HiveException
HiveException
public void setInputFormatClass(java.lang.Class<? extends InputFormat> inputFormatClass)
public void setOutputFormatClass(java.lang.Class<? extends HiveOutputFormat> outputFormatClass)
public final java.util.Properties getMetadata()
public final Path getPath()
public final java.lang.String getTableName()
public final java.net.URI getDataLocation()
public final Deserializer getDeserializer()
public HiveStorageHandler getStorageHandler()
public final java.lang.Class<? extends InputFormat> getInputFormatClass()
public final java.lang.Class<? extends HiveOutputFormat> getOutputFormatClass()
public final boolean isValidSpec(java.util.Map<java.lang.String,java.lang.String> spec) throws HiveException
HiveException
public void setProperty(java.lang.String name, java.lang.String value)
public java.lang.String getProperty(java.lang.String name)
public void setTableType(TableType tableType)
public TableType getTableType()
public java.util.ArrayList<StructField> getFields()
public StructField getField(java.lang.String fld)
public java.lang.String toString()
toString
in class java.lang.Object
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public java.util.List<FieldSchema> getPartCols()
public boolean isPartitionKey(java.lang.String colName)
public java.lang.String getBucketingDimensionId()
public void setDataLocation(java.net.URI uri)
public void unsetDataLocation()
public void setBucketCols(java.util.List<java.lang.String> bucketCols) throws HiveException
HiveException
public void setSortCols(java.util.List<Order> sortOrder) throws HiveException
HiveException
public void setSkewedValueLocationMap(java.util.List<java.lang.String> valList, java.lang.String dirName) throws HiveException
HiveException
public java.util.Map<java.util.List<java.lang.String>,java.lang.String> getSkewedColValueLocationMaps()
public void setSkewedColValues(java.util.List<java.util.List<java.lang.String>> skewedValues) throws HiveException
HiveException
public java.util.List<java.util.List<java.lang.String>> getSkewedColValues()
public void setSkewedColNames(java.util.List<java.lang.String> skewedColNames) throws HiveException
HiveException
public java.util.List<java.lang.String> getSkewedColNames()
public SkewedInfo getSkewedInfo()
public void setSkewedInfo(SkewedInfo skewedInfo) throws HiveException
HiveException
public boolean isStoredAsSubDirectories()
public void setStoredAsSubDirectories(boolean storedAsSubDirectories) throws HiveException
HiveException
public java.util.List<FieldSchema> getCols()
public java.util.List<FieldSchema> getAllCols()
public void setPartCols(java.util.List<FieldSchema> partCols)
public java.lang.String getDbName()
public int getNumBuckets()
protected void replaceFiles(Path srcf) throws HiveException
srcf
- Source directoryHiveException
protected void copyFiles(Path srcf) throws HiveException
srcf
- Files to be moved. Leaf directories or globbed file pathsHiveException
public void setInputFormatClass(java.lang.String name) throws HiveException
HiveException
public void setOutputFormatClass(java.lang.String name) throws HiveException
HiveException
public boolean isPartitioned()
public void setFields(java.util.List<FieldSchema> fields)
public void setNumBuckets(int nb)
public java.lang.String getOwner()
Table.getOwner()
public java.util.Map<java.lang.String,java.lang.String> getParameters()
Table.getParameters()
public int getRetention()
Table.getRetention()
public void setOwner(java.lang.String owner)
owner
- Table.setOwner(java.lang.String)
public void setRetention(int retention)
retention
- Table.setRetention(int)
public void setSerializationLib(java.lang.String lib)
public java.lang.String getSerializationLib()
public java.lang.String getSerdeParam(java.lang.String param)
public java.lang.String setSerdeParam(java.lang.String param, java.lang.String value)
public java.util.List<java.lang.String> getBucketCols()
public java.util.List<Order> getSortCols()
public void setTableName(java.lang.String tableName)
public void setDbName(java.lang.String databaseName)
public java.util.List<FieldSchema> getPartitionKeys()
public java.lang.String getViewOriginalText()
public void setViewOriginalText(java.lang.String viewOriginalText)
viewOriginalText
- the original view text to setpublic java.lang.String getViewExpandedText()
public void clearSerDeInfo()
public void setViewExpandedText(java.lang.String viewExpandedText)
viewExpandedText
- the expanded view text to setpublic boolean isView()
public boolean isIndexTable()
public java.util.LinkedHashMap<java.lang.String,java.lang.String> createSpec(Partition tp)
tp
- Use the information from this partition.public Table copy() throws HiveException
HiveException
public void setCreateTime(int createTime)
public int getLastAccessTime()
public void setLastAccessTime(int lastAccessTime)
public boolean isNonNative()
public void setProtectMode(ProtectMode protectMode)
protectMode
- public ProtectMode getProtectMode()
public boolean isOffline()
public boolean canDrop()
public boolean canWrite()
public java.lang.String getCompleteName()
public java.util.List<Index> getAllIndexes(short max) throws HiveException
HiveException
public FileStatus[] getSortedPaths()
Copyright © 2012 The Apache Software Foundation