public class POPartialAgg extends PhysicalOperator implements Spillable, GroupingSpillable
PhysicalOperator.OriginalLocation
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POPartialAgg(OperatorKey k) |
POPartialAgg(OperatorKey k,
boolean isGroupAll) |
Modifier and Type | Method and Description |
---|---|
PhysicalOperator |
clone()
Make a copy of this operator.
|
PhysicalPlan |
getKeyPlan() |
long |
getMemorySize()
Requests that an object return an estimate of its in memory size.
|
Result |
getNextTuple() |
List<PhysicalPlan> |
getValuePlans() |
Tuple |
illustratorMarkup(Object in,
Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
String |
name() |
void |
setKeyPlan(PhysicalPlan keyPlan) |
void |
setValuePlans(List<PhysicalPlan> valuePlans) |
long |
spill()
Instructs an object to spill whatever it can to disk and release
references to any data structures it spills.
|
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, attachInput, 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
public POPartialAgg(OperatorKey k)
public POPartialAgg(OperatorKey k, boolean isGroupAll)
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public Tuple illustratorMarkup(Object in, Object out, int eqClassIndex)
Illustrable
illustratorMarkup
in interface Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorpublic void visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public boolean supportsMultipleInputs()
Operator
supportsMultipleInputs
in class Operator<PhyPlanVisitor>
public boolean supportsMultipleOutputs()
Operator
supportsMultipleOutputs
in class Operator<PhyPlanVisitor>
public String name()
name
in class Operator<PhyPlanVisitor>
public PhysicalPlan getKeyPlan()
public void setKeyPlan(PhysicalPlan keyPlan)
public List<PhysicalPlan> getValuePlans()
public void setValuePlans(List<PhysicalPlan> valuePlans)
public long spill()
Spillable
public long getMemorySize()
Spillable
getMemorySize
in interface Spillable
public PhysicalOperator clone() throws CloneNotSupportedException
PhysicalOperator
Copyright © 2007-2017 The Apache Software Foundation