Package 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

  • Constructor Details

  • Method Details

    • 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()