com.hof.mi.etl.runner

Class ETLPreviewThreadManager

java.lang.Object

com.hof.mi.etl.runner.ETLPreviewThreadManager

All Implemented Interfaces:

ETLThreadManager

public class ETLPreviewThreadManager
extends java.lang.Object
implements ETLThreadManager

Implementation of the ETLThreadManager interface for managing threads for ETL Preview (edit mode) Execution. It creates a Fixed Thread Pool. The number of threads is determined by a number of factors:

1. Number of runnable "head" steps
2. Minimum number of threads for concurrency, as defined in ETLThreadManager.MIN_THREADS_FOR_CONCURRENCY
3. MaxThreadsPerETLPreviewJob startup parameter, if available, from #getMaxThreadsPerETLPreviewJob()

The size of the thread pool will not exceed MaxThreadsPerETLPreviewJob, unless it is lesser than ETLThreadManager.MIN_THREADS_FOR_CONCURRENCY.

Field Summary

Fields inherited from interface com.hof.mi.etl.runner.ETLThreadManager

MIN_THREADS_FOR_CONCURRENCY

Constructor Summary

Constructors

Constructor and Description
ETLPreviewThreadManager(int headCount)

Method Summary

Methods

Modifier and Type	Method and Description
int	getMaxThreads() Get the maximum number of threads in the Thread Manager
void	shutdown() Shut down the Thread Manager.
java.util.concurrent.Future<java.lang.Void>	submit(ExecutionHead head) Submit a head task to the Thread Manager and return a Future.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ETLPreviewThreadManager

public ETLPreviewThreadManager(int headCount)

Method Detail

getMaxThreads

public int getMaxThreads()

Description copied from interface: ETLThreadManager

Get the maximum number of threads in the Thread Manager

Specified by:

getMaxThreads in interface ETLThreadManager

submit

public java.util.concurrent.Future<java.lang.Void> submit(ExecutionHead head)

Description copied from interface: ETLThreadManager

Submit a head task to the Thread Manager and return a Future.

Specified by:

submit in interface ETLThreadManager

Parameters:

head - - A runnable which can execute a "head" ETL step.

shutdown

public void shutdown()

Description copied from interface: ETLThreadManager

Shut down the Thread Manager.

Specified by:

shutdown in interface ETLThreadManager