public class PhysicalPlan extends OperatorPlan<PhysicalOperator> implements Cloneable
OperatorPlan.IndexHelper<E>
Modifier and Type | Field and Description |
---|---|
boolean |
endOfAllInput |
log, mFromEdges, mKeys, mOps, mSoftFromEdges, mSoftToEdges, mToEdges
Constructor and Description |
---|
PhysicalPlan() |
Modifier and Type | Method and Description |
---|---|
void |
attachInput(Tuple t) |
PhysicalPlan |
clone() |
void |
connect(PhysicalOperator from,
PhysicalOperator to)
Create an edge between two nodes.
|
void |
detachInput() |
void |
explain(OutputStream out)
Write a visual representation of the Physical Plan
into the given output stream
|
void |
explain(OutputStream out,
boolean verbose)
Write a visual representation of the Physical Plan
into the given output stream
|
void |
explain(PrintStream ps,
String format,
boolean verbose)
Write a visual representation of the Physical Plan
into the given printstream
|
boolean |
isEmpty() |
void |
remove(PhysicalOperator op)
Remove an operator from the plan.
|
void |
replace(PhysicalOperator oldNode,
PhysicalOperator newNode)
Replace an existing node in the graph with a new node.
|
void |
resetOpMap() |
void |
setOpMap(MultiMap<PhysicalOperator,PhysicalOperator> opmap) |
String |
toString() |
add, addAsLeaf, addAsRoot, createSoftLink, disconnect, doInsertBetween, dump, getKeys, getLeaves, getOperator, getOperatorKey, getPredecessors, getRoots, getSoftLinkPredecessors, getSoftLinkSuccessors, getSuccessors, insertBetween, isSingleLeafPlan, iterator, merge, mergeSharedPlan, pathExists, pushAfter, pushBefore, removeAndReconnect, removeAndReconnectMultiSucc, removeSoftLink, size, swap, trimAbove, trimBelow
equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
forEach, spliterator
public void attachInput(Tuple t)
public void detachInput()
public void explain(OutputStream out)
out
- : OutputStream to which the visual representation is writtenpublic void explain(OutputStream out, boolean verbose)
out
- : OutputStream to which the visual representation is writtenverbose
- : Amount of information to printpublic void explain(PrintStream ps, String format, boolean verbose)
ps
- : PrintStream to which the visual representation is writtenformat
- : Format to print inverbose
- : Amount of information to printpublic void connect(PhysicalOperator from, PhysicalOperator to) throws PlanException
OperatorPlan
connect
in class OperatorPlan<PhysicalOperator>
from
- Operator data will flow from.to
- Operator data will flow to.PlanException
- if this edge will create multiple inputs for an
operator that does not support multiple inputs or create multiple outputs
for an operator that does not support multiple outputs.public void remove(PhysicalOperator op)
OperatorPlan
remove
in class OperatorPlan<PhysicalOperator>
op
- Operator to remove.public void replace(PhysicalOperator oldNode, PhysicalOperator newNode) throws PlanException
OperatorPlan
replace
in class OperatorPlan<PhysicalOperator>
oldNode
- Node to be replacednewNode
- Node to add in place of oldNodePlanException
public boolean isEmpty()
public PhysicalPlan clone() throws CloneNotSupportedException
clone
in class Object
CloneNotSupportedException
public void setOpMap(MultiMap<PhysicalOperator,PhysicalOperator> opmap)
public void resetOpMap()
Copyright © 2007-2017 The Apache Software Foundation