org.apache.drill.exec.store.mock

Class MockStorePOP

java.lang.Object

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

org.apache.drill.exec.physical.base.AbstractSingle

org.apache.drill.exec.physical.base.AbstractStore

org.apache.drill.exec.store.mock.MockStorePOP

All Implemented Interfaces:

Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, FragmentLeaf, FragmentRoot, HasAffinity, PhysicalOperator, Root, Store

public class MockStorePOP
extends AbstractStore

Field Summary

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

child

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

INIT_ALLOCATION, initialAllocation, MAX_ALLOCATION, maxAllocation

Constructor Summary

Constructors

Constructor and Description
MockStorePOP(PhysicalOperator child)

Method Summary

Modifier and Type	Method and Description
void	applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints) Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes.
int	getMaxWidth() The maximum allowable width for the Store operation.
protected PhysicalOperator	getNewWithChild(PhysicalOperator child)
List<EndpointAffinity>	getOperatorAffinity() Get the list of Endpoints with associated affinities that this operator has preference for.
String	getOperatorType()
Store	getSpecificStore(PhysicalOperator child, int minorFragmentId) Provides full materialized Store operators for execution purposes.

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

accept, getDistributionAffinity

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

getChild, getNewWithChildren, iterator

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

accept, getCost, getInitialAllocation, getMaxAllocation, getOperatorId, getSVMode, getUserName, isBufferedOperator, isExecutable, 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.exec.physical.base.Store

getChild

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

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

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

accept

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Constructor Detail

MockStorePOP

public MockStorePOP(PhysicalOperator child)

Method Detail

getMaxWidth

public int getMaxWidth()

Description copied from interface: Store

The maximum allowable width for the Store operation. In some cases, a store operation has a limited number of parallelizations that it can support. For example, a Screen return cannot be parallelized at all. In this case, a maxWidth value of 1 will be returned. In the case that there is no limit for parallelization, this method should return Integer.MAX_VALUE.

Returns:

The maximum allowable width for the Store operation.

getOperatorAffinity

public List<EndpointAffinity> getOperatorAffinity()

Description copied from interface: HasAffinity

Get the list of Endpoints with associated affinities that this operator has preference for.

Returns:

List of EndpointAffinity objects.

applyAssignments

public void applyAssignments(List<CoordinationProtos.DrillbitEndpoint> endpoints)

Description copied from interface: Store

Inform the Store node about the actual decided DrillbitEndpoint assignments desired for storage purposes. This is a precursor to the execution planner running a set of getSpecificStore() method calls for full Store node materialization.

Parameters:

endpoints - The list of endpoints that this Store node are going to be executed on.

getSpecificStore

public Store getSpecificStore(PhysicalOperator child,
                              int minorFragmentId)

Description copied from interface: Store

Provides full materialized Store operators for execution purposes.

Parameters:

child - The child operator that this operator will consume from.

minorFragmentId - The particular minor fragment id associated with this particular fragment materialization.

Returns:

A materialized Store Operator.

getNewWithChild

protected PhysicalOperator getNewWithChild(PhysicalOperator child)

Specified by:

getNewWithChild in class AbstractSingle

getOperatorType

public String getOperatorType()