|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.exec.Operator<GroupByDesc> org.apache.hadoop.hive.ql.exec.GroupByOperator
public class GroupByOperator
GroupBy operator implementation.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class org.apache.hadoop.hive.ql.exec.Operator |
---|
Operator.OperatorFunc, Operator.State |
Field Summary | |
---|---|
static MemoryMXBean |
memoryMXBean
|
Fields inherited from class org.apache.hadoop.hive.ql.exec.Operator |
---|
HIVECOUNTERCREATEDFILES, HIVECOUNTERFATAL |
Constructor Summary | |
---|---|
GroupByOperator()
|
Method Summary | |
---|---|
boolean |
acceptLimitPushdown()
we can push the limit above GBY (running in Reducer), since that will generate single row for each group. |
void |
closeOp(boolean abort)
We need to forward all the aggregations to children. |
void |
endGroup()
|
void |
flush()
Forward all aggregations to children. |
List<String> |
genColLists(HashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx)
|
String |
getName()
Implements the getName function for the Node Interface. |
static String |
getOperatorName()
|
org.apache.hadoop.hive.ql.plan.api.OperatorType |
getType()
Return the type of the specific operator among the types in OperatorType. |
static javolution.util.FastBitSet |
groupingSet2BitSet(int value)
|
void |
processOp(Object row,
int tag)
Process the row. |
void |
startGroup()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static MemoryMXBean memoryMXBean
Constructor Detail |
---|
public GroupByOperator()
Method Detail |
---|
public static javolution.util.FastBitSet groupingSet2BitSet(int value)
public void startGroup() throws HiveException
startGroup
in class Operator<GroupByDesc>
HiveException
public void endGroup() throws HiveException
endGroup
in class Operator<GroupByDesc>
HiveException
public void processOp(Object row, int tag) throws HiveException
Operator
processOp
in class Operator<GroupByDesc>
row
- The object representing the row.tag
- The tag of the row usually means which parent this row comes from.
Rows with the same tag should have exactly the same rowInspector
all the time.
HiveException
public void flush() throws HiveException
flush
in class Operator<GroupByDesc>
HiveException
public void closeOp(boolean abort) throws HiveException
HiveException
public List<String> genColLists(HashMap<Operator<? extends OperatorDesc>,OpParseContext> opParseCtx)
public String getName()
Operator
getName
in interface Node
getName
in class Operator<GroupByDesc>
public static String getOperatorName()
public org.apache.hadoop.hive.ql.plan.api.OperatorType getType()
Operator
getType
in class Operator<GroupByDesc>
public boolean acceptLimitPushdown()
acceptLimitPushdown
in class Operator<GroupByDesc>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |