public class ReduceWork extends BaseWork
Constructor and Description |
---|
ReduceWork() |
Modifier and Type | Method and Description |
---|---|
void |
configureJobConf(JobConf job) |
protected java.util.List<Operator<?>> |
getAllRootOperators() |
TableDesc |
getKeyDesc() |
boolean |
getNeedsTagging() |
java.lang.Integer |
getNumReduceTasks()
If the number of reducers is -1, the runtime will automatically figure it
out by input data size.
|
Operator<?> |
getReducer() |
java.util.List<TableDesc> |
getTagToValueDesc() |
void |
setKeyDesc(TableDesc keyDesc)
If the plan has a reducer and correspondingly a reduce-sink, then store the TableDesc pointing
to keySerializeInfo of the ReduceSink
|
void |
setNeedsTagging(boolean needsTagging) |
void |
setNumReduceTasks(java.lang.Integer numReduceTasks) |
void |
setReducer(Operator<?> reducer) |
void |
setTagToValueDesc(java.util.List<TableDesc> tagToValueDesc) |
getAllOperators, isGatheringStats, setGatheringStats
clone
public void setKeyDesc(TableDesc keyDesc)
keyDesc
- public TableDesc getKeyDesc()
public java.util.List<TableDesc> getTagToValueDesc()
public void setTagToValueDesc(java.util.List<TableDesc> tagToValueDesc)
public Operator<?> getReducer()
public void setReducer(Operator<?> reducer)
public boolean getNeedsTagging()
public void setNeedsTagging(boolean needsTagging)
protected java.util.List<Operator<?>> getAllRootOperators()
getAllRootOperators
in class BaseWork
public java.lang.Integer getNumReduceTasks()
public void setNumReduceTasks(java.lang.Integer numReduceTasks)
public void configureJobConf(JobConf job)
Copyright © 2012 The Apache Software Foundation