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

类 BlockAwareSegmentInputStreamImpl

java.lang.Object

java.io.InputStream

org.apache.bookkeeper.mledger.offload.jcloud.BlockAwareSegmentInputStream

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

所有已实现的接口:

Closeable, AutoCloseable

public class BlockAwareSegmentInputStreamImpl
extends BlockAwareSegmentInputStream

The BlockAwareSegmentInputStreamImpl for each cold storage data block. 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

构造器概要

构造器

构造器	说明
BlockAwareSegmentInputStreamImpl(org.apache.bookkeeper.client.api.ReadHandle ledger, long startEntryId, int blockSize)

方法概要

修饰符和类型	方法	说明
static int	calculateBlockSize(int maxBlockSize, org.apache.bookkeeper.client.api.ReadHandle readHandle, long firstEntryToWrite, long entryBytesAlreadyWritten)
void	close()
int	getBlockEntryBytesCount()	Get sum of entries data size read from the this InputStream.
int	getBlockEntryCount()	Get entry count that read out from this InputStream.
int	getBlockSize()	Get block size that could read out from this InputStream.
int	getDataBlockFullOffset()
long	getEndEntryId()	Get end entry id contained in this InputStream.
static long	getHeaderSize()
org.apache.bookkeeper.client.api.ReadHandle	getLedger()	Get the ledger, from which this InputStream read data.
long	getStartEntryId()	Get start entry id contained in this InputStream.
int	read()
int	read(byte[] b, int off, int len)

从类继承的方法 java.io.InputStream

available, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo

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

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

构造器详细资料

BlockAwareSegmentInputStreamImpl

public BlockAwareSegmentInputStreamImpl(org.apache.bookkeeper.client.api.ReadHandle ledger,
 long startEntryId,
 int blockSize)

方法详细资料

read

public int read(byte[] b,
 int off,
 int len)
         throws IOException

覆盖:

read 在类中 InputStream

抛出:

IOException

read

public int read()
         throws IOException

指定者:

read 在类中 InputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Closeable

覆盖:

close 在类中 InputStream

抛出:

IOException

getLedger

public org.apache.bookkeeper.client.api.ReadHandle getLedger()

从类复制的说明: BlockAwareSegmentInputStream

Get the ledger, from which this InputStream read data.

指定者:

getLedger 在类中 BlockAwareSegmentInputStream

getStartEntryId

public long getStartEntryId()

从类复制的说明: BlockAwareSegmentInputStream

Get start entry id contained in this InputStream.

指定者:

getStartEntryId 在类中 BlockAwareSegmentInputStream

返回:

the start entry id

getBlockSize

public int getBlockSize()

从类复制的说明: BlockAwareSegmentInputStream

Get block size that could read out from this InputStream.

指定者:

getBlockSize 在类中 BlockAwareSegmentInputStream

返回:

the block size

getDataBlockFullOffset

public int getDataBlockFullOffset()

getBlockEntryCount

public int getBlockEntryCount()

从类复制的说明: BlockAwareSegmentInputStream

Get entry count that read out from this InputStream.

指定者:

getBlockEntryCount 在类中 BlockAwareSegmentInputStream

返回:

the block entry count

getEndEntryId

public long getEndEntryId()

从类复制的说明: BlockAwareSegmentInputStream

Get end entry id contained in this InputStream.

指定者:

getEndEntryId 在类中 BlockAwareSegmentInputStream

返回:

the end entry id

getBlockEntryBytesCount

public int getBlockEntryBytesCount()

从类复制的说明: BlockAwareSegmentInputStream

Get sum of entries data size read from the this InputStream.

指定者:

getBlockEntryBytesCount 在类中 BlockAwareSegmentInputStream

返回:

the block entry bytes count

getHeaderSize

public static long getHeaderSize()

calculateBlockSize

public static int calculateBlockSize(int maxBlockSize,
 org.apache.bookkeeper.client.api.ReadHandle readHandle,
 long firstEntryToWrite,
 long entryBytesAlreadyWritten)