public class POFilter extends PhysicalOperator
PhysicalOperator.OriginalLocation
alias, illustrator, input, inputAttached, inputs, lineageTracer, mBagFactory, mTupleFactory, outputs, parentPlan, pigLogger, reporter, requestedParallelism, res, RESULT_EMPTY, RESULT_EOP, resultType
Constructor and Description |
---|
POFilter(OperatorKey k) |
POFilter(OperatorKey k,
int rp) |
POFilter(OperatorKey k,
int rp,
java.util.List<PhysicalOperator> inputs) |
POFilter(OperatorKey k,
java.util.List<PhysicalOperator> inputs) |
Modifier and Type | Method and Description |
---|---|
PhysicalOperator |
clone()
Make a copy of this operator.
|
Result |
getNextTuple()
Attaches the proccesed input tuple to the expression plan and checks if
comparison operator returns a true.
|
PhysicalPlan |
getPlan() |
Tuple |
illustratorMarkup(java.lang.Object in,
java.lang.Object out,
int eqClassIndex)
input tuple mark up to be illustrate-able
|
java.lang.String |
name() |
void |
setPlan(PhysicalPlan plan) |
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, getPigLogger, getReporter, getRequestedParallelism, getResultType, isAccumStarted, isAccumulative, isBlocking, isInputAttached, processInput, reset, setAccumEnd, setAccumStart, setAccumulative, setIllustrator, setInputs, setParentPlan, setPigLogger, setReporter, setRequestedParallelism, setResultType, staticDataCleanup
compareTo, equals, getOperatorKey, getProjectionMap, hashCode, regenerateProjectionMap, rewire, toString, unsetProjectionMap
public POFilter(OperatorKey k)
public POFilter(OperatorKey k, int rp)
public POFilter(OperatorKey k, java.util.List<PhysicalOperator> inputs)
public POFilter(OperatorKey k, int rp, java.util.List<PhysicalOperator> inputs)
public Result getNextTuple() throws ExecException
getNextTuple
in class PhysicalOperator
ExecException
public java.lang.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 visit(PhyPlanVisitor v) throws VisitorException
Operator
visit
in class PhysicalOperator
v
- Visitor to visit with.VisitorException
- if the visitor has a problem.public void setPlan(PhysicalPlan plan)
public PhysicalPlan getPlan()
public Tuple illustratorMarkup(java.lang.Object in, java.lang.Object out, int eqClassIndex)
Illustrable
in
- input tupleout
- output tuple before wrapped in ExampleTupleeqClassIndex
- index into equivalence classes in illustratorpublic PhysicalOperator clone() throws java.lang.CloneNotSupportedException
PhysicalOperator
clone
in class PhysicalOperator
java.lang.CloneNotSupportedException
Do not use the clone method directly. Operators are cloned when logical plans
are cloned using {@link LogicalPlanCloner}
Copyright © 2007-2012 The Apache Software Foundation