org.apache.hadoop.hive.ql.plan

Class TableScanDesc

java.lang.Object

org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

org.apache.hadoop.hive.ql.plan.TableScanDesc

All Implemented Interfaces:

Serializable, Cloneable, IStatsGatherDesc, OperatorDesc

public class TableScanDesc
extends AbstractOperatorDesc
implements IStatsGatherDesc

Table Scan Descriptor Currently, data is only read from a base source as part of map-reduce framework. So, nothing is stored in the descriptor. But, more things will be added here as table scan is invoked as part of local work.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TableScanDesc.TableScanOperatorExplainVectorization

Field Summary

Fields

Modifier and Type	Field and Description
static String	FILTER_EXPR_CONF_STR
static String	FILTER_OBJECT_CONF_STR
static String	FILTER_TEXT_CONF_STR

Fields inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode

Constructor Summary

Constructors

Constructor and Description
TableScanDesc()
TableScanDesc(String alias, List<VirtualColumn> vcs, Table tblMetadata)
TableScanDesc(String alias, Table tblMetadata)
TableScanDesc(Table tblMetadata)

Method Summary

Modifier and Type	Method and Description
void	addVirtualCols(List<VirtualColumn> virtualCols)
Object	clone()
AcidUtils.AcidOperationalProperties	getAcidOperationalProperties()
String	getAlias()
Map<String,Integer>	getBucketFileNameMapping()
List<String>	getColumnNamesForExplain()
String	getDatabaseName()
ExprNodeGenericFuncDesc	getFilterExpr()
String	getFilterExprString()
Serializable	getFilterObject()
String	getIncludedBucketExplain()
BitSet	getIncludedBuckets()
boolean	getIsMetadataOnly()
List<Integer>	getNeededColumnIDs()
List<String>	getNeededColumns()
List<String>	getNeededNestedColumnPaths()
int	getNumBuckets()
Map<String,String>	getOpProps()
List<String>	getOutputColumnNames()
List<String>	getPartColumns()
String	getPredicateString()
List<String>	getPrunedColumnPaths()
String	getQualifiedTable()
List<String>	getReferencedColumns()
int	getRowLimit()
Integer	getRowLimitExplain()
String	getSerializedFilterExpr()
String	getSerializedFilterObject()
String	getStatsAggPrefix()
Table	getTableMetadata()
String	getTableName()
TableSample	getTableSample()
TableScanDesc.TableScanOperatorExplainVectorization	getTableScanVectorization()
String	getTbl()
String	getTmpStatsDir()
List<VirtualColumn>	getVirtualCols()
boolean	hasVirtualCols()
boolean	isFullAcidTable()
boolean	isGatherStats()
boolean	isNeedSkipHeaderFooters()
boolean	isSame(OperatorDesc other) The default implementation delegates to Object.equals(Object).
boolean	isStatsReliable()
boolean	isTemporary()
boolean	isTranscationalTable()
boolean	isVectorized()
void	setAlias(String alias)
void	setBucketFileNameMapping(Map<String,Integer> bucketFileNameMapping)
void	setFilterExpr(ExprNodeGenericFuncDesc filterExpr)
void	setFilterObject(Serializable filterObject)
void	setGatherStats(boolean gatherStats)
void	setIncludedBuckets(BitSet bitset)
void	setIsMetadataOnly(boolean metadata_only)
void	setNeededColumnIDs(List<Integer> neededColumnIDs)
void	setNeededColumns(List<String> neededColumns)
void	setNeededNestedColumnPaths(List<String> neededNestedColumnPaths)
void	setNumBuckets(int numBuckets)
void	setPartColumns(List<String> partColumns)
void	setReferencedColumns(List<String> referencedColumns)
void	setRowLimit(int rowLimit)
void	setSerializedFilterExpr(String serializedFilterExpr)
void	setSerializedFilterObject(String serializedFilterObject)
void	setStatsAggPrefix(String k)
void	setStatsReliable(boolean statsReliable)
void	setTableMetadata(Table tableMetadata)
void	setTableSample(TableSample tableSample)
void	setTmpStatsDir(String tmpStatsDir)
void	setVectorized(boolean vectorized)
void	setVirtualCols(List<VirtualColumn> virtualCols)

Methods inherited from class org.apache.hadoop.hive.ql.plan.AbstractOperatorDesc

fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode

Methods inherited from class java.lang.Object

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

Field Detail

FILTER_EXPR_CONF_STR

public static final String FILTER_EXPR_CONF_STR

See Also:

Constant Field Values

FILTER_TEXT_CONF_STR

public static final String FILTER_TEXT_CONF_STR

See Also:

Constant Field Values

FILTER_OBJECT_CONF_STR

public static final String FILTER_OBJECT_CONF_STR

See Also:

Constant Field Values

Constructor Detail

TableScanDesc

public TableScanDesc()

TableScanDesc

public TableScanDesc(Table tblMetadata)

TableScanDesc

public TableScanDesc(String alias,
                     Table tblMetadata)

TableScanDesc

public TableScanDesc(String alias,
                     List<VirtualColumn> vcs,
                     Table tblMetadata)

Method Detail

clone

public Object clone()

