org.apache.hadoop.hive.ql.io.rcfile.truncate

Class ColumnTruncateWork

java.lang.Object

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

org.apache.hadoop.hive.ql.plan.BaseWork

org.apache.hadoop.hive.ql.plan.MapWork

org.apache.hadoop.hive.ql.io.rcfile.truncate.ColumnTruncateWork

All Implemented Interfaces:

Serializable, Cloneable, OperatorDesc

public class ColumnTruncateWork
extends MapWork
implements Serializable

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.plan.MapWork

MapWork.LlapIODescriptor, MapWork.MapExplainVectorization

Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.plan.BaseWork

BaseWork.BaseExplainVectorization

Field Summary

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

SAMPLING_ON_PREV_MR, SAMPLING_ON_START

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

inputFormatSupportSet, llapMode, LOG, supportRemovedReasons, supportSetInUse, uberMode, useVectorizedInputFileFormat, vectorizationEnabled, vectorizationExamined, vectorizedRowBatchCtx, vectorizedTestingReducerBatchSize, vectorizedVertexNum

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
ColumnTruncateWork()
ColumnTruncateWork(List<Integer> droppedColumns, org.apache.hadoop.fs.Path inputDir, org.apache.hadoop.fs.Path outputDir)
ColumnTruncateWork(List<Integer> droppedColumns, org.apache.hadoop.fs.Path inputDir, org.apache.hadoop.fs.Path outputDir, boolean hasDynamicPartitions, DynamicPartitionCtx dynPartCtx)

Method Summary

Modifier and Type	Method and Description
List<Integer>	getDroppedColumns()
DynamicPartitionCtx	getDynPartCtx()
org.apache.hadoop.fs.Path	getInputDir()
String	getInputformat()
ListBucketingCtx	getListBucketingCtx()
Class<? extends org.apache.hadoop.mapred.Mapper>	getMapperClass()
Long	getMinSplitSize()
org.apache.hadoop.fs.Path	getOutputDir()
boolean	hasDynamicPartitions()
boolean	isGatheringStats()
boolean	isListBucketingAlterTableConcatenate()
void	setDroppedColumns(List<Integer> droppedColumns)
void	setDynPartCtx(DynamicPartitionCtx dynPartCtx)
void	setHasDynamicPartitions(boolean hasDynamicPartitions)
void	setInputPaths(org.apache.hadoop.fs.Path inputDir)
void	setListBucketingCtx(ListBucketingCtx listBucketingCtx)
void	setOutputDir(org.apache.hadoop.fs.Path outputDir)

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

addMapWork, addPathToAlias, addPathToAlias, addPathToPartitionInfo, configureJobConf, deriveExplainAttributes, deriveLlap, getAliases, getAliasToPartnInfo, getAliasToWork, getAllRootOperators, getAnyRootOperator, getBaseSrc, getBucketedColsByDirectory, getCacheAffinity, getDoSplitsGrouping, getDummyTableScan, getEventSourceColumnNameMap, getEventSourceColumnTypeMap, getEventSourcePartKeyExprMap, getEventSourceTableDescMap, getExecutionMode, getIncludedBuckets, getInputFormatSupportSet, getLlapIoDescString, getMapAliases, getMapExplainVectorization, getMaxSplitSize, getMinSplitSizePerNode, getMinSplitSizePerRack, getNameToSplitSample, getNotEnabledInputFileFormatReason, getNumMapTasks, getPartitionDescs, getPaths, getPathToAliases, getPathToPartitionInfo, getSamplingType, getSamplingTypeString, getSortedColsByDirectory, getSupportRemovedReasons, getSupportSetInUse, getTmpHDFSPath, getTmpPathForPartitionPruning, getTruncatedPathToAliases, getUseVectorizedInputFileFormat, getVectorizationEnabledConditionsMet, getVectorizationEnabledConditionsNotMet, getVectorizationInputFileFormatClassNameSet, getVectorizedRowBatch, getVectorPartitionDescList, getWorks, initialize, internTable, isInputFormatSorted, isLeftInputJoin, isMapperCannotSpanPartns, isMergeFromResolver, isUseBucketizedHiveInputFormat, mergeAliasedInput, mergingInto, removePathToAlias, removePathToPartitionInfo, replaceRoots, resolveDynamicPartitionStoredAsSubDirsMerge, setAliasToPartnInfo, setAliasToWork, setBaseSrc, setDoSplitsGrouping, setDummyTableScan, setEventSourceColumnNameMap, setEventSourcePartKeyExprMap, setEventSourceTableDescMap, setIncludedBuckets, setInputformat, setInputFormatSorted, setInputFormatSupportSet, setIsMergeFromResolver, setLeftInputJoin, setMapAliases, setMapperCannotSpanPartns, setMaxSplitSize, setMinSplitSize, setMinSplitSizePerNode, setMinSplitSizePerRack, setNameToSplitSample, setNotEnabledInputFileFormatReason, setNumMapTasks, setPathToAliases, setPathToPartitionInfo, setSamplingType, setSupportRemovedReasons, setSupportSetInUse, setTmpHDFSPath, setTmpPathForPartitionPruning, setUseBucketizedHiveInputFormat, setUseVectorizedInputFileFormat, setVectorizationEnabledConditionsMet, setVectorizationEnabledConditionsNotMet, setVectorizationInputFileFormatClassNameSet, setVectorizedRowBatch, setVectorPartitionDescList

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

