Package org.apache.iceberg.util
Class ThreadPools
- java.lang.Object
- 
- org.apache.iceberg.util.ThreadPools
 
- 
 public class ThreadPools extends java.lang.Object
- 
- 
Field SummaryFields Modifier and Type Field Description static intWORKER_THREAD_POOL_SIZEstatic java.lang.StringWORKER_THREAD_POOL_SIZE_PROP
 - 
Method SummaryAll Methods Static Methods Concrete Methods Modifier and Type Method Description static java.util.concurrent.ExecutorServicegetWorkerPool()Return anExecutorServicethat uses the "worker" thread-pool.
 
- 
- 
- 
Field Detail- 
WORKER_THREAD_POOL_SIZE_PROPpublic static final java.lang.String WORKER_THREAD_POOL_SIZE_PROP - See Also:
- Constant Field Values
 
 - 
WORKER_THREAD_POOL_SIZEpublic static final int WORKER_THREAD_POOL_SIZE 
 
- 
 - 
Method Detail- 
getWorkerPoolpublic static java.util.concurrent.ExecutorService getWorkerPool() Return anExecutorServicethat 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 ExecutorServicethat uses the worker pool
 
 
- 
 
-