Interface TableProvider

    • Method Detail

      • getSchema

        String getSchema()
        The schema name (aka database) that this table provider's table belongs to.
        Returns:
        String containing the schema name.
      • getTableName

        TableName getTableName()
        The fully qualified name of the table represented by this TableProvider.
        Returns:
        The TableName containing the fully qualified name of the Table.
      • getPartitions

        default void getPartitions​(BlockWriter blockWriter,
                                   GetTableLayoutRequest request)
                            throws Exception
        Default implementation returns a single partition since many of the TableProviders may not support parallel scans.
        Throws:
        Exception
      • enhancePartitionSchema

        default void enhancePartitionSchema​(SchemaBuilder partitionSchemaBuilder,
                                            GetTableLayoutRequest request)
        Default implementation does not enhance the partition results schema
      • readWithConstraint

        void readWithConstraint​(BlockSpiller spiller,
                                ReadRecordsRequest recordsRequest,
                                QueryStatusChecker queryStatusChecker)
        Effects the requested read against the table, writing result row data using the supplied BlockSpliller.