com.alibaba.innodb.java.reader

类 TableReader

java.lang.Object

com.alibaba.innodb.java.reader.TableReader

所有已实现的接口:

Closeable, AutoCloseable

public class TableReader
extends Object
implements Closeable

Table space reader to manipulate *.ibd file. Note that operations are thread-safe.

作者:

xu.zx

构造器概要

构造器

构造器和说明
TableReader(String ibdFilePath, Schema schema)
TableReader(String ibdFilePath, String createTableSql)

方法概要

限定符和类型	方法和说明
void	close()
double	getAllIndexPageFillingRate() Get all index page filling rate, use iterator pattern to avoid OutOfMemory.
double	getIndexPageFillingRate(int pageNumber) Get single index page filling rate.
long	getNumOfPages() Get number of pages.
Iterator<AbstractPage>	getPageIterator() Get page iterator.
Iterator<GenericRecord>	getQueryAllIterator()
Iterator<GenericRecord>	getRangeQueryIterator(Object lowerInclusiveKey, Object upperExclusiveKey)
Schema	getSchema()
void	open()
List<GenericRecord>	queryAll()
List<GenericRecord>	queryAll(java.util.function.Predicate<GenericRecord> recordPredicate)
List<GenericRecord>	queryByPageNumber(int pageNumber)
List<GenericRecord>	queryByPageNumber(long pageNumber)
GenericRecord	queryByPrimaryKey(Object key)
List<GenericRecord>	rangeQueryByPrimaryKey(Object lowerInclusiveKey, Object upperExclusiveKey)
List<GenericRecord>	rangeQueryByPrimaryKey(Object lowerInclusiveKey, Object upperExclusiveKey, java.util.function.Predicate<GenericRecord> recordPredicate)
List<FilHeader>	readAllPageHeaders() Read all page headers into memory.
List<AbstractPage>	readAllPages() Read all pages into memory which may cause OutOfMemory when tablespace file size is too big.
AbstractPage	readPage(long pageNumber) Read one page as AbstractPage.

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

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

构造器详细资料

TableReader

public TableReader(String ibdFilePath,
                   String createTableSql)

TableReader

public TableReader(String ibdFilePath,
                   Schema schema)

方法详细资料

open

public void open()

getNumOfPages

public long getNumOfPages()

Get number of pages. If page size is 16KiB, then the value will be file size / 16384.

返回:

number of pages

readAllPages

public List<AbstractPage> readAllPages()

Read all pages into memory which may cause OutOfMemory when tablespace file size is too big. Use getPageIterator() if file size is too big.

返回:

list of AbstractPage

getPageIterator

public Iterator<AbstractPage> getPageIterator()

Get page iterator.

返回:

Iterator of AbstractPage

readAllPageHeaders

public List<FilHeader> readAllPageHeaders()

Read all page headers into memory.

返回:

list of FilHeader

readPage

public AbstractPage readPage(long pageNumber)

Read one page as AbstractPage.

参数:

pageNumber - page number

返回:

AbstractPage

getAllIndexPageFillingRate

public double getAllIndexPageFillingRate()

Get all index page filling rate, use iterator pattern to avoid OutOfMemory.

返回:

filling rate

getIndexPageFillingRate

public double getIndexPageFillingRate(int pageNumber)

Get single index page filling rate.

参数:

pageNumber - page number

返回:

filling rate

queryByPageNumber

public List<GenericRecord> queryByPageNumber(int pageNumber)

queryByPageNumber

public List<GenericRecord> queryByPageNumber(long pageNumber)

queryByPrimaryKey

public GenericRecord queryByPrimaryKey(Object key)

queryAll

public List<GenericRecord> queryAll()

queryAll

public List<GenericRecord> queryAll(java.util.function.Predicate<GenericRecord> recordPredicate)

rangeQueryByPrimaryKey

public List<GenericRecord> rangeQueryByPrimaryKey(Object lowerInclusiveKey,
                                                  Object upperExclusiveKey)

rangeQueryByPrimaryKey

public List<GenericRecord> rangeQueryByPrimaryKey(Object lowerInclusiveKey,
                                                  Object upperExclusiveKey,
                                                  java.util.function.Predicate<GenericRecord> recordPredicate)

getQueryAllIterator

public Iterator<GenericRecord> getQueryAllIterator()

getRangeQueryIterator

public Iterator<GenericRecord> getRangeQueryIterator(Object lowerInclusiveKey,
                                                     Object upperExclusiveKey)

getSchema

public Schema getSchema()

close

public void close()

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable