com.alibaba.innodb.java.reader.service.impl

类 FileChannelStorageServiceImpl

java.lang.Object

com.alibaba.innodb.java.reader.service.impl.FileChannelStorageServiceImpl

所有已实现的接口:

StorageService, Closeable, AutoCloseable

public class FileChannelStorageServiceImpl
extends Object
implements StorageService

FileChannelStorageServiceImpl

Use Java NIO2.0 to read file, leverage page cache, data are read into JVM direct memory then copy to heap.

Note that to achieve GC-less load, we prefer to use DirectBuffer in ThreadLocal. We could create one DirectByteBuffer pool to make the same result, but here we use HeapByteBuffer because direct byte buffer cannot be released once page is load, the lifecycle has to be extended until decoding by IndexService is done, so we cannot simply add try-finally to clean the buffer after load and recycle them to the pool. The lifecycle of the direct byte buffer must be managed by index service as well, this will be enhanced in the future.

作者:

xu.zx

构造器概要

构造器

构造器和说明
FileChannelStorageServiceImpl()

方法概要

限定符和类型	方法和说明
void	close()
InnerPage	loadPage(long pageNumber) load page
FilHeader	loadPageHeader(long pageNumber) only load page header
long	numOfPages() Number of pages in the tablespace
void	open(String ibdFilePath) open file

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

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

构造器详细资料

FileChannelStorageServiceImpl

public FileChannelStorageServiceImpl()

方法详细资料

open

public void open(String ibdFilePath)
          throws IOException

从接口复制的说明: StorageService

open file

指定者:

open 在接口中 StorageService

参数:

ibdFilePath - file path

抛出:

IOException - throws IOException when open file fails

loadPage

public InnerPage loadPage(long pageNumber)
                   throws ReaderException

从接口复制的说明: StorageService

load page

指定者:

loadPage 在接口中 StorageService

参数:

pageNumber - page number

返回:

InnerPage

抛出:

ReaderException - throws ReaderException when internal errors occurs

loadPageHeader

public FilHeader loadPageHeader(long pageNumber)
                         throws ReaderException

从接口复制的说明: StorageService

only load page header

指定者:

loadPageHeader 在接口中 StorageService

参数:

pageNumber - page number

返回:

FilHeader

抛出:

ReaderException - throws ReaderException when internal errors occurs

close

public void close()
           throws IOException

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

抛出:

IOException

numOfPages

public long numOfPages()

从接口复制的说明: StorageService

Number of pages in the tablespace

指定者:

numOfPages 在接口中 StorageService

返回:

Number of pages