Package org.apache.drill.exec.planner.fragment

Class Fragment

java.lang.Object

org.apache.drill.exec.planner.fragment.Fragment

All Implemented Interfaces:

Iterable<Fragment.ExchangeFragmentPair>

public class Fragment
extends Object
implements Iterable<Fragment.ExchangeFragmentPair>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static class	Fragment.BufferedOpFinder
class	Fragment.ExchangeFragmentPair

Constructor Summary

Constructors

Constructor	Description
Fragment()

Method Summary

Modifier and Type	Method	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()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Constructor Details

Fragment

public Fragment()

Method Details

addOperator

public void addOperator(PhysicalOperator o)

Set the given operator as root operator of this fragment. If root operator is already set, then this method call is a no-op.

Parameters:

o - new root operator

addSendExchange

public void addSendExchange(Exchange e,
 Fragment sendingToFragment)
                     throws ForemanSetupException

Throws:

ForemanSetupException

addReceiveExchange

public void addReceiveExchange(Exchange e,
 Fragment fragment)

iterator

public Iterator<Fragment.ExchangeFragmentPair> iterator()

Specified by:

iterator in interface Iterable<Fragment.ExchangeFragmentPair>

getReceivingExchangePairs

public List<Fragment.ExchangeFragmentPair> getReceivingExchangePairs()

getRoot

public PhysicalOperator getRoot()

getSendingExchange

public Exchange getSendingExchange()

getSendingExchangePair

public Fragment.ExchangeFragmentPair getSendingExchangePair()

hashCode

public int hashCode()

Overrides:

hashCode in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getBufferedOperators

public List<PhysicalOperator> getBufferedOperators(QueryContext queryContext)

toString

public String toString()

Overrides:

toString in class Object