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

类 BlockAwareSegmentInputStream

java.lang.Object
java.io.InputStream
org.apache.bookkeeper.mledger.offload.jcloud.BlockAwareSegmentInputStream
所有已实现的接口:
Closeable, AutoCloseable
直接已知子类:
BlockAwareSegmentInputStreamImpl
public abstract class BlockAwareSegmentInputStream extends InputStream
The BlockAwareSegmentInputStream for each cold storage data block. This interface should be implemented while extends InputStream. It gets data from ledger, and will be read out the content for a data block. DataBlockHeader + entries(each with format[[entry_size -- int][entry_id -- long][entry_data]]) + padding

  • 构造器详细资料

    • BlockAwareSegmentInputStream

      public BlockAwareSegmentInputStream()

  • 方法详细资料

    • getLedger

      public abstract org.apache.bookkeeper.client.api.ReadHandle getLedger()
      Get the ledger, from which this InputStream read data.

    • getStartEntryId

      public abstract long getStartEntryId()
      Get start entry id contained in this InputStream.
      返回:
      the start entry id

    • getBlockSize

      public abstract int getBlockSize()
      Get block size that could read out from this InputStream.
      返回:
      the block size

    • getBlockEntryCount

      public abstract int getBlockEntryCount()
      Get entry count that read out from this InputStream.
      返回:
      the block entry count

    • getEndEntryId

      public abstract long getEndEntryId()
      Get end entry id contained in this InputStream.
      返回:
      the end entry id

    • getBlockEntryBytesCount

      public abstract int getBlockEntryBytesCount()
      Get sum of entries data size read from the this InputStream.
      返回:
      the block entry bytes count