public class SparkPartitionPruningSinkDesc extends AbstractOperatorDesc
Modifier and Type | Class and Description |
---|---|
static class |
SparkPartitionPruningSinkDesc.DPPTargetInfo |
colExprMap, memAvailable, memNeeded, opProps, opTraits, runtimeStatsTmpDir, statistics, vectorDesc, vectorMode
Constructor and Description |
---|
SparkPartitionPruningSinkDesc() |
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) |
clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, setColumnExprMap, setMaxMemoryAvailable, setMemoryNeeded, setOpProps, setRuntimeStatsTmpDir, setStatistics, setTraits, setVectorDesc, setVectorMode
public List<SparkPartitionPruningSinkDesc.DPPTargetInfo> getTargetInfos()
public void addTarget(String colName, String colType, ExprNodeDesc partKey, MapWork mapWork, TableScanOperator tableScan)
public org.apache.hadoop.fs.Path getTmpPathOfTargetWork()
public org.apache.hadoop.fs.Path getPath()
public void setPath(org.apache.hadoop.fs.Path path)
public String getTargetWorks()
public String getTableScanNames()
public TableDesc getTable()
public void setTable(TableDesc table)
public String displayTargetColumns()
public boolean isSame(OperatorDesc other)
AbstractOperatorDesc
Object.equals(Object)
. Intended to be
overridden by sub classes.isSame
in interface OperatorDesc
isSame
in class AbstractOperatorDesc
public void removeTarget(String name)
Copyright © 2022 The Apache Software Foundation. All rights reserved.