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

类 BlobStoreBackedReadHandleImpl

java.lang.Object
org.apache.bookkeeper.mledger.offload.jcloud.impl.BlobStoreBackedReadHandleImpl
所有已实现的接口:
AutoCloseable, org.apache.bookkeeper.client.api.Handle, org.apache.bookkeeper.client.api.ReadHandle
public class BlobStoreBackedReadHandleImpl extends Object implements org.apache.bookkeeper.client.api.ReadHandle

  • 方法详细资料

    • getId

      public long getId()
      指定者:
      getId 在接口中 org.apache.bookkeeper.client.api.Handle

    • getLedgerMetadata

      public org.apache.bookkeeper.client.api.LedgerMetadata getLedgerMetadata()
      指定者:
      getLedgerMetadata 在接口中 org.apache.bookkeeper.client.api.Handle

    • closeAsync

      public CompletableFuture<Void> closeAsync()
      指定者:
      closeAsync 在接口中 org.apache.bookkeeper.client.api.Handle

    • readAsync

      public CompletableFuture<org.apache.bookkeeper.client.api.LedgerEntries> readAsync(long firstEntry, long lastEntry)
      指定者:
      readAsync 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • readUnconfirmedAsync

      public CompletableFuture<org.apache.bookkeeper.client.api.LedgerEntries> readUnconfirmedAsync(long firstEntry, long lastEntry)
      指定者:
      readUnconfirmedAsync 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • readLastAddConfirmedAsync

      public CompletableFuture<Long> readLastAddConfirmedAsync()
      指定者:
      readLastAddConfirmedAsync 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • tryReadLastAddConfirmedAsync

      public CompletableFuture<Long> tryReadLastAddConfirmedAsync()
      指定者:
      tryReadLastAddConfirmedAsync 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • getLastAddConfirmed

      public long getLastAddConfirmed()
      指定者:
      getLastAddConfirmed 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • getLength

      public long getLength()
      指定者:
      getLength 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • isClosed

      public boolean isClosed()
      指定者:
      isClosed 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • readLastAddConfirmedAndEntryAsync

      public CompletableFuture<org.apache.bookkeeper.client.api.LastConfirmedAndEntry> readLastAddConfirmedAndEntryAsync(long entryId, long timeOutInMillis, boolean parallel)
      指定者:
      readLastAddConfirmedAndEntryAsync 在接口中 org.apache.bookkeeper.client.api.ReadHandle

    • open

      public static org.apache.bookkeeper.client.api.ReadHandle open(ScheduledExecutorService executor, org.jclouds.blobstore.BlobStore blobStore, String bucket, String key, String indexKey, DataBlockUtils.VersionCheck versionCheck, long ledgerId, int readBufferSize) throws IOException
      抛出:
      IOException