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

类 BufferedOffloadStream

java.lang.Object

java.io.InputStream

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

所有已实现的接口:

Closeable, AutoCloseable

public class BufferedOffloadStream
extends InputStream

构造器概要

构造器

构造器	说明
BufferedOffloadStream(int blockSize, List<org.apache.bookkeeper.mledger.Entry> entries, long ledgerId, long beginEntryId)

方法概要

修饰符和类型	方法	说明
static int	calculateBlockSize(int streamingBlockSize, int entryCount, int entrySize)
void	close()
long	getBeginEntryId()
long	getBlockSize()
long	getEndEntryId()
long	getLedgerId()
int	read()

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

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

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

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

构造器详细资料

BufferedOffloadStream

public BufferedOffloadStream(int blockSize,
 List<org.apache.bookkeeper.mledger.Entry> entries,
 long ledgerId,
 long beginEntryId)

方法详细资料

getEndEntryId

public long getEndEntryId()

getLedgerId

public long getLedgerId()

getBeginEntryId

public long getBeginEntryId()

getBlockSize

public long getBlockSize()

read

public int read()
         throws IOException

指定者:

read 在类中 InputStream

抛出:

IOException

close

public void close()
           throws IOException

指定者:

close 在接口中 AutoCloseable

指定者:

close 在接口中 Closeable

覆盖:

close 在类中 InputStream

抛出:

IOException

calculateBlockSize

public static int calculateBlockSize(int streamingBlockSize,
 int entryCount,
 int entrySize)