|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.pig.impl.plan.Operator<PhyPlanVisitor>
org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator
org.apache.pig.backend.hadoop.executionengine.physicalLayer.relationalOperators.POPreCombinerLocalRearrange
public class POPreCombinerLocalRearrange
A specialized local rearrange operator which behaves like the regular local rearrange in the getNext() as far as getting its input and constructing the "key" out of the input. It then returns a tuple with two fields - the key in the first position and the "value" inside a bag in the second position. This output format resembles the format out of a Package. This output will feed to a foreach which expects this format.
Field Summary | |
---|---|
protected byte |
keyType
|
protected List<ExpressionOperator> |
leafOps
|
protected static BagFactory |
mBagFactory
|
protected static TupleFactory |
mTupleFactory
|
protected List<PhysicalPlan> |
plans
|
protected static long |
serialVersionUID
|
Fields inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
alias, dummyBag, dummyBool, dummyDBA, dummyDouble, dummyFloat, dummyInt, dummyLong, dummyMap, dummyString, dummyTuple, illustrator, input, inputAttached, inputs, lineageTracer, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, resultType |
Fields inherited from class org.apache.pig.impl.plan.Operator |
---|
mKey |
Constructor Summary | |
---|---|
POPreCombinerLocalRearrange(OperatorKey k)
|
|
POPreCombinerLocalRearrange(OperatorKey k,
int rp)
|
|
POPreCombinerLocalRearrange(OperatorKey k,
int rp,
List<PhysicalOperator> inp)
|
|
POPreCombinerLocalRearrange(OperatorKey k,
List<PhysicalOperator> inp)
|
Method Summary | |
---|---|
void |
attachInput(Tuple t)
Overridden since the attachment of the new input should cause the old processing to end. |
protected Tuple |
constructLROutput(List<Result> resLst,
Tuple value)
|
byte |
getKeyType()
|
Result |
getNext(Tuple t)
Calls getNext on the generate operator inside the nested physical plan. |
List<PhysicalPlan> |
getPlans()
|
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able |
String |
name()
|
void |
setKeyType(byte keyType)
|
void |
setPlans(List<PhysicalPlan> plans)
|
boolean |
supportsMultipleInputs()
Indicates whether this operator supports multiple inputs. |
boolean |
supportsMultipleOutputs()
Indicates whether this operator supports multiple outputs. |
void |
visit(PhyPlanVisitor v)
Visit this node with the provided visitor. |
Methods inherited from class org.apache.pig.backend.hadoop.executionengine.physicalLayer.PhysicalOperator |
---|
clone, cloneHelper, detachInput, getAlias, getAliasString, getDummy, getIllustrator, getInputs, getLogger, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getNext, getPigLogger, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setAlias, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType |
Methods inherited from class org.apache.pig.impl.plan.Operator |
---|
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap |
Methods inherited from class java.lang.Object |
---|
finalize, getClass, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
protected static final long serialVersionUID
protected static final TupleFactory mTupleFactory
protected static BagFactory mBagFactory
protected List<PhysicalPlan> plans
protected List<ExpressionOperator> leafOps
protected byte keyType
Constructor Detail |
---|
public POPreCombinerLocalRearrange(OperatorKey k)
public POPreCombinerLocalRearrange(OperatorKey k, int rp)
public POPreCombinerLocalRearrange(OperatorKey k, List<PhysicalOperator> inp)
public POPreCombinerLocalRearrange(OperatorKey k, int rp, List<PhysicalOperator> inp)
Method Detail |
---|
public void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.
VisitorException
- if the visitor has a problem.public String name()
name
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public void attachInput(Tuple t)
attachInput
in class PhysicalOperator
t
- -
The tuple that should be used as inputpublic Result getNext(Tuple t) throws ExecException
getNext
in class PhysicalOperator
ExecException
protected Tuple constructLROutput(List<Result> resLst, Tuple value) throws ExecException
ExecException
public byte getKeyType()
public void setKeyType(byte keyType)
public List<PhysicalPlan> getPlans()
public void setPlans(List<PhysicalPlan> plans)
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustrator
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |