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

类 OffloadIndexBlockV2Impl

java.lang.Object

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

所有已实现的接口:

Closeable, AutoCloseable, OffloadIndexBlockV2

public class OffloadIndexBlockV2Impl
extends Object
implements OffloadIndexBlockV2

方法概要

修饰符和类型	方法	说明
void	close()
static OffloadIndexBlockV2Impl	get(int magic, DataInputStream stream)
static OffloadIndexBlockV2Impl	get(Map<Long,org.apache.bookkeeper.mledger.proto.MLDataFormats.ManagedLedgerInfo.LedgerInfo> metadata, long dataObjectLength, long dataHeaderLength, Map<Long,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 ledgerId, long messageEntryId)	Get the related OffloadIndexEntry that contains the given messageEntryId.
static int	getIndexMagicWord()
org.apache.bookkeeper.client.api.LedgerMetadata	getLedgerMetadata(long ledgerId)	Get LedgerMetadata.
long	getStartEntryId(long ledgerId)
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

方法详细资料

get

public static OffloadIndexBlockV2Impl get(Map<Long,org.apache.bookkeeper.mledger.proto.MLDataFormats.ManagedLedgerInfo.LedgerInfo> metadata,
 long dataObjectLength,
 long dataHeaderLength,
 Map<Long,List<OffloadIndexEntryImpl>> entries)

get

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

抛出:

IOException

recycle

public void recycle()

getIndexEntryForEntry

public OffloadIndexEntry getIndexEntryForEntry(long ledgerId,
 long messageEntryId)
                                        throws IOException

从接口复制的说明: OffloadIndexBlockV2

Get the related OffloadIndexEntry that contains the given messageEntryId.

指定者:

getIndexEntryForEntry 在接口中 OffloadIndexBlockV2

messageEntryId - the entry id of message

返回:

the offload index entry

抛出:

IOException

getStartEntryId

public long getStartEntryId(long ledgerId)

指定者:

getStartEntryId 在接口中 OffloadIndexBlockV2

getEntryCount

public int getEntryCount()

从接口复制的说明: OffloadIndexBlockV2

Get the entry count that contained in this index Block.

指定者:

getEntryCount 在接口中 OffloadIndexBlockV2

getLedgerMetadata

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

从接口复制的说明: OffloadIndexBlockV2

Get LedgerMetadata.

指定者:

getLedgerMetadata 在接口中 OffloadIndexBlockV2

返回:

getDataObjectLength

public long getDataObjectLength()

从接口复制的说明: OffloadIndexBlockV2

Get the total size of the data object.

指定者:

getDataObjectLength 在接口中 OffloadIndexBlockV2

getDataBlockHeaderLength

public long getDataBlockHeaderLength()

从接口复制的说明: OffloadIndexBlockV2

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

指定者:

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 在接口中 OffloadIndexBlockV2

抛出:

IOException

getIndexMagicWord

public static int getIndexMagicWord()

close

public void close()

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Closeable