public class CopyObjectOperator extends Object
Constructor and Description |
---|
CopyObjectOperator(CopyObjectInStoreRequest request,
MultipleResponseHandler restoreHandler,
TierObjectStore tierObjectStore,
ThreadPoolExecutor executor,
RestoreMetricsManager metrics,
org.apache.kafka.common.utils.Time time) |
Modifier and Type | Method and Description |
---|---|
CompletableFuture<Void> |
restoreObjectByCopy()
A wrapper to send copy request to object store asynchronously
|
public CopyObjectOperator(CopyObjectInStoreRequest request, MultipleResponseHandler restoreHandler, TierObjectStore tierObjectStore, ThreadPoolExecutor executor, RestoreMetricsManager metrics, org.apache.kafka.common.utils.Time time)
public CompletableFuture<Void> restoreObjectByCopy()