Modifier and Type | Method and Description |
---|---|
List<GroupByOperator> |
GroupByOptimizer.GroupByOptimizerContext.getListGroupByOperatorsProcessed() |
Modifier and Type | Method and Description |
---|---|
protected int |
CountDistinctRewriteProc.CountDistinctProcessor.checkCountDistinct(GroupByOperator mGby,
ReduceSinkOperator rs,
GroupByOperator rGby) |
protected boolean |
GroupByOptimizer.SortGroupByProcessor.checkGroupByOperatorProcessed(GroupByOptimizer.GroupByOptimizerContext groupBySortOptimizerContext,
GroupByOperator groupByOp) |
protected GroupByOptimizer.GroupByOptimizerSortMatch |
GroupByOptimizer.SortGroupByProcessor.checkSortGroupBy(Stack<Node> stack,
GroupByOperator groupByOp) |
protected void |
GroupByOptimizer.SortGroupByProcessor.convertGroupByMapSideSortedGroupBy(HiveConf conf,
GroupByOperator groupByOp,
int depth) |
protected void |
CountDistinctRewriteProc.CountDistinctProcessor.processGroupBy(GroupByOperator mGby,
ReduceSinkOperator rs,
GroupByOperator rGby,
int indexOfDist) |
protected void |
GroupByOptimizer.SortGroupByProcessor.processGroupBy(GroupByOptimizer.GroupByOptimizerContext ctx,
Stack<Node> stack,
GroupByOperator groupByOp,
int depth) |
Modifier and Type | Method and Description |
---|---|
void |
GroupByOptimizer.GroupByOptimizerContext.setListGroupByOperatorsProcessed(List<GroupByOperator> listGroupByOperatorsProcessed) |
Modifier and Type | Method and Description |
---|---|
protected abstract Object |
ReduceSinkDeDuplication.AbsctractReducerReducerProc.process(ReduceSinkOperator cRS,
GroupByOperator cGBY,
ReduceSinkDeDuplication.ReduceSinkDeduplicateProcCtx dedupCtx) |
protected static void |
CorrelationUtilities.removeReduceSinkForGroupBy(ReduceSinkOperator cRS,
GroupByOperator cGBYr,
ParseContext context,
org.apache.hadoop.hive.ql.optimizer.correlation.AbstractCorrelationProcCtx procCtx) |
Modifier and Type | Method and Description |
---|---|
protected Object |
BucketingSortingOpProcFactory.GroupByInferrer.processGroupBy(Operator<? extends OperatorDesc> parent,
GroupByOperator gop,
BucketingSortingCtx bctx)
Process a GroupByOperator to determine which if any columns the output is bucketed and
sorted by, assumes the columns output by the parent which are bucketed and sorted have
already been determined.
|
protected void |
BucketingSortingOpProcFactory.GroupByInferrer.processGroupByReduceSink(ReduceSinkOperator rop,
GroupByOperator gop,
BucketingSortingCtx bctx)
Process the ReduceSinkOperator preceding a GroupByOperator to determine which columns
are bucketed and sorted.
|
Modifier and Type | Method and Description |
---|---|
Map<ExprNodeDesc,GroupByOperator> |
ParseContext.getColExprToGBMap() |
Modifier and Type | Method and Description |
---|---|
void |
ParseContext.setColExprToGBMap(Map<ExprNodeDesc,GroupByOperator> colExprToGBMap) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.