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