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

类 OffloadIndexBlockImpl

java.lang.Object

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

所有已实现的接口:

Closeable, AutoCloseable, OffloadIndexBlock, OffloadIndexBlockV2

public class OffloadIndexBlockImpl
extends Object
implements OffloadIndexBlock

嵌套类概要

从接口继承的嵌套类/接口 org.apache.bookkeeper.mledger.offload.jcloud.OffloadIndexBlock

OffloadIndexBlock.IndexInputStream

方法概要

修饰符和类型	方法	说明
void	close()
static OffloadIndexBlockImpl	get(int magic, DataInputStream stream)
static OffloadIndexBlockImpl	get(org.apache.bookkeeper.client.api.LedgerMetadata metadata, long dataObjectLength, long dataHeaderLength, List<OffloadIndexEntryImpl> entries)
long	getDataBlockHeaderLength()	Get the length of the header in the blocks in the data object.
long	getDataObjectLength()	Get the total size of the data object.
int	getEntryCount()	Get the entry count that contained in this index Block.
OffloadIndexEntry	getIndexEntryForEntry(long messageEntryId)	Get the related OffloadIndexEntry that contains the given messageEntryId.
static int	getIndexMagicWord()
org.apache.bookkeeper.client.api.LedgerMetadata	getLedgerMetadata()	Get LedgerMetadata.
void	recycle()
OffloadIndexBlock.IndexInputStream	toStream()	Get the content of the index block as InputStream.

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

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

从接口继承的方法 org.apache.bookkeeper.mledger.offload.jcloud.OffloadIndexBlock

getIndexEntryForEntry, getLedgerMetadata, getStartEntryId

方法详细资料

get

public static OffloadIndexBlockImpl get(org.apache.bookkeeper.client.api.LedgerMetadata metadata,
 long dataObjectLength,
 long dataHeaderLength,
 List<OffloadIndexEntryImpl> entries)

get

public static OffloadIndexBlockImpl get(int magic,
 DataInputStream stream)
                                 throws IOException

抛出:

IOException

recycle

public void recycle()

getIndexEntryForEntry

public OffloadIndexEntry getIndexEntryForEntry(long messageEntryId)
                                        throws IOException

从接口复制的说明: OffloadIndexBlock

Get the related OffloadIndexEntry that contains the given messageEntryId.

指定者:

getIndexEntryForEntry 在接口中 OffloadIndexBlock

参数:

messageEntryId - the entry id of message

返回:

the offload index entry

抛出:

IOException

getEntryCount

public int getEntryCount()

从接口复制的说明: OffloadIndexBlock

Get the entry count that contained in this index Block.

指定者:

getEntryCount 在接口中 OffloadIndexBlock

指定者:

getEntryCount 在接口中 OffloadIndexBlockV2

getLedgerMetadata

public org.apache.bookkeeper.client.api.LedgerMetadata getLedgerMetadata()

从接口复制的说明: OffloadIndexBlock

Get LedgerMetadata.

指定者:

getLedgerMetadata 在接口中 OffloadIndexBlock

getDataObjectLength

public long getDataObjectLength()

从接口复制的说明: OffloadIndexBlock

Get the total size of the data object.

指定者:

getDataObjectLength 在接口中 OffloadIndexBlock

指定者:

getDataObjectLength 在接口中 OffloadIndexBlockV2

getDataBlockHeaderLength

public long getDataBlockHeaderLength()

从接口复制的说明: OffloadIndexBlock

Get the length of the header in the blocks in the data object.

指定者:

getDataBlockHeaderLength 在接口中 OffloadIndexBlock

指定者:

getDataBlockHeaderLength 在接口中 OffloadIndexBlockV2

toStream

public OffloadIndexBlock.IndexInputStream toStream()
                                            throws IOException

Get the content of the index block as InputStream. Read out in format: | index_magic_header | index_block_len | data_object_len | data_header_len | | index_entry_count | segment_metadata_len | segment metadata | index entries... |

指定者:

toStream 在接口中 OffloadIndexBlock

指定者:

toStream 在接口中 OffloadIndexBlockV2

抛出:

IOException

getIndexMagicWord

public static int getIndexMagicWord()

close

public void close()

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Closeable