fe/src/main/java/com/cloudera/impala/catalog/TableLoadingMgr.java
/**
   * Gets the next table name to load off the head of the table loading queue. If
   * the queue is empty, this will block until a new table is added.
   */
Gets the next table name to load off the head of the table loading queue. If
the queue is empty, this will block until a new table is added.
Gets the next table name to load off the head of the table loading queue . If the queue is empty this will block until a new table is added .
private void loadNextTable() throws InterruptedException {
    TTableName tblName = tableLoadingDeque_.takeFirst();
    tableLoadingSet_.remove(tblName);
    LOG.debug("Loading next table. Remaining items in queue: "
        + tableLoadingDeque_.size());
    try {
      catalog_.getOrLoadTable(tblName.getDb_name(), tblName.getTable_name());
    } catch (DatabaseNotFoundException e) {
    }
  }
private void loadNextTable ( ) throws InterruptedException { TTableName tblName = tableLoadingDeque_ . takeFirst ( ) ; tableLoadingSet_ . remove ( tblName ) ; LOG . debug ( "Loading next table. Remaining items in queue: " + tableLoadingDeque_ . size ( ) ) ; try { catalog_ . getOrLoadTable ( tblName . getDb_name ( ) , tblName . getTable_name ( ) ) ; } catch ( DatabaseNotFoundException e ) { } }
Gets the next table name to load off the head of the table loading queue.
Gets the next table name to load off the head of the table loading queue .
// Always get the next table from the head of the deque. // TODO: Instead of calling "getOrLoad" here we could call "loadAsync". We would // just need to add a mechanism for moving loaded tables into the Catalog. // Ignore.