public class POCollectedGroup extends PhysicalOperator
PhysicalOperator.OriginalLocation
Modifier and Type | Field and Description |
---|---|
protected byte |
keyType |
protected List<ExpressionOperator> |
leafOps |
protected static TupleFactory |
mTupleFactory |
protected List<PhysicalPlan> |
plans |
protected static long |
serialVersionUID |
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POCollectedGroup(OperatorKey k) |
POCollectedGroup(OperatorKey k,
int rp) |
POCollectedGroup(OperatorKey k,
int rp,
List<PhysicalOperator> inp) |
POCollectedGroup(OperatorKey k,
List<PhysicalOperator> inp) |
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Tuple t)
Overridden since the attachment of the new input should cause the old
processing to end.
|
protected Tuple |
constructOutput(List<Result> resLst,
Tuple value) |
byte |
getKeyType() |
Result |
getNextTuple() |
List<PhysicalPlan> |
getPlans() |
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
boolean |
isEndOfInput() |
String |
name() |
void |
setEndOfInput(boolean isEndOfInput) |
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.
|
addOriginalLocation, addOriginalLocation, clone, cloneHelper, clonePlans, copyAliasFrom, detachInput, getAlias, getAliasString, getIllustrator, getInputs, getLogger, getNext, getNextBigDecimal, getNextBigInteger, getNextBoolean, getNextDataBag, getNextDataByteArray, getNextDateTime, getNextDouble, getNextFloat, getNextInteger, getNextLong, getNextMap, getNextString, getOriginalLocations, getParentPlan, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isEndOfAllInput, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
protected static final long serialVersionUID
protected static final TupleFactory mTupleFactory
protected List<PhysicalPlan> plans
protected List<ExpressionOperator> leafOps
protected byte keyType
public POCollectedGroup(OperatorKey k)
public POCollectedGroup(OperatorKey k, int rp)
public POCollectedGroup(OperatorKey k, List<PhysicalOperator> inp)
public POCollectedGroup(OperatorKey k, int rp, List<PhysicalOperator> inp)
public boolean isEndOfInput()
public void setEndOfInput(boolean isEndOfInput)
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 getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
protected Tuple constructOutput(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) throws PlanException
PlanException
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorCopyright © 2007-2017 The Apache Software Foundation