Specified by:

clone in interface OperatorDesc

Overrides:

clone in class AbstractOperatorDesc

getAlias

public String getAlias()

getPredicateString

public String getPredicateString()

getTableName

public String getTableName()

getDatabaseName

public String getDatabaseName()

getColumnNamesForExplain

public List<String> getColumnNamesForExplain()

isTemporary

public boolean isTemporary()

getTbl

public String getTbl()

isTranscationalTable

public boolean isTranscationalTable()

getAcidOperationalProperties

public AcidUtils.AcidOperationalProperties getAcidOperationalProperties()

getOutputColumnNames

public List<String> getOutputColumnNames()

getFilterExprString

public String getFilterExprString()

getFilterExpr

public ExprNodeGenericFuncDesc getFilterExpr()

setFilterExpr

public void setFilterExpr(ExprNodeGenericFuncDesc filterExpr)

getFilterObject

public Serializable getFilterObject()

setFilterObject

public void setFilterObject(Serializable filterObject)

setNeededColumnIDs

public void setNeededColumnIDs(List<Integer> neededColumnIDs)

getNeededColumnIDs

public List<Integer> getNeededColumnIDs()

getNeededNestedColumnPaths

public List<String> getNeededNestedColumnPaths()

setNeededNestedColumnPaths

public void setNeededNestedColumnPaths(List<String> neededNestedColumnPaths)

setNeededColumns

public void setNeededColumns(List<String> neededColumns)

getNeededColumns

public List<String> getNeededColumns()

getPrunedColumnPaths

public List<String> getPrunedColumnPaths()

setReferencedColumns

public void setReferencedColumns(List<String> referencedColumns)

getReferencedColumns

public List<String> getReferencedColumns()

setAlias

public void setAlias(String alias)

setPartColumns

public void setPartColumns(List<String> partColumns)

getPartColumns

public List<String> getPartColumns()

setGatherStats

public void setGatherStats(boolean gatherStats)

isGatherStats

public boolean isGatherStats()

Specified by:

isGatherStats in interface IStatsGatherDesc

getTmpStatsDir

public String getTmpStatsDir()

Specified by:

getTmpStatsDir in interface IStatsGatherDesc

setTmpStatsDir

public void setTmpStatsDir(String tmpStatsDir)

getVirtualCols

public List<VirtualColumn> getVirtualCols()

setVirtualCols

public void setVirtualCols(List<VirtualColumn> virtualCols)

addVirtualCols

public void addVirtualCols(List<VirtualColumn> virtualCols)

hasVirtualCols

public boolean hasVirtualCols()

setStatsAggPrefix

public void setStatsAggPrefix(String k)

getStatsAggPrefix

public String getStatsAggPrefix()

Specified by:

getStatsAggPrefix in interface IStatsGatherDesc

isStatsReliable

public boolean isStatsReliable()

setStatsReliable

public void setStatsReliable(boolean statsReliable)

setRowLimit

public void setRowLimit(int rowLimit)

getRowLimit

public int getRowLimit()

getRowLimitExplain

public Integer getRowLimitExplain()

getBucketFileNameMapping

public Map<String,Integer> getBucketFileNameMapping()

setBucketFileNameMapping

public void setBucketFileNameMapping(Map<String,Integer> bucketFileNameMapping)

setIsMetadataOnly

public void setIsMetadataOnly(boolean metadata_only)

getIsMetadataOnly

public boolean getIsMetadataOnly()

getQualifiedTable

public String getQualifiedTable()

getTableMetadata

public Table getTableMetadata()

setTableMetadata

public void setTableMetadata(Table tableMetadata)

getTableSample

public TableSample getTableSample()

setTableSample

public void setTableSample(TableSample tableSample)

getSerializedFilterExpr

public String getSerializedFilterExpr()

setSerializedFilterExpr

public void setSerializedFilterExpr(String serializedFilterExpr)

getSerializedFilterObject

public String getSerializedFilterObject()

setSerializedFilterObject

public void setSerializedFilterObject(String serializedFilterObject)

setIncludedBuckets

public void setIncludedBuckets(BitSet bitset)

getIncludedBuckets

public BitSet getIncludedBuckets()

getIncludedBucketExplain

public String getIncludedBucketExplain()

getNumBuckets

public int getNumBuckets()

setNumBuckets

public void setNumBuckets(int numBuckets)

isNeedSkipHeaderFooters

public boolean isNeedSkipHeaderFooters()

getOpProps

public Map<String,String> getOpProps()

Specified by:

getOpProps in interface OperatorDesc

Overrides:

getOpProps in class AbstractOperatorDesc

getTableScanVectorization

public TableScanDesc.TableScanOperatorExplainVectorization getTableScanVectorization()

setVectorized

public void setVectorized(boolean vectorized)

isVectorized

public boolean isVectorized()

isSame

public boolean isSame(OperatorDesc other)

Description copied from class: AbstractOperatorDesc

The default implementation delegates to Object.equals(Object). Intended to be overridden by sub classes.

Specified by:

isSame in interface OperatorDesc

Overrides:

isSame in class AbstractOperatorDesc

isFullAcidTable

public boolean isFullAcidTable()