public class ObjectStorePoolImpl extends Object implements ObjectStorePool
ObjectStoreRequest
s that involve communicating wih Object Store.Constructor and Description |
---|
ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver,
ThreadPoolExecutor threadPool,
TierObjectStore tierObjectStore,
RestoreMetricsManager restoreMetricsManager,
org.apache.kafka.common.utils.Time time)
Constructs a new ObjectStorePool using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
shutdown()
Shuts down the ObjectStorePool.
|
void |
startUp()
Starts up the ObjectStorePool.
|
void |
submitObjectStoreRequest(ObjectStoreRequest objectStoreRequest)
Submits objectStoreRequest to be processed.
|
ThreadPoolExecutor |
threadPool() |
public ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver, ThreadPoolExecutor threadPool, TierObjectStore tierObjectStore, RestoreMetricsManager restoreMetricsManager, org.apache.kafka.common.utils.Time time)
resultsReceiver
- results receiver to send results totierObjectStore
- object store to write tothreadPool
- thread poolpublic void startUp()
startUp
in interface ObjectStorePool
public void shutdown()
shutdown
in interface ObjectStorePool
public void submitObjectStoreRequest(ObjectStoreRequest objectStoreRequest)
submitObjectStoreRequest
in interface ObjectStorePool
objectStoreRequest
- request to be processed.public ThreadPoolExecutor threadPool()