org.apache.hadoop.hive.ql.optimizer.spark

Class SparkPartitionPruningSinkDesc

java.lang.Object

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

org.apache.hadoop.hive.ql.optimizer.spark.SparkPartitionPruningSinkDesc

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class SparkPartitionPruningSinkDesc
extends AbstractOperatorDesc

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SparkPartitionPruningSinkDesc.DPPTargetInfo

Field Summary

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
SparkPartitionPruningSinkDesc()

Method Summary

Modifier and Type	Method and Description
void	addTarget(String colName, String colType, ExprNodeDesc partKey, MapWork mapWork, TableScanOperator tableScan)
String	displayTargetColumns()
org.apache.hadoop.fs.Path	getPath()
TableDesc	getTable()
String	getTableScanNames()
List<SparkPartitionPruningSinkDesc.DPPTargetInfo>	getTargetInfos()
String	getTargetWorks()
org.apache.hadoop.fs.Path	getTmpPathOfTargetWork()
boolean	isSame(OperatorDesc other) The default implementation delegates to Object.equals(Object).
void	removeTarget(String name)
void	setPath(org.apache.hadoop.fs.Path path)
void	setTable(TableDesc table)

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

clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, 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

Constructor Detail

SparkPartitionPruningSinkDesc

public SparkPartitionPruningSinkDesc()

Method Detail

getTargetInfos

public List<SparkPartitionPruningSinkDesc.DPPTargetInfo> getTargetInfos()

addTarget

public void addTarget(String colName,
                      String colType,
                      ExprNodeDesc partKey,
                      MapWork mapWork,
                      TableScanOperator tableScan)

getTmpPathOfTargetWork

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

getPath

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

setPath

public void setPath(org.apache.hadoop.fs.Path path)

getTargetWorks

public String getTargetWorks()

getTableScanNames

public String getTableScanNames()

getTable

public TableDesc getTable()

setTable

public void setTable(TableDesc table)

displayTargetColumns

public String displayTargetColumns()

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

removeTarget

public void removeTarget(String name)