Class ThreadPools


  • public class ThreadPools
    extends java.lang.Object
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static java.util.concurrent.ExecutorService getWorkerPool()
      Return an ExecutorService that uses the "worker" thread-pool.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Field Detail

      • WORKER_THREAD_POOL_SIZE_PROP

        public static final java.lang.String WORKER_THREAD_POOL_SIZE_PROP
        See Also:
        Constant Field Values
      • WORKER_THREAD_POOL_SIZE

        public static final int WORKER_THREAD_POOL_SIZE
    • Method Detail

      • getWorkerPool

        public static java.util.concurrent.ExecutorService getWorkerPool()
        Return an ExecutorService that uses the "worker" thread-pool.

        The size of the worker pool limits the number of tasks concurrently reading manifests in the base table implementation across all concurrent planning operations.

        The size of this thread-pool is controlled by the Java system property iceberg.worker.num-threads.

        Returns:
        an ExecutorService that uses the worker pool