public static class MapJoinResolver.LocalMapJoinProcCtx extends Object implements NodeProcessorCtx
Constructor and Description |
---|
LocalMapJoinProcCtx(Task<? extends Serializable> task,
ParseContext parseCtx) |
Modifier and Type | Method and Description |
---|---|
void |
addDirectWorks(MapJoinOperator mapJoinOp,
List<Operator<? extends OperatorDesc>> directOperators) |
void |
addDummyParentOp(Operator<? extends OperatorDesc> op) |
Task<? extends Serializable> |
getCurrentTask() |
Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> |
getDirectWorks() |
List<Operator<? extends OperatorDesc>> |
getDummyParentOp() |
ParseContext |
getParseCtx() |
boolean |
isFollowedByGroupBy() |
void |
setCurrentTask(Task<? extends Serializable> currentTask) |
void |
setDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks) |
void |
setDummyParentOp(List<Operator<? extends OperatorDesc>> op) |
void |
setFollowedByGroupBy(boolean isFollowedByGroupBy) |
void |
setParseCtx(ParseContext parseCtx) |
public LocalMapJoinProcCtx(Task<? extends Serializable> task, ParseContext parseCtx)
public Task<? extends Serializable> getCurrentTask()
public void setCurrentTask(Task<? extends Serializable> currentTask)
public boolean isFollowedByGroupBy()
public void setFollowedByGroupBy(boolean isFollowedByGroupBy)
public ParseContext getParseCtx()
public void setParseCtx(ParseContext parseCtx)
public void setDummyParentOp(List<Operator<? extends OperatorDesc>> op)
public List<Operator<? extends OperatorDesc>> getDummyParentOp()
public void addDummyParentOp(Operator<? extends OperatorDesc> op)
public void setDirectWorks(Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> directWorks)
public Map<MapJoinOperator,List<Operator<? extends OperatorDesc>>> getDirectWorks()
public void addDirectWorks(MapJoinOperator mapJoinOp, List<Operator<? extends OperatorDesc>> directOperators)
Copyright © 2017 The Apache Software Foundation. All rights reserved.