Package | Description |
---|---|
org.apache.hadoop.hive.ql.optimizer | |
org.apache.hadoop.hive.ql.parse |
Modifier and Type | Method and Description |
---|---|
static BaseWork |
ReduceSinkMapJoinProc.getMapJoinParentWork(GenTezProcContext context,
Operator<?> parentRS) |
static Object |
ReduceSinkMapJoinProc.processReduceSinkToHashJoin(ReduceSinkOperator parentRS,
MapJoinOperator mapJoinOp,
GenTezProcContext context) |
Modifier and Type | Method and Description |
---|---|
MapWork |
GenTezUtils.createMapWork(GenTezProcContext context,
Operator<?> root,
TezWork tezWork,
PrunedPartitionList partitions) |
static ReduceWork |
GenTezUtils.createReduceWork(GenTezProcContext context,
Operator<?> root,
TezWork tezWork) |
static UnionWork |
GenTezUtils.createUnionWork(GenTezProcContext context,
Operator<?> root,
Operator<?> leaf,
TezWork tezWork) |
static BaseWork |
GenTezUtils.getEnclosingWork(Operator<?> op,
GenTezProcContext procCtx)
getEncosingWork finds the BaseWork any given operator belongs to.
|
static void |
GenTezUtils.processAppMasterEvent(GenTezProcContext procCtx,
AppMasterEventOperator event)
processAppMasterEvent sets up the event descriptor and the MapWork.
|
static void |
GenTezUtils.processFileSink(GenTezProcContext context,
FileSinkOperator fileSink) |
static void |
GenTezUtils.removeUnionOperators(GenTezProcContext context,
BaseWork work) |
protected void |
GenTezUtils.setupMapWork(MapWork mapWork,
GenTezProcContext context,
PrunedPartitionList partitions,
TableScanOperator root,
String alias) |
Constructor and Description |
---|
GenTezWorkWalker(Dispatcher disp,
GenTezProcContext ctx)
constructor of the walker - the dispatcher is passed.
|
Copyright © 2016 The Apache Software Foundation. All rights reserved.