Package org.apache.drill.exec.physical.base

Class AbstractDbGroupScan

java.lang.Object
org.apache.drill.exec.physical.base.AbstractBase
org.apache.drill.exec.physical.base.AbstractGroupScan
org.apache.drill.exec.physical.base.AbstractDbGroupScan
All Implemented Interfaces:
Iterable<PhysicalOperator>, GraphValue<PhysicalOperator>, DbGroupScan, FragmentLeaf, GroupScan, HasAffinity, Leaf, PhysicalOperator, Scan
public abstract class AbstractDbGroupScan extends AbstractGroupScan implements DbGroupScan

  • Constructor Details

    • AbstractDbGroupScan

      public AbstractDbGroupScan(String userName)

    • AbstractDbGroupScan

      public AbstractDbGroupScan(AbstractDbGroupScan that)

  • Method Details

    • getStoragePlugin

      public abstract AbstractStoragePlugin getStoragePlugin()

    • getStorageConfig

      public abstract StoragePluginConfig getStorageConfig()

    • supportsSecondaryIndex

      public boolean supportsSecondaryIndex()
      Specified by:
      supportsSecondaryIndex in interface DbGroupScan

    • getSecondaryIndexCollection

      public IndexCollection getSecondaryIndexCollection(org.apache.calcite.rel.RelNode scanrel)
      Description copied from interface: DbGroupScan
      Get the index collection associated with this table if any
      Specified by:
      getSecondaryIndexCollection in interface DbGroupScan

    • supportsRestrictedScan

      public boolean supportsRestrictedScan()
      Description copied from interface: DbGroupScan
      Whether this DbGroupScan supports creating a restricted (skip) scan
      Specified by:
      supportsRestrictedScan in interface DbGroupScan
      Returns:
      true if restricted scan is supported, false otherwise

    • isRestrictedScan

      public boolean isRestrictedScan()
      Description copied from interface: DbGroupScan
      Whether this DbGroupScan is itself a restricted scan
      Specified by:
      isRestrictedScan in interface DbGroupScan
      Returns:
      true if this DbGroupScan is itself a restricted scan, false otherwise

    • getRestrictedScan

      public DbGroupScan getRestrictedScan(List<SchemaPath> columns)
      Description copied from interface: DbGroupScan
      If this DbGroupScan supports restricted scan, create a restricted scan from this DbGroupScan.
      Specified by:
      getRestrictedScan in interface DbGroupScan
      Parameters:
      columns - list of column paths
      Returns:
      a non-null DbGroupScan if restricted scan is supported, null otherwise

    • getRowKeyName

      public String getRowKeyName()
      Specified by:
      getRowKeyName in interface DbGroupScan

    • getRowKeyPath

      public SchemaPath getRowKeyPath()
      Specified by:
      getRowKeyPath in interface DbGroupScan

    • getRangePartitionFunction

      public PartitionFunction getRangePartitionFunction(List<FieldReference> refList)
      Description copied from interface: DbGroupScan
      Get a partition function instance for range based partitioning
      Specified by:
      getRangePartitionFunction in interface DbGroupScan
      Parameters:
      refList - a list of FieldReference exprs that are participating in the range partitioning
      Returns:
      instance of a partitioning function

    • getPluginCostModel

      public PluginCost getPluginCostModel()
      Description copied from interface: DbGroupScan
      Get the format plugin cost model. The cost model will provide cost factors such as seq. scan cost, random scan cost, block size
      Specified by:
      getPluginCostModel in interface DbGroupScan
      Returns:
      a PluginCost cost model