org.apache.hadoop.hive.ql.metadata
Class Table

java.lang.Object
  org.apache.hadoop.hive.ql.metadata.Table

All Implemented Interfaces:

Serializable

public class Table
extends Object
implements Serializable

A Hive Table: is a fundamental unit of data in Hive that shares a common schema/DDL. Please note that the ql code should always go through methods of this class to access the metadata, instead of directly accessing org.apache.hadoop.hive.metastore.api.Table. This helps to isolate the metastore code and the ql code.

See Also:

Serialized Form

Constructor Summary

Table()
Used only for serialization.

Table(String databaseName, String tableName)

Table(Table table)

Method Summary

boolean	canDrop()
boolean	canWrite()
void	checkValidity()
void	clearSerDeInfo()
Table	copy()
protected void	copyFiles(org.apache.hadoop.fs.Path srcf) Inserts files specified into the partition.
LinkedHashMap<String,String>	createSpec(Partition tp) Creates a partition name -> value spec map object
boolean	equals(Object obj)
List<FieldSchema>	getAllCols() Returns a list of all the columns of the table (data columns + partition columns in that order.
List<Index>	getAllIndexes(short max)
List<String>	getBucketCols()
String	getBucketingDimensionId()
List<FieldSchema>	getCols()
String	getCompleteName()
URI	getDataLocation()
String	getDbName()
Deserializer	getDeserializer()
StructField	getField(String fld)
ArrayList<StructField>	getFields()
Class<? extends org.apache.hadoop.mapred.InputFormat>	getInputFormatClass()
int	getLastAccessTime()
int	getNumBuckets()
Class<? extends HiveOutputFormat>	getOutputFormatClass()
String	getOwner()
Map<String,String>	getParameters()
List<FieldSchema>	getPartCols()
List<FieldSchema>	getPartitionKeys()
org.apache.hadoop.fs.Path	getPath()
String	getProperty(String name)
ProtectMode	getProtectMode()
int	getRetention()
Properties	getSchema()
String	getSerdeParam(String param)
String	getSerializationLib()
List<String>	getSkewedColNames()
Map<List<String>,String>	getSkewedColValueLocationMaps()
List<List<String>>	getSkewedColValues()
SkewedInfo	getSkewedInfo()
List<Order>	getSortCols()
HiveStorageHandler	getStorageHandler()
String	getTableName()
TableType	getTableType()
Table	getTTable() This function should only be used in serialization.
String	getViewExpandedText()
String	getViewOriginalText()
int	hashCode()
boolean	isIndexTable()
boolean	isNonNative()
boolean	isOffline()
boolean	isPartitioned()
boolean	isPartitionKey(String colName)
boolean	isStoredAsSubDirectories()
boolean	isValidSpec(Map<String,String> spec)
boolean	isView()
protected void	replaceFiles(org.apache.hadoop.fs.Path srcf) Replaces the directory corresponding to the table by srcf.
void	setBucketCols(List<String> bucketCols)
void	setCreateTime(int createTime)
void	setDataLocation(URI uri)
void	setDbName(String databaseName)
void	setFields(List<FieldSchema> fields)
void	setInputFormatClass(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass)
void	setInputFormatClass(String name)
void	setLastAccessTime(int lastAccessTime)
void	setNumBuckets(int nb)
void	setOutputFormatClass(Class<? extends HiveOutputFormat> outputFormatClass)
void	setOutputFormatClass(String name)
void	setOwner(String owner)
void	setPartCols(List<FieldSchema> partCols)
void	setProperty(String name, String value)
void	setProtectMode(ProtectMode protectMode)
void	setRetention(int retention)
String	setSerdeParam(String param, String value)
void	setSerializationLib(String lib)
void	setSkewedColNames(List<String> skewedColNames)
void	setSkewedColValues(List<List<String>> skewedValues)
void	setSkewedInfo(SkewedInfo skewedInfo)
void	setSkewedValueLocationMap(List<String> valList, String dirName)
void	setSortCols(List<Order> sortOrder)
void	setStoredAsSubDirectories(boolean storedAsSubDirectories)
void	setTableName(String tableName)
void	setTableType(TableType tableType)
void	setTTable(Table tTable) This function should only be called by Java serialization.
void	setViewExpandedText(String viewExpandedText)
void	setViewOriginalText(String viewOriginalText)
String	toString()
void	unsetDataLocation()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

Table

public Table()

Used only for serialization.

Table

public Table(Table table)

Table

public Table(String databaseName,
             String tableName)

Method Detail

getTTable

public Table getTTable()

This function should only be used in serialization. We should never call this function to modify the fields, because the cached fields will become outdated.

setTTable

public void setTTable(Table tTable)

This function should only be called by Java serialization.

checkValidity

public void checkValidity()
                   throws HiveException

Throws:

HiveException

setInputFormatClass

public void setInputFormatClass(Class<? extends org.apache.hadoop.mapred.InputFormat> inputFormatClass)

setOutputFormatClass

public void setOutputFormatClass(Class<? extends HiveOutputFormat> outputFormatClass)

getSchema

public final Properties getSchema()

getPath

public final org.apache.hadoop.fs.Path getPath()

getTableName

public final String getTableName()

getDataLocation

public final URI getDataLocation()

getDeserializer

public final Deserializer getDeserializer()

getStorageHandler

public HiveStorageHandler getStorageHandler()

getInputFormatClass

public final Class<? extends org.apache.hadoop.mapred.InputFormat> getInputFormatClass()

getOutputFormatClass

public final Class<? extends HiveOutputFormat> getOutputFormatClass()

isValidSpec

public final boolean isValidSpec(Map<String,String> spec)
                          throws HiveException

Throws:

HiveException

setProperty

public void setProperty(String name,
                        String value)

getProperty

public String getProperty(String name)

setTableType

public void setTableType(TableType tableType)

getTableType

public TableType getTableType()

getFields

public ArrayList<StructField> getFields()

getField

public StructField getField(String fld)

toString

public String toString()

Overrides:

toString in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getPartCols

public List<FieldSchema> getPartCols()

isPartitionKey

public boolean isPartitionKey(String colName)

getBucketingDimensionId

public String getBucketingDimensionId()

setDataLocation

public void setDataLocation(URI uri)

unsetDataLocation

public void unsetDataLocation()

setBucketCols

public void setBucketCols(List<String> bucketCols)
                   throws HiveException

Throws:

HiveException

setSortCols

public void setSortCols(List<Order> sortOrder)
                 throws HiveException

Throws:

HiveException

setSkewedValueLocationMap

public void setSkewedValueLocationMap(List<String> valList,
                                      String dirName)
                               throws HiveException

Throws:

HiveException

getSkewedColValueLocationMaps

public Map<List<String>,String> getSkewedColValueLocationMaps()

setSkewedColValues

public void setSkewedColValues(List<List<String>> skewedValues)
                        throws HiveException

Throws:

HiveException

getSkewedColValues

public List<List<String>> getSkewedColValues()

setSkewedColNames

public void setSkewedColNames(List<String> skewedColNames)
                       throws HiveException

Throws:

HiveException

getSkewedColNames

public List<String> getSkewedColNames()

getSkewedInfo

public SkewedInfo getSkewedInfo()

setSkewedInfo

public void setSkewedInfo(SkewedInfo skewedInfo)
                   throws HiveException

Throws:

HiveException

isStoredAsSubDirectories

public boolean isStoredAsSubDirectories()

setStoredAsSubDirectories

public void setStoredAsSubDirectories(boolean storedAsSubDirectories)
                               throws HiveException

Throws:

HiveException

getCols

public List<FieldSchema> getCols()

getAllCols

public List<FieldSchema> getAllCols()

Returns a list of all the columns of the table (data columns + partition columns in that order.

Returns:

List

setPartCols

public void setPartCols(List<FieldSchema> partCols)

getDbName

public String getDbName()

getNumBuckets

public int getNumBuckets()

replaceFiles

protected void replaceFiles(org.apache.hadoop.fs.Path srcf)
                     throws HiveException

Replaces the directory corresponding to the table by srcf. Works by deleting the table directory and renaming the source directory.

Parameters:

srcf - Source directory

Throws:

HiveException

copyFiles

protected void copyFiles(org.apache.hadoop.fs.Path srcf)
                  throws HiveException

Inserts files specified into the partition. Works by moving files

Parameters:

srcf - Files to be moved. Leaf directories or globbed file paths

Throws:

HiveException

setInputFormatClass

public void setInputFormatClass(String name)
                         throws HiveException

Throws:

HiveException

setOutputFormatClass

public void setOutputFormatClass(String name)
                          throws HiveException

Throws:

HiveException

isPartitioned

public boolean isPartitioned()

setFields

public void setFields(List<FieldSchema> fields)

setNumBuckets

public void setNumBuckets(int nb)

getOwner

public String getOwner()

Returns:

The owner of the table.

See Also:

Table.getOwner()

getParameters

public Map<String,String> getParameters()

Returns:

The table parameters.

See Also:

Table.getParameters()

getRetention

public int getRetention()

Returns:

The retention on the table.

See Also:

Table.getRetention()

setOwner

public void setOwner(String owner)

Parameters:

owner -

See Also:

Table.setOwner(java.lang.String)

setRetention

public void setRetention(int retention)

Parameters:

retention -

See Also:

Table.setRetention(int)

setSerializationLib

public void setSerializationLib(String lib)

getSerializationLib

public String getSerializationLib()

getSerdeParam

public String getSerdeParam(String param)

setSerdeParam

public String setSerdeParam(String param,
                            String value)

getBucketCols

public List<String> getBucketCols()

getSortCols

public List<Order> getSortCols()

setTableName

public void setTableName(String tableName)

setDbName

public void setDbName(String databaseName)

getPartitionKeys

public List<FieldSchema> getPartitionKeys()

getViewOriginalText

public String getViewOriginalText()

Returns:

the original view text, or null if this table is not a view

setViewOriginalText

public void setViewOriginalText(String viewOriginalText)

Parameters:

viewOriginalText - the original view text to set

getViewExpandedText

public String getViewExpandedText()

Returns:

the expanded view text, or null if this table is not a view

clearSerDeInfo

public void clearSerDeInfo()

setViewExpandedText

public void setViewExpandedText(String viewExpandedText)

Parameters:

viewExpandedText - the expanded view text to set

isView

public boolean isView()

Returns:

whether this table is actually a view

isIndexTable

public boolean isIndexTable()

Returns:

whether this table is actually an index table

createSpec

public LinkedHashMap<String,String> createSpec(Partition tp)

Creates a partition name -> value spec map object

Parameters:

tp - Use the information from this partition.

Returns:

Partition name to value mapping.

copy

public Table copy()
           throws HiveException

Throws:

HiveException

setCreateTime

public void setCreateTime(int createTime)

getLastAccessTime

public int getLastAccessTime()

setLastAccessTime

public void setLastAccessTime(int lastAccessTime)

isNonNative

public boolean isNonNative()

setProtectMode

public void setProtectMode(ProtectMode protectMode)

Parameters:

protectMode -

getProtectMode

public ProtectMode getProtectMode()

Returns:

protect mode

isOffline

public boolean isOffline()

Returns:

True protect mode indicates the table if offline.

canDrop

public boolean canDrop()

Returns:

True if protect mode attribute of the partition indicate that it is OK to drop the partition

canWrite

public boolean canWrite()

Returns:

True if protect mode attribute of the table indicate that it is OK to write the table

getCompleteName

public String getCompleteName()

Returns:

include the db name

getAllIndexes

public List<Index> getAllIndexes(short max)
                          throws HiveException

Returns:

List containing Indexes names if there are indexes on this table

Throws:

HiveException