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.
|
protected void |
submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest request)
Submits
RestoreObjectsInStoreRequest to be processed. |
protected void |
submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest request)
Submits
UploadFtpsToStoreRequest 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.protected void submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest request)
RestoreObjectsInStoreRequest
to be processed.request
- request to be processedprotected void submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest request)
UploadFtpsToStoreRequest
to be processed.request
- request to be processedpublic ThreadPoolExecutor threadPool()