程序包 org.apache.bookkeeper.mledger.offload.jcloud.impl

类 BlobStoreManagedLedgerOffloader

java.lang.Object

org.apache.bookkeeper.mledger.offload.jcloud.impl.BlobStoreManagedLedgerOffloader

所有已实现的接口:

org.apache.bookkeeper.mledger.LedgerOffloader

public class BlobStoreManagedLedgerOffloader
extends Object
implements org.apache.bookkeeper.mledger.LedgerOffloader

Tiered Storage Offloader that is backed by a JCloud Blob Store.

The constructor takes an instance of TieredStorageConfiguration, which contains all of the configuration data necessary to connect to a JCloud Provider service.

嵌套类概要

从接口继承的嵌套类/接口 org.apache.bookkeeper.mledger.LedgerOffloader

org.apache.bookkeeper.mledger.LedgerOffloader.OffloadHandle, org.apache.bookkeeper.mledger.LedgerOffloader.OffloadResult

字段概要

从接口继承的字段 org.apache.bookkeeper.mledger.LedgerOffloader

METADATA_PULSAR_CLUSTER_NAME, METADATA_SOFTWARE_GITSHA_KEY, METADATA_SOFTWARE_VERSION_KEY

方法概要

修饰符和类型	方法	说明
void	close()
static BlobStoreManagedLedgerOffloader	create(TieredStorageConfiguration config, Map<String,String> userMetadata, org.apache.bookkeeper.common.util.OrderedScheduler scheduler)
CompletableFuture<Void>	deleteOffloaded(long ledgerId, UUID uid, Map<String,String> offloadDriverMetadata)
CompletableFuture<Void>	deleteOffloaded(UUID uid, Map<String,String> offloadDriverMetadata)
Map<String,String>	getOffloadDriverMetadata()
String	getOffloadDriverName()
org.apache.pulsar.common.policies.data.OffloadPoliciesImpl	getOffloadPolicies()
CompletableFuture<Void>	offload(org.apache.bookkeeper.client.api.ReadHandle readHandle, UUID uuid, Map<String,String> extraMetadata)	Upload the DataBlocks associated with the given ReadHandle using MultiPartUpload, Creating indexBlocks for each corresponding DataBlock that is uploaded.
CompletableFuture<org.apache.bookkeeper.client.api.ReadHandle>	readOffloaded(long ledgerId, UUID uid, Map<String,String> offloadDriverMetadata)
CompletableFuture<org.apache.bookkeeper.client.api.ReadHandle>	readOffloaded(long ledgerId, org.apache.bookkeeper.mledger.proto.MLDataFormats.OffloadContext ledgerContext, Map<String,String> offloadDriverMetadata)
CompletableFuture<org.apache.bookkeeper.mledger.LedgerOffloader.OffloadHandle>	streamingOffload(@NonNull org.apache.bookkeeper.mledger.ManagedLedger ml, UUID uuid, long beginLedger, long beginEntry, Map<String,String> driverMetadata)

从类继承的方法 java.lang.Object

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

方法详细资料

create

public static BlobStoreManagedLedgerOffloader create(TieredStorageConfiguration config,
 Map<String,String> userMetadata,
 org.apache.bookkeeper.common.util.OrderedScheduler scheduler)
                                              throws IOException

抛出:

IOException

getOffloadDriverName

public String getOffloadDriverName()

指定者:

getOffloadDriverName 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

getOffloadDriverMetadata

public Map<String,String> getOffloadDriverMetadata()

指定者:

getOffloadDriverMetadata 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

offload

public CompletableFuture<Void> offload(org.apache.bookkeeper.client.api.ReadHandle readHandle,
 UUID uuid,
 Map<String,String> extraMetadata)

Upload the DataBlocks associated with the given ReadHandle using MultiPartUpload, Creating indexBlocks for each corresponding DataBlock that is uploaded.

指定者:

offload 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

streamingOffload

public CompletableFuture<org.apache.bookkeeper.mledger.LedgerOffloader.OffloadHandle> streamingOffload(@NonNull
 @NonNull org.apache.bookkeeper.mledger.ManagedLedger ml,
 UUID uuid,
 long beginLedger,
 long beginEntry,
 Map<String,String> driverMetadata)

指定者:

streamingOffload 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

readOffloaded

public CompletableFuture<org.apache.bookkeeper.client.api.ReadHandle> readOffloaded(long ledgerId,
 UUID uid,
 Map<String,String> offloadDriverMetadata)

指定者:

readOffloaded 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

readOffloaded

public CompletableFuture<org.apache.bookkeeper.client.api.ReadHandle> readOffloaded(long ledgerId,
 org.apache.bookkeeper.mledger.proto.MLDataFormats.OffloadContext ledgerContext,
 Map<String,String> offloadDriverMetadata)

指定者:

readOffloaded 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

deleteOffloaded

public CompletableFuture<Void> deleteOffloaded(long ledgerId,
 UUID uid,
 Map<String,String> offloadDriverMetadata)

指定者:

deleteOffloaded 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

deleteOffloaded

public CompletableFuture<Void> deleteOffloaded(UUID uid,
 Map<String,String> offloadDriverMetadata)

指定者:

deleteOffloaded 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

getOffloadPolicies

public org.apache.pulsar.common.policies.data.OffloadPoliciesImpl getOffloadPolicies()

指定者:

getOffloadPolicies 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader

close

public void close()

指定者:

close 在接口中 org.apache.bookkeeper.mledger.LedgerOffloader