org.apache.iceberg.util

Class ThreadPools

java.lang.Object

org.apache.iceberg.util.ThreadPools

public class ThreadPools
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	WORKER_THREAD_POOL_SIZE
static java.lang.String	WORKER_THREAD_POOL_SIZE_PROP

Method Summary

Modifier and Type	Method and 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