addDummyOp, addSortCols, getAllLeafOperators, getAllNative, getAllOperators, getDummyOps, getInputSourceToRuntimeValuesInfo, getIsTestForcedVectorizationEnable, getIsTestVectorizationSuppressExplainExecutionMode, getLlapMode, getMapRedLocalWork, getName, getNotVectorizedReason, getReservedMemoryMB, getSortCols, getTag, getUberMode, getUsesVectorUDFAdaptor, getVectorizationEnabled, getVectorizationExamined, getVectorizedRowBatchCtx, getVectorizedTestingReducerBatchSize, getVectorizedVertexNum, setAllNative, setDummyOps, setGatheringStats, setInputSourceToRuntimeValuesInfo, setIsTestForcedVectorizationEnable, setIsTestVectorizationSuppressExplainExecutionMode, setLlapMode, setMapRedLocalWork, setName, setNotVectorizedReason, setReservedMemoryMB, setTag, setUberMode, setUsesVectorUDFAdaptor, setVectorizationEnabled, setVectorizationExamined, setVectorizedRowBatchCtx, setVectorizedTestingReducerBatchSize, setVectorizedVertexNum

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

clone, fillSignature, getColumnExprMap, getColumnExprMapForExplain, getMaxMemoryAvailable, getMemoryNeeded, getOpProps, getRuntimeStatsTmpDir, getStatistics, getTraits, getUserLevelStatistics, getVectorDesc, getVectorMode, isSame, 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

ColumnTruncateWork

public ColumnTruncateWork()

ColumnTruncateWork

public ColumnTruncateWork(List<Integer> droppedColumns,
                          org.apache.hadoop.fs.Path inputDir,
                          org.apache.hadoop.fs.Path outputDir)

ColumnTruncateWork

public ColumnTruncateWork(List<Integer> droppedColumns,
                          org.apache.hadoop.fs.Path inputDir,
                          org.apache.hadoop.fs.Path outputDir,
                          boolean hasDynamicPartitions,
                          DynamicPartitionCtx dynPartCtx)

Method Detail

getInputDir

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

setInputPaths

public void setInputPaths(org.apache.hadoop.fs.Path inputDir)

getOutputDir

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

setOutputDir

public void setOutputDir(org.apache.hadoop.fs.Path outputDir)

getMapperClass

public Class<? extends org.apache.hadoop.mapred.Mapper> getMapperClass()

getMinSplitSize

public Long getMinSplitSize()

Overrides:

getMinSplitSize in class MapWork

getInputformat

public String getInputformat()

Overrides:

getInputformat in class MapWork

isGatheringStats

public boolean isGatheringStats()

Overrides:

isGatheringStats in class BaseWork

hasDynamicPartitions

public boolean hasDynamicPartitions()

setHasDynamicPartitions

public void setHasDynamicPartitions(boolean hasDynamicPartitions)

getDynPartCtx

public DynamicPartitionCtx getDynPartCtx()

setDynPartCtx

public void setDynPartCtx(DynamicPartitionCtx dynPartCtx)

getListBucketingCtx

public ListBucketingCtx getListBucketingCtx()

Returns:

the listBucketingCtx

setListBucketingCtx

public void setListBucketingCtx(ListBucketingCtx listBucketingCtx)

Parameters:

listBucketingCtx - the listBucketingCtx to set

isListBucketingAlterTableConcatenate

public boolean isListBucketingAlterTableConcatenate()

Returns:

the isListBucketingAlterTableConcatenate

getDroppedColumns

public List<Integer> getDroppedColumns()

setDroppedColumns

public void setDroppedColumns(List<Integer> droppedColumns)