Package org.apache.drill.exec.store.mock

Class MockSubScanPOP

java.lang.Object

org.apache.drill.exec.physical.base.AbstractBase

org.apache.drill.exec.store.mock.MockSubScanPOP

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, Leaf, PhysicalOperator, Scan, SubScan

public class MockSubScanPOP
extends AbstractBase
implements SubScan

Describes a physical scan operation for the mock data source. Each operator can, in general, give rise to one or more actual scans. For the mock data source, each sub-scan does exactly one (simulated) scan.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	OPERATOR_TYPE
protected final List<MockTableDef.MockScanEntry>	readEntries

Fields inherited from class org.apache.drill.exec.physical.base.AbstractBase

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation, userName

Constructor Summary

Constructors

Constructor	Description
MockSubScanPOP(String url, Boolean extended, List<MockTableDef.MockScanEntry> readEntries)	This constructor is called from Jackson and is designed to support both older physical plans and the newer ("extended") plans.

Method Summary

Modifier and Type	Method	Description
<T, X, E extends Throwable> T	accept(PhysicalVisitor<T,X,E> physicalVisitor, X value)	Provides capability to build a set of output based on traversing a query graph tree.
PhysicalOperator	getNewWithChildren(List<PhysicalOperator> children)	Regenerate with this node with a new set of children.
String	getOperatorType()
List<MockTableDef.MockScanEntry>	getReadEntries()
String	getUrl()
boolean	isExecutable()	Describes whether or not a particular physical operator can actually be executed.
boolean	isExtended()
Iterator<PhysicalOperator>	iterator()

Methods inherited from class org.apache.drill.exec.physical.base.AbstractBase

accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.drill.common.graph.GraphValue

accept

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Methods inherited from interface org.apache.drill.exec.physical.base.PhysicalOperator

getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, setCost, setMaxAllocation, setOperatorId

Field Details

OPERATOR_TYPE

public static final String OPERATOR_TYPE

See Also:

• Constant Field Values

readEntries

protected final List<MockTableDef.MockScanEntry> readEntries

Constructor Details

MockSubScanPOP

public MockSubScanPOP(String url,
 Boolean extended,
 List<MockTableDef.MockScanEntry> readEntries)

This constructor is called from Jackson and is designed to support both older physical plans and the newer ("extended") plans. Jackson will fill in a null value for the extended field for older plans; we use that null value to know that the plan is old, thus not extended. Newer plans simply provide the value.

Parameters:

url - not used for the mock plan, appears to be a vestige of creating this from a file-based plugin. Must keep it because older physical plans contained a dummy URL value.

extended - see above

readEntries - a description of the columns to generate in a Jackson-serialized form unique to the mock data source plugin.

Method Details

getUrl

public String getUrl()

isExtended

public boolean isExtended()

getReadEntries

public List<MockTableDef.MockScanEntry> getReadEntries()

iterator

public Iterator<PhysicalOperator> iterator()

Specified by:

iterator in interface Iterable<PhysicalOperator>

isExecutable

public boolean isExecutable()

Description copied from interface: PhysicalOperator

Describes whether or not a particular physical operator can actually be executed. Most physical operators can be executed. However, Exchange nodes cannot be executed. In order to be executed, they must be converted into their Exec sub components.

Specified by:

isExecutable in interface PhysicalOperator

Overrides:

isExecutable in class AbstractBase

accept

public <T,
X,
E extends Throwable> T accept(PhysicalVisitor<T,X,E> physicalVisitor,
 X value)
                                   throws E

Description copied from interface: PhysicalOperator

Provides capability to build a set of output based on traversing a query graph tree.

Specified by:

accept in interface PhysicalOperator

Throws:

E extends Throwable

getNewWithChildren

public PhysicalOperator getNewWithChildren(List<PhysicalOperator> children)

Description copied from interface: PhysicalOperator

Regenerate with this node with a new set of children. This is used in the case of materialization or optimization.

Specified by:

getNewWithChildren in interface PhysicalOperator

getOperatorType

public String getOperatorType()

Specified by:

getOperatorType in interface PhysicalOperator