public class PartialScanWork extends MapWork implements java.io.Serializable
SAMPLING_ON_PREV_MR, SAMPLING_ON_START
Constructor and Description |
---|
PartialScanWork() |
PartialScanWork(java.util.List<java.lang.String> inputPaths) |
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getAggKey() |
java.lang.String |
getInputformat() |
java.util.List<java.lang.String> |
getInputPaths() |
java.lang.Class<? extends Mapper> |
getMapperClass() |
java.lang.Long |
getMinSplitSize() |
boolean |
isGatheringStats() |
void |
setAggKey(java.lang.String aggKey) |
void |
setInputPaths(java.util.List<java.lang.String> inputPaths) |
addIndexIntermediateFile, addMapWork, configureJobConf, deriveExplainAttributes, getAliases, getAliasToPartnInfo, getAliasToWork, getAllRootOperators, getBucketedColsByDirectory, getHadoopSupportsSplittable, getIndexIntermediateFile, getJoinTree, getMapLocalWork, getMaxSplitSize, getMinSplitSizePerNode, getMinSplitSizePerRack, getNameToSplitSample, getNumMapTasks, getOpParseCtxMap, getPartitionDescs, getPaths, getPathToAliases, getPathToPartitionInfo, getSamplingType, getSamplingTypeString, getSortedColsByDirectory, getTmpHDFSFileURI, getTruncatedPathToAliases, getWorks, initialize, isInputFormatSorted, isMapperCannotSpanPartns, isUseBucketizedHiveInputFormat, mergeAliasedInput, mergingInto, resolveDynamicPartitionStoredAsSubDirsMerge, setAliasToPartnInfo, setAliasToWork, setHadoopSupportsSplittable, setInputformat, setInputFormatSorted, setJoinTree, setMapLocalWork, setMapperCannotSpanPartns, setMaxSplitSize, setMinSplitSize, setMinSplitSizePerNode, setMinSplitSizePerRack, setNameToSplitSample, setNumMapTasks, setOpParseCtxMap, setPathToAliases, setPathToPartitionInfo, setSamplingType, setTmpHDFSFileURI, setUseBucketizedHiveInputFormat
getAllOperators, setGatheringStats
clone
public PartialScanWork()
public PartialScanWork(java.util.List<java.lang.String> inputPaths)
public java.util.List<java.lang.String> getInputPaths()
public void setInputPaths(java.util.List<java.lang.String> inputPaths)
public java.lang.Class<? extends Mapper> getMapperClass()
public java.lang.Long getMinSplitSize()
getMinSplitSize
in class MapWork
public java.lang.String getInputformat()
getInputformat
in class MapWork
public boolean isGatheringStats()
isGatheringStats
in class BaseWork
public java.lang.String getAggKey()
public void setAggKey(java.lang.String aggKey)
aggKey
- the aggKey to setCopyright © 2012 The Apache Software Foundation