Package org.apache.drill.exec.store

Interface SchemaPartitionExplorer

All Known Implementing Classes:
AbstractSchema, CapitalizingJdbcSchema, CassandraDrillSchema, CassandraRootDrillSchema, ClickhouseCatalogSchema, DrillPluginSchema, DruidSchemaFactory.DruidDataSources, DynamicRootSchema.RootSchema, ElasticsearchDrillSchema, FileSystemSchemaFactory.FileSystemSchema, GoogleSheetsDrillSchema, GoogleSheetsRootSchema, HiveDatabaseSchema, HttpAPIConnectionSchema, HttpSchemaFactory.HttpSchema, KafkaMessageSchema, MongoDatabaseSchema, SplunkSchema, SubSchemaWrapper, WorkspaceSchemaFactory.WorkspaceSchema
public interface SchemaPartitionExplorer
Exposes partition information for a particular schema.

For a more explanation of the current use of this interface see the documentation in PartitionExplorer.

  • Method Summary

    Modifier and Type
    Method
    Description
    Iterable<String>
    getSubPartitions(String table, List<String> partitionColumns, List<String> partitionValues)
    Get a list of sub-partitions of a particular table and the partitions specified by partition columns and values.

  • Method Details

    • getSubPartitions

      Iterable<String> getSubPartitions(String table, List<String> partitionColumns, List<String> partitionValues) throws PartitionNotFoundException
      Get a list of sub-partitions of a particular table and the partitions specified by partition columns and values. Individual storage plugins will assign specific meaning to the parameters and return values.

      For more info see docs in PartitionExplorer.

      Parameters:
      partitionColumns - a list of partitions to match
      partitionValues - list of values of each partition (corresponding to the partition column list)
      Returns:
      list of sub-partitions, will be empty if a there is no further level of sub-partitioning below, i.e. hit a leaf partition
      Throws:
      PartitionNotFoundException - when the partition does not exist in the given workspace