Class LocalTable

fe/src/main/java/org/apache/impala/catalog/local/LocalTable.java:78–481

Table instance loaded from LocalCatalog. This class is not thread-safe. A new instance is created for each catalog instance.

 * each catalog instance.
 */
abstract class LocalTable implements FeTable {
  private static final Logger LOG = LoggerFactory.getLogger(LocalTable.class);

  protected final LocalDb db_;
  /** The lower-case name of the table. */
  protected final String name_;
  protected final TImpalaTableType tableType_;
  protected final String tableComment_;

  private final ColumnMap cols_;

  protected final Table msTable_;

  private final TTableStats tableStats_;

  // Virtual columns of this table.
  protected final ArrayList<VirtualColumn> virtualCols_ = new ArrayList<>();

  // Test only stats that will be injected in place of stats obtained from HMS.
  protected SideloadTableStats testStats_ = null;

  // Scale factor to multiply table stats with. Only used for testing.
  protected double testMetadataScale_ = 1.0;

  /**
   * Table reference as provided by the initial call to the metadata provider.
   * This must be passed back to any further calls to the metadata provider
   * in order to verify consistency.
   *
   * In the case of CTAS target tables, this may be null. Since the tables don't
   * exist yet in any metadata storage, it would be invalid to try to load any metadata
   * about them.
   */
  @Nullable
  @VisibleForTesting
  protected final TableMetaRef ref_;

  public static LocalTable load(LocalDb db, String tblName) throws TableLoadingException {
    Pair<Table, TableMetaRef> tableMeta = loadTableMetadata(db, tblName);
    return load(db, tableMeta);
  }

  public static LocalTable load(LocalDb db, Pair<Table, TableMetaRef> tableMeta)
      throws TableLoadingException {
    // In order to know which kind of table subclass to instantiate, we need
    // to eagerly grab and parse the top-level Table object from the HMS.
    LocalTable t = null;
    Table msTbl = tableMeta.first;
    TableMetaRef ref = tableMeta.second;
    if (TableType.valueOf(msTbl.getTableType()) == TableType.VIRTUAL_VIEW) {
      t = new LocalView(db, msTbl, ref);
    } else if (HBaseTable.isHBaseTable(msTbl)) {
      t = LocalHbaseTable.loadFromHbase(db, msTbl, ref);
    } else if (KuduTable.isKuduTable(msTbl)) {
      t = LocalKuduTable.loadFromKudu(db, msTbl, ref);
    } else if (IcebergTable.isIcebergTable(msTbl)) {
      t = LocalIcebergTable.loadIcebergTableViaMetaProvider(db, msTbl, ref);
    } else if (PaimonUtil.isPaimonTable(msTbl)) {