Modifier and Type | Method and Description |
---|---|
UnionOperator |
GenMRProcContext.getCurrUnionOp() |
Modifier and Type | Method and Description |
---|---|
GenMRProcContext.GenMRUnionCtx |
GenMRProcContext.getUnionTask(UnionOperator op) |
static void |
GenMapRedUtils.initUnionPlan(GenMRProcContext opProcCtx,
UnionOperator currUnionOp,
Task<? extends Serializable> currTask,
boolean local) |
static void |
GenMapRedUtils.initUnionPlan(ReduceSinkOperator op,
UnionOperator currUnionOp,
GenMRProcContext opProcCtx,
Task<? extends Serializable> unionTask)
Initialize the current union plan.
|
static void |
GenMapRedUtils.joinUnionPlan(GenMRProcContext opProcCtx,
UnionOperator currUnionOp,
Task<? extends Serializable> currentUnionTask,
Task<? extends Serializable> existingTask,
boolean local) |
void |
GenMRProcContext.setCurrUnionOp(UnionOperator currUnionOp) |
void |
GenMRProcContext.setUnionTask(UnionOperator op,
GenMRProcContext.GenMRUnionCtx uTask) |
Modifier and Type | Method and Description |
---|---|
static int |
UnionProcFactory.getPositionParent(UnionOperator union,
Stack<Node> stack) |
UnionProcContext.UnionParseContext |
UnionProcContext.getUnionParseContext(UnionOperator u) |
void |
UnionProcContext.setUnionParseContext(UnionOperator u,
UnionProcContext.UnionParseContext uCtx) |
Modifier and Type | Field and Description |
---|---|
List<UnionOperator> |
GenTezProcContext.currentUnionOperators |
Modifier and Type | Field and Description |
---|---|
List<UnionOperator> |
GenSparkProcContext.currentUnionOperators |
Modifier and Type | Method and Description |
---|---|
Set<UnionOperator> |
UnionWork.getUnionOperators() |
Modifier and Type | Method and Description |
---|---|
void |
UnionWork.addUnionOperators(Collection<UnionOperator> unions) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.