public class Fragment extends Object implements Iterable<Fragment.ExchangeFragmentPair>
Modifier and Type | Class and Description |
---|---|
protected static class |
Fragment.BufferedOpFinder |
class |
Fragment.ExchangeFragmentPair |
Constructor and Description |
---|
Fragment() |
Modifier and Type | Method and Description |
---|---|
void |
addOperator(PhysicalOperator o)
Set the given operator as root operator of this fragment.
|
void |
addReceiveExchange(Exchange e,
Fragment fragment) |
void |
addSendExchange(Exchange e,
Fragment sendingToFragment) |
boolean |
equals(Object obj) |
List<PhysicalOperator> |
getBufferedOperators(QueryContext queryContext) |
List<Fragment.ExchangeFragmentPair> |
getReceivingExchangePairs() |
PhysicalOperator |
getRoot() |
Exchange |
getSendingExchange() |
Fragment.ExchangeFragmentPair |
getSendingExchangePair() |
int |
hashCode() |
Iterator<Fragment.ExchangeFragmentPair> |
iterator() |
String |
toString() |
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
forEach, spliterator
public void addOperator(PhysicalOperator o)
o
- new root operatorpublic void addSendExchange(Exchange e, Fragment sendingToFragment) throws ForemanSetupException
ForemanSetupException
public Iterator<Fragment.ExchangeFragmentPair> iterator()
iterator
in interface Iterable<Fragment.ExchangeFragmentPair>
public List<Fragment.ExchangeFragmentPair> getReceivingExchangePairs()
public PhysicalOperator getRoot()
public Exchange getSendingExchange()
public Fragment.ExchangeFragmentPair getSendingExchangePair()
public List<PhysicalOperator> getBufferedOperators(QueryContext queryContext)
Copyright © 2021 The Apache Software Foundation. All rights reserved.