fe/src/main/java/org/apache/impala/catalog/TableLoadingMgr.java
/**
   * Starts table loading threads in a fixed sized thread pool with a size
   * defined by NUM_TBL_LOADING_THREADS. Each thread polls the tableLoadingDeque_
   * for new tables to load.
   */
Starts table loading threads in a fixed sized thread pool with a size
defined by NUM_TBL_LOADING_THREADS. Each thread polls the tableLoadingDeque_
for new tables to load.
Starts table loading threads in a fixed sized thread pool with a size defined by NUM_TBL_LOADING_THREADS . Each thread polls the tableLoadingDeque_ for new tables to load .
private void startTableLoadingThreads() {
    ExecutorService loadingPool = Executors.newFixedThreadPool(numLoadingThreads_);
    try {
      for (int i = 0; i < numLoadingThreads_; ++i) {
        loadingPool.execute(new Runnable() {
          @Override
          public void run() {
            while (true) {
              try {
                loadNextTable();
              } catch (Exception e) {
                LOG.error("Error loading table: ", e);
              }
            }
          }
        });
      }
    } finally {
      loadingPool.shutdown();
    }
  }
private void startTableLoadingThreads ( ) { ExecutorService loadingPool = Executors . newFixedThreadPool ( numLoadingThreads_ ) ; try { for ( int i = 0 ; i < numLoadingThreads_ ; ++ i ) { loadingPool . execute ( new Runnable ( ) { @ Override public void run ( ) { while ( true ) { try { loadNextTable ( ) ; } catch ( Exception e ) { LOG . error ( "Error loading table: " , e ) ; } } } } ) ; } } finally { loadingPool . shutdown ( ) ; } }
Starts table loading threads in a fixed sized thread pool with a size
 defined by NUM_TBL_LOADING_THREADS.
Starts table loading threads in a fixed sized thread pool with a size defined by NUM_TBL_LOADING_THREADS .
// Ignore exception.