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

类 IndexServiceImpl

java.lang.Object

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

所有已实现的接口:

Constants, IndexService

public class IndexServiceImpl
extends Object
implements IndexService, Constants

Index service implementation

Only work for clustered index currently.

作者:

xu.zx

嵌套类概要

从接口继承的嵌套类/接口 com.alibaba.innodb.java.reader.Constants

Constants.Symbol

字段概要

从接口继承的字段 com.alibaba.innodb.java.reader.Constants

CONST_UNSIGNED_LOWER, CONST_UNSIGNED_UPPER, DEFAULT_JAVA_CHARSET, DEFAULT_MYSQL_CHARSET, ROOT_PAGE_NUMBER

构造器概要

构造器

构造器和说明
IndexServiceImpl(StorageService storageService, Schema schema)

方法概要

限定符和类型	方法和说明
Iterator<GenericRecord>	getQueryAllIterator() Leverage getRangeQueryIterator(Object, Object)
Iterator<GenericRecord>	getRangeQueryIterator(Object lowerInclusiveKey, Object upperExclusiveKey) The implementation is different from the way queryAll(Optional) works.
List<GenericRecord>	queryAll(Optional<java.util.function.Predicate<GenericRecord>> recordPredicate) query all records of a tablespace Note this will cause out-of-memory if the table is too big
List<GenericRecord>	queryByPageNumber(int pageNumber) query all records by single page
List<GenericRecord>	queryByPageNumber(long pageNumber) query all records by single page
GenericRecord	queryByPrimaryKey(Object key) query record by primary key in a tablespace
List<GenericRecord>	rangeQueryByPrimaryKey(Object lowerInclusiveKey, Object upperExclusiveKey, Optional<java.util.function.Predicate<GenericRecord>> recordPredicate) range query records by primary key in a tablespace Note this will cause out-of-memory if there are too many records within the range
void	traverseBPlusTree(long pageNumber, List<GenericRecord> recordList, Optional<java.util.function.Predicate<GenericRecord>> recordPredicate) Traverse b+ tree from root page recursively in depth-first way.

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

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

构造器详细资料

IndexServiceImpl

public IndexServiceImpl(StorageService storageService,
                        Schema schema)

方法详细资料

queryByPageNumber

public List<GenericRecord> queryByPageNumber(int pageNumber)

从接口复制的说明: IndexService

query all records by single page

指定者:

queryByPageNumber 在接口中 IndexService

参数:

pageNumber - page number (int type), can be leaf or non-leaf page

返回:

list of records

queryByPageNumber

public List<GenericRecord> queryByPageNumber(long pageNumber)

从接口复制的说明: IndexService

query all records by single page

指定者:

queryByPageNumber 在接口中 IndexService

参数:

pageNumber - page number (long type), can be leaf or non-leaf page

返回:

list of records

queryByPrimaryKey

public GenericRecord queryByPrimaryKey(Object key)

从接口复制的说明: IndexService

query record by primary key in a tablespace

指定者:

queryByPrimaryKey 在接口中 IndexService

参数:

key - primary key

返回:

record

queryAll

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

从接口复制的说明: IndexService

query all records of a tablespace

Note this will cause out-of-memory if the table is too big

指定者:

queryAll 在接口中 IndexService

参数:

recordPredicate - optional. evaluating record, if true then it will be added to result set, else skip it

返回:

all records

getQueryAllIterator

public Iterator<GenericRecord> getQueryAllIterator()

Leverage getRangeQueryIterator(Object, Object)

指定者:

getQueryAllIterator 在接口中 IndexService

返回:

record iterator

getRangeQueryIterator

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

The implementation is different from the way queryAll(Optional) works. This method will do point query to search the nearest lower and upper bound record, then visit the leaf page, go through all the level 0 pages by the double-linked pages. While queryAll(Optional) traverses b+ tree in a depth-first way.

指定者:

getRangeQueryIterator 在接口中 IndexService

参数:

lowerInclusiveKey - lower bound, inclusive, if set to null means no limit for lower

upperExclusiveKey - upper bound, exclusive, if set to null means no limit for upper

返回:

record iterator

rangeQueryByPrimaryKey

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

从接口复制的说明: IndexService

range query records by primary key in a tablespace

Note this will cause out-of-memory if there are too many records within the range

指定者:

rangeQueryByPrimaryKey 在接口中 IndexService

参数:

lowerInclusiveKey - lower bound, inclusive, if set to null means no limit for lower

upperExclusiveKey - upper bound, exclusive, if set to null means no limit for upper

recordPredicate - optional. evaluating record, if true then it will be added to result set, else skip it

返回:

list of records

traverseBPlusTree

public void traverseBPlusTree(long pageNumber,
                              List<GenericRecord> recordList,
                              Optional<java.util.function.Predicate<GenericRecord>> recordPredicate)

Traverse b+ tree from root page recursively in depth-first way.

参数:

pageNumber - page number

recordList - where record will be add to

recordPredicate - evaluating record, if true then it will be added to result set, else skip it