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

类 StreamingDataBlockHeaderImpl

java.lang.Object

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

所有已实现的接口:

DataBlockHeader

public class StreamingDataBlockHeaderImpl
extends Object
implements DataBlockHeader

The data block header in tiered storage for each data block.

字段概要

字段

修饰符和类型	字段	说明
static final int	HEADER_MAX_SIZE

构造器概要

构造器

构造器	说明
StreamingDataBlockHeaderImpl(long headerLength, long blockLength, long ledgerId, long firstEntryId)

方法概要

修饰符和类型	方法	说明
static StreamingDataBlockHeaderImpl	fromStream(InputStream stream)
long	getBlockLength()	Get the length of the block in bytes, including the header.
static int	getBlockMagicWord()
static int	getDataStartOffset()
long	getFirstEntryId()	Get the message entry Id for the first message that stored in this data block.
long	getHeaderLength()	Get the size of this DataBlockHeader.
long	getLedgerId()
static StreamingDataBlockHeaderImpl	of(int blockLength, long ledgerId, long firstEntryId)
InputStream	toStream()	Get the content of the data block header as InputStream.
String	toString()

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

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

字段详细资料

HEADER_MAX_SIZE

public static final int HEADER_MAX_SIZE

另请参阅:

• 常量字段值

构造器详细资料

StreamingDataBlockHeaderImpl

public StreamingDataBlockHeaderImpl(long headerLength,
 long blockLength,
 long ledgerId,
 long firstEntryId)

方法详细资料

getLedgerId

public long getLedgerId()

of

public static StreamingDataBlockHeaderImpl of(int blockLength,
 long ledgerId,
 long firstEntryId)

getBlockMagicWord

public static int getBlockMagicWord()

getDataStartOffset

public static int getDataStartOffset()

getBlockLength

public long getBlockLength()

从接口复制的说明: DataBlockHeader

Get the length of the block in bytes, including the header.

指定者:

getBlockLength 在接口中 DataBlockHeader

getHeaderLength

public long getHeaderLength()

从接口复制的说明: DataBlockHeader

Get the size of this DataBlockHeader.

指定者:

getHeaderLength 在接口中 DataBlockHeader

getFirstEntryId

public long getFirstEntryId()

从接口复制的说明: DataBlockHeader

Get the message entry Id for the first message that stored in this data block.

指定者:

getFirstEntryId 在接口中 DataBlockHeader

fromStream

public static StreamingDataBlockHeaderImpl fromStream(InputStream stream)
                                               throws IOException

抛出:

IOException

toStream

public InputStream toStream()

Get the content of the data block header as InputStream. Read out in format: [ magic_word -- int ][ block_len -- int ][ first_entry_id -- long] [padding zeros]

指定者:

toStream 在接口中 DataBlockHeader

toString

public String toString()

覆盖:

toString 在类中 Object