A B C D E F G H I J L M N O P Q R S T U V W X Y

A

AbstractHADatasource<T extends MysqlDataSource> - net.neoremind.fountain.datasource 中的 类
mysql ha 支持的数据源抽象。
AbstractHADatasource() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 的构造方法
 
AbstractMaxCapacityFountainMQ - net.neoremind.fountain.common.mq 中的 类
内存队列实现的抽象类.
AbstractMaxCapacityFountainMQ(int) - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 的构造方法
构造方法
AbstractMysqlDataSource - net.neoremind.fountain.datasource 中的 类
数据源的抽象实现,实现大部分的通用的功能,比如打开连接、权限验证等,建议其他实现MysqlDataSource接口的类都继承本类
AbstractMysqlDataSource() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 的构造方法
 
AbstractProxyDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
抽象的代理DisposeEventPosition
AbstractProxyDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 的构造方法
 
accept(FormatInfo) - 接口 net.neoremind.fountain.rowbaselog.event.FormatInfoCallback 中的方法
 
acceptTableMapEvent(TableMapEvent) - 接口 net.neoremind.fountain.rowbaselog.event.TableEventCallback 中的方法
保存TableMapEvent事件
addAfterValues(DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAfterValues(int, DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAfterValues(DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAfterValues(int, DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAfterValuesBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAfterValuesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAllAfterValues(Iterable<? extends DataUnitDef.ColumnValue>) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
addAllBeforeValues(Iterable<? extends DataUnitDef.ColumnValue>) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addAllColumnMeta(Iterable<? extends DataUnitDef.ColumnMeta>) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addAllRows(Iterable<? extends DataUnitDef.RowData>) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addAllTables(Iterable<? extends DataUnitDef.TableData>) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addBeforeValues(DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addBeforeValues(int, DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addBeforeValues(DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addBeforeValues(int, DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addBeforeValuesBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addBeforeValuesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
addCallback(Class<? extends BaseLogEvent>, EventCallback) - 类 net.neoremind.fountain.support.EventListener 中的方法
为某种binlog event添加回调
addColumnMeta(DataUnitDef.ColumnMeta) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addColumnMeta(int, DataUnitDef.ColumnMeta) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addColumnMeta(DataUnitDef.ColumnMeta.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addColumnMeta(int, DataUnitDef.ColumnMeta.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addColumnMetaBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addColumnMetaBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
addGtId(byte[], Long) - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
递增gtid

gtid要大于等于interval end,否则抛出GtIdInvalidException异常

addRows(DataUnitDef.RowData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addRows(int, DataUnitDef.RowData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addRows(DataUnitDef.RowData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addRows(int, DataUnitDef.RowData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addRowsBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addRowsBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
addSyncPoint(String, int, String, BigInteger) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
增加sync point
addTables(DataUnitDef.TableData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addTables(int, DataUnitDef.TableData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addTables(DataUnitDef.TableData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addTables(int, DataUnitDef.TableData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addTablesBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
addTablesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
affectRows - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
AFTERVALUES_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态变量
 
AMPERSAND - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
ANONYMOUS_GTID_LOG_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
ANYHOST - 类 net.neoremind.fountain.util.NetUtils 中的静态变量
 
APPEND_BLOCK_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
apply(F) - 接口 net.neoremind.fountain.util.Function 中的方法
Returns the result of applying this function to input.
applySocket(Socket) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
使用给定的socket作为当前实现的主socket
ARRAY - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type ARRAY.
ASTERISK - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
AsyncFixedRateDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
以固定的时间频率异步的存储同步点
AsyncFixedRateDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 的构造方法
 
AT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 

B

BACK_SLASH - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
BACKTICK - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
BaiduGroupIdSyncPoint - net.neoremind.fountain.eventposition 中的 类
描述百度mysql分支的group id
BaiduGroupIdSyncPoint() - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 的构造方法
无参数构造方法
BaiduGroupIdSyncPoint(BigInteger) - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 的构造方法
有参数构造方法
BaiduGroupIdSyncPointFactory - net.neoremind.fountain.eventposition.factory 中的 类
生成BaiduGroupIdSyncPoint
BaiduGroupIdSyncPointFactory() - 类 net.neoremind.fountain.eventposition.factory.BaiduGroupIdSyncPointFactory 的构造方法
 
BaseLogEvent - net.neoremind.fountain.event 中的 类
 
BaseLogEvent(EventHeader) - 类 net.neoremind.fountain.event.BaseLogEvent 的构造方法
 
BEFOREVALUES_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态变量
 
BEGIN_LOAD_QUERY_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
BIGINT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type BIGINT.
BIGINT_64_MAX_VALUE - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
BIGINTEGER - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
biginteger
BINARY - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type BINARY.
BinlogAndOffsetSyncPoint - net.neoremind.fountain.eventposition 中的 类
描述传统row base binlog同步点
BinlogAndOffsetSyncPoint() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 的构造方法
无参数构造方法
BinlogAndOffsetSyncPoint(List<BinlogAndOffsetSyncPoint.MysqlSyncPoint>) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 的构造方法
有参数构造反复
BinlogAndOffsetSyncPoint.MysqlSyncPoint - net.neoremind.fountain.eventposition 中的 类
描述传统的mysql的同步点
BinlogAndOffsetSyncPoint.MysqlSyncPoint() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 的构造方法
 
BinlogAndOffsetSyncPointFactory - net.neoremind.fountain.eventposition.factory 中的 类
生成BinlogAndOffsetSyncPoint
BinlogAndOffsetSyncPointFactory() - 类 net.neoremind.fountain.eventposition.factory.BinlogAndOffsetSyncPointFactory 的构造方法
 
binlogCreateTime - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的变量
4 bytes.
BinlogEventHeader - net.neoremind.fountain.rowbaselog.event 中的 类
MySQL binglog header

对于一个binlog event来说,它分为三个部分,header,post-header以及payload。

BinlogEventHeader(int) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 的构造方法
构造方法
BinlogTraceable - net.neoremind.fountain.changedata 中的 接口
可从追溯binlog来源的数据对象描述
binlogVersion - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的变量
2 bytes.
BIT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type BIT.
bitArray - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
BLOB - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type BLOB.
BOOLEAN - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, somtimes referred to as a type code, that identifies the generic SQL type BOOLEAN.
BOOLVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
BRACE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
大括号
BRACKET - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
中括号
build() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
build() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
build() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
build() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
build() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
buildFromString(String) - 类 net.neoremind.fountain.eventposition.GtId 中的静态方法
从字符串还原成GtId类对象
buildFromString(String) - 类 net.neoremind.fountain.eventposition.GtIdSet 中的静态方法
从字符串还原GtIdSet类对象
buildPartial() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
buildPartial() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
buildPartial() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
buildPartial() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
buildPartial() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
BYTEARRAYVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
bytes2Object(byte[], Class<?>) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 

C

CachedTableMetaProvider - net.neoremind.fountain.meta 中的 类
实现TableMetaProvider接口,支持对表元数据 进行缓存。
CachedTableMetaProvider(MysqlDataSource) - 类 net.neoremind.fountain.meta.CachedTableMetaProvider 的构造方法
构造器
ChangeDataSet - net.neoremind.fountain.changedata 中的 类
描述变化的数据的数据结构,类似jdbc的RowsSet,包括元数据和数据变化。
ChangeDataSet() - 类 net.neoremind.fountain.changedata.ChangeDataSet 的构造方法
构造方法
ChangeDataSet(SyncPoint, String) - 类 net.neoremind.fountain.changedata.ChangeDataSet 的构造方法
构造方法
CHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type CHAR.
checkDataSourceListEmpty() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
检查备选数据源是否为空,如果为空则抛出异常
choose(List<T>, DatasourceChooseCallbackHandler<T>) - 接口 net.neoremind.fountain.datasource.DatasourceChoosePolicy 中的方法
从给定的datasourceList选择合适的datasource,选择过程中如果需要读取数据或者初始化选中的datasource, 调用callback来完成该任务
choose(List<T>, DatasourceChooseCallbackHandler<T>) - 类 net.neoremind.fountain.datasource.RoundRobinDatasourceChoosePolicy 中的方法
 
chooseMysqlDataSource() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
从备选数据源列表中选中可用的数据源源,具体的选择会被委托到DatasourceChoosePolicy 中, 选中的数据源需要使用DatasourceChooseCallbackHandler来回调做一些初始化操作。
cleanTrxContext() - 类 net.neoremind.fountain.support.ThreadHolder 中的静态方法
清空线程上下文
clear() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
clear() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
clear() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
clear() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
clear() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
clearAfterValues() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
clearBeforeValues() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
clearBoolValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool boolValue = 5;
clearByteArrayValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bytes byteArrayValue = 7;
clearColumnMeta() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
clearDataType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required sint32 dataType = 1;
clearDoubleValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional double doubleValue = 1;
clearFloatValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional float floatValue = 2;
clearGtId() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
optional sint64 gtId = 1;
clearIntValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint32 intValue = 3;
clearIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isNull = 4;
clearIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool isNull = 8;
clearIsPrimay() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isPrimay = 3;
clearIsUnsiged() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isUnsiged = 5;
clearLongValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint64 longValue = 4;
clearName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
clearName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
clearOptype() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
required sint32 optype = 3;
clearRows() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
clearStringValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
clearTables() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
clearValueOneof() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
CLIENT_CHARSET_NUMBER - 类 net.neoremind.fountain.util.MysqlCommonConstants 中的静态变量
默认客户端字符集

Number Hex Character Set Name 33 0x21 utf8_general_ci
ClientAuthPacket - net.neoremind.fountain.packet 中的 类
mysql登录验证包
ClientAuthPacket() - 类 net.neoremind.fountain.packet.ClientAuthPacket 的构造方法
 
CLOB - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type CLOB.
clone() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
clone() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
clone() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
clone() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
clone() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
close() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
close() - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
关闭数据源
closeSocket(Socket) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
安全的关闭socket连接,使用apache commons io组件实现
CollectionUtil - net.neoremind.fountain.util 中的 类
集合框架工具类
CollectionUtil() - 类 net.neoremind.fountain.util.CollectionUtil 的构造方法
 
CollectionUtils - net.neoremind.fountain.util 中的 类
集合工具
COLON - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
冒号
ColumnData - net.neoremind.fountain.event.data 中的 类
列数据
ColumnData() - 类 net.neoremind.fountain.event.data.ColumnData 的构造方法
 
ColumnDataParser - net.neoremind.fountain.event 中的 接口
解析协议中的列数据,由协议规定的个数转化为java对象
ColumnDataParserFactory - net.neoremind.fountain.event 中的 接口
根据每列的类型生成该类型的ColumnDataParser实例
columnInfoArray - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
ColumnMeta - net.neoremind.fountain.meta 中的 类
描述表的列信息,主要包括: 列名称 列的数据类型 是否为空标识 是否为索引以及索引类型 默认缺省值 字符集
ColumnMeta() - 类 net.neoremind.fountain.meta.ColumnMeta 的构造方法
 
COLUMNMETA_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态变量
 
columnNullMap - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
columnsLength - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
columnsLength - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
ColumnTypeEnum - net.neoremind.fountain.meta 中的 枚举
描述mysql字段数据类型的枚举
columnUpdateUsedBitSet - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
columnUsedBitSet - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
COM_BINLOG_DUMP - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_BINLOG_DUMP_GTID - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_CHANGE_USER - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_CONNECT - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_CONNECT_OUT - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_CREATE_DB - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_DAEMON - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_DEBUG - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_DELAYED_INSERT - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_DROP_DB - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_FIELD_LIST - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_INIT_DB - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_PING - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_PROCESS_INFO - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_PROCESS_KILL - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_QUERY - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_QUIT - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_REFRESH - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_REGISTER_SLAVE - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_SET_OPTION - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_SHUTDOWN - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_SLEEP - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STATISTICS - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_CLOSE - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_EXECUTE - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_FETCH - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_PREPARE - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_RESET - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_STMT_SEND_LONG_DATA - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_TABLE_DUMP - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COM_TIME - 类 net.neoremind.fountain.util.CommandTypeConstant 中的静态变量
 
COMMA - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
逗号
CommandPacket - net.neoremind.fountain.packet 中的 类
执行sql指令的命令包
CommandPacket() - 类 net.neoremind.fountain.packet.CommandPacket 的构造方法
 
CommandTypeConstant - net.neoremind.fountain.util 中的 类
MySQL命名定义字典
CommandTypeConstant() - 类 net.neoremind.fountain.util.CommandTypeConstant 的构造方法
 
conf - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的变量
数据源基础配置
configCharset(String) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convert2Pb(ChangeDataSet) - 类 net.neoremind.fountain.changedata.pb.ProtoUtils 中的静态方法
转化ChangeDataSet成pb格式
convertByteArray2String(byte[]) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convertByteArray2String(byte[], String) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convertLengthCodedLength(ByteBuffer) - 类 net.neoremind.fountain.util.MysqlValueHelper 中的静态方法
 
convertLittleEndianLong(ByteBuffer, int) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convertLittleEndianLongByteArray2BigInteger(byte[]) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convertLittleEndianUnsignedInt(ByteBuffer, int) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
convertValue(Object, JavaType) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
CREATE_FILE_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
createArrayList() - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
创建ArrayList实例
createArrayList(int) - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
创建ArrayList实例
createHashMap(int) - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
创建HashMap实例
createLinkedList() - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
创建LinkedList实例
createQuerySocket() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
创建一个用于查询的socket
createSyncPoint() - 类 net.neoremind.fountain.eventposition.LocalFileBinlogAndOffsetDisposeEventPosition 中的方法
 
createSyncPoint() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
构建SyncPoint对象,继承类可以override该方法
createSyncPoint() - 类 net.neoremind.fountain.eventposition.LocalFileGtIdSetDisposeEventPosition 中的方法
 
CRLF - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
currentDataSource - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的变量
记录当前选中的数据源

D

DASH - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
DatabusColBitmapFlag - net.neoremind.fountain.meta 中的 枚举
databus定义的列bitmap flag
DataErrorException - net.neoremind.fountain.exception 中的 异常
 
DataErrorException() - 异常 net.neoremind.fountain.exception.DataErrorException 的构造方法
 
DataErrorException(String) - 异常 net.neoremind.fountain.exception.DataErrorException 的构造方法
 
DataErrorException(String, Throwable) - 异常 net.neoremind.fountain.exception.DataErrorException 的构造方法
 
DATALINK - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, somtimes referred to as a type code, that identifies the generic SQL type DATALINK.
DatasourceChooseCallbackHandler<T> - net.neoremind.fountain.datasource 中的 接口
ha场景下选择数据源后初始化数据源或者读取数据的回调
datasourceChoosePolicy - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的变量
数据源选择策略
DatasourceChoosePolicy - net.neoremind.fountain.datasource 中的 接口
在ha场景中,选择备选datasource的策略
DatasourceConfigure - net.neoremind.fountain.datasource 中的 类
数据源的配置
DatasourceConfigure() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 的构造方法
 
DataSourceInvalidException - net.neoremind.fountain.exception 中的 异常
 
DataSourceInvalidException() - 异常 net.neoremind.fountain.exception.DataSourceInvalidException 的构造方法
 
DataSourceInvalidException(String) - 异常 net.neoremind.fountain.exception.DataSourceInvalidException 的构造方法
 
DataSourceInvalidException(String, Throwable) - 异常 net.neoremind.fountain.exception.DataSourceInvalidException 的构造方法
 
DATATYPE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
DataUnitDef - net.neoremind.fountain.changedata.pb 中的 类
 
DataUnitDef.ColumnMeta - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.ColumnMeta
DataUnitDef.ColumnMeta.Builder - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.ColumnMeta
DataUnitDef.ColumnMetaOrBuilder - net.neoremind.fountain.changedata.pb 中的 接口
 
DataUnitDef.ColumnValue - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.ColumnValue
DataUnitDef.ColumnValue.Builder - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.ColumnValue
DataUnitDef.ColumnValue.ValueOneofCase - net.neoremind.fountain.changedata.pb 中的 枚举
 
DataUnitDef.ColumnValueOrBuilder - net.neoremind.fountain.changedata.pb 中的 接口
 
DataUnitDef.DataSet - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.DataSet
DataUnitDef.DataSet.Builder - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.DataSet
DataUnitDef.DataSetOrBuilder - net.neoremind.fountain.changedata.pb 中的 接口
 
DataUnitDef.RowData - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.RowData
DataUnitDef.RowData.Builder - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.RowData
DataUnitDef.RowDataOrBuilder - net.neoremind.fountain.changedata.pb 中的 接口
 
DataUnitDef.TableData - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.TableData
DataUnitDef.TableData.Builder - net.neoremind.fountain.changedata.pb 中的 类
Protobuf type com.baidu.fountain.changedata.pb.TableData
DataUnitDef.TableDataOrBuilder - net.neoremind.fountain.changedata.pb 中的 接口
 
DATE - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type DATE.
dbName - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
dbName - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
dbNameLength - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
dbNameLength - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
DECIMAL - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type DECIMAL.
DelayGroupIdDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
延迟一般一个、最多两个事务记录同步点,同步点必须是GroupIdSyncPoint
DelayGroupIdDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.DelayGroupIdDisposeEventPosition 的构造方法
 
DelayGtIdDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
不用延迟直接存储GtId,针对MySQL5.6本身会Server,fountain会传递自己的executed gtid set,以GtIdSet中的GtId.intervalStart和 GtId.intervalEnd表示,这里面GtId.intervalEnd是个开区间,最后一个点会重新下发。
DelayGtIdDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.DelayGtIdDisposeEventPosition 的构造方法
 
delegate - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 中的变量
 
DELETE_FILE_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
DELETE_ROWS_EVENT_V0 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
DELETE_ROWS_EVENT_V1 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
DELETE_ROWS_EVENT_V2 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
destroy() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
DisposeEventPosition - net.neoremind.fountain.eventposition 中的 接口
保存最后一个处理的mysql 事件所对应的gt id,重启或者数据源崩溃时从该id继续恢复数据读取。
DisposeEventPositionBridge - net.neoremind.fountain.eventposition 中的 接口
用于fountain-producer和fountain-consumer部署在同一个jvm中的场景,此时需要消费者来记录 当前已经成功处理的消息的gt id,使用该类来解耦生产者和消费者
DisposeEventPositionBridgeImpl - net.neoremind.fountain.eventposition 中的 类
实现DisposeEventPositionBridge接口。
DisposeEventPositionBridgeImpl() - 类 net.neoremind.fountain.eventposition.DisposeEventPositionBridgeImpl 的构造方法
 
DISTINCT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type DISTINCT.
doCallback(T) - 接口 net.neoremind.fountain.datasource.DatasourceChooseCallbackHandler 中的方法
对数据源进行初始化或者其他操作
doHaTask(String, String, TaskExcutor<E>) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
在ha的环境中封装一批类似的业务逻辑,比如执行sql,查询表的元数据等,本身是一种策略模式,被用于模板方法中
doHaTask(String, String, TaskExcutor<T>) - 类 net.neoremind.fountain.datasource.HANormalMysqlDataSource 中的方法
 
DOLLAR_LEFT_BRACE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
DOLLARS - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
美元符
DOT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
点号
DOTDOT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
点点
DOUBLE - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type DOUBLE.
DOUBLE_QUOTE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
双引号
DOUBLEVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 

E

EMPTY - 接口 net.neoremind.fountain.meta.MetaDefine.KEY_FLAG 中的静态变量
该列值的可以重复,表示该列没有索引,或者是一个非唯一的复合索引的非前导列
EMPTY - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
空
encode(ByteArrayOutputStream) - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
从库把自己的gtid_executed发送给主,这个数据结构封装了写socket stream的格式。
encryptBySHA(byte[], byte[]) - 类 net.neoremind.fountain.util.Encrypter 中的静态方法
算法如下:
SHA1( password ) XOR SHA1( "20-bytes random data from server" SHA1( SHA1( password ) ) )
Encrypter - net.neoremind.fountain.util 中的 类
验证方法
Encrypter() - 类 net.neoremind.fountain.util.Encrypter 的构造方法
 
EOF_FLAG - 类 net.neoremind.fountain.packet.EOFPacket 中的静态变量
 
EOFException - net.neoremind.fountain.exception 中的 异常
 
EOFException() - 异常 net.neoremind.fountain.exception.EOFException 的构造方法
 
EOFException(String) - 异常 net.neoremind.fountain.exception.EOFException 的构造方法
 
EOFException(String, Throwable) - 异常 net.neoremind.fountain.exception.EOFException 的构造方法
 
EOFPacket - net.neoremind.fountain.packet 中的 类
mysql eof packet
EOFPacket() - 类 net.neoremind.fountain.packet.EOFPacket 的构造方法
 
EQUALS - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
等号
ERROR_FLAG - 类 net.neoremind.fountain.packet.ErrorPacket 中的静态变量
Error packet第一个字节为0xff
errorCode - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
ErrorPacket - net.neoremind.fountain.packet 中的 类
mysql error packet

错误信息和错误代码请参考: ErrorPacket() - 类 net.neoremind.fountain.packet.ErrorPacket 的构造方法

 
EventCallback<T extends BaseLogEvent> - net.neoremind.fountain.support 中的 接口
BaseLogEvent处理的回调接口
EventConstant - net.neoremind.fountain.rowbaselog.event 中的 类
 
EventConstant() - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 的构造方法
 
eventDataFixedPartLength - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的变量
(string.EOF) a array indexed by Binlog Event Type - 1 to extract the length of the event specific header.
EventHeader - net.neoremind.fountain.event 中的 接口
 
eventHeaderLength - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的变量
1 byte.
EventListener - net.neoremind.fountain.support 中的 类
binlog event的回调监听器
EventPositionExtender - net.neoremind.fountain.eventposition 中的 接口
扩展已经同步的binlog的位置信息, 一般来讲需要存储binlog event的global transaction id,在使用原生row base binlog 的情况下,需要根据global transaction id转化为binlog file name和position。
EXCLAMATION_MARK - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
EXEC_LOAD_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
execute(String, MysqlDataSource) - 接口 net.neoremind.fountain.datasource.TaskExcutor 中的方法
在指定的数据源上执行一个命令,命令是可枚举的,在调用 doHaTask方法时确定其业务逻辑
EXECUTE_LOAD_QUERY_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
executeTime - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
extend(SyncPoint, MysqlDataSource) - 接口 net.neoremind.fountain.eventposition.EventPositionExtender 中的方法
从给定的数据源中读取与global transaction id有关的信息,比如binlog file name和position用于同步

F

factory(ColumnTypeEnum) - 接口 net.neoremind.fountain.event.ColumnDataParserFactory 中的方法
根据列的类型生成ColumnDataParser实例
factory() - 类 net.neoremind.fountain.eventposition.factory.BaiduGroupIdSyncPointFactory 中的方法
 
factory() - 类 net.neoremind.fountain.eventposition.factory.BinlogAndOffsetSyncPointFactory 中的方法
 
factory() - 类 net.neoremind.fountain.eventposition.factory.GtIdSyncPointFactory 中的方法
 
factory() - 接口 net.neoremind.fountain.eventposition.factory.SyncPointFactory 中的方法
生成SyncPoint
factory() - 类 net.neoremind.fountain.support.EventListener 中的静态方法
静态构造方法
factory() - 类 net.neoremind.fountain.support.TrxContext 中的静态方法
静态构造方法
FieldDescriptionPacket - net.neoremind.fountain.packet 中的 类
mysql sql field 描述包
FieldDescriptionPacket() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 的构造方法
 
fillBitmap(BitSet, ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
fillBitMap(byte[], Position, int, BitSet) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
解析位图
FLOAT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type FLOAT.
FLOATVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
FORMAT_DESCRIPTION_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
FormatDescriptionEvent - net.neoremind.fountain.rowbaselog.event 中的 类
binlog format描述事件,在v4版本的binlog文件中,第一个event就是FORMAT_DESCRIPTION_EVENT, 它描述了接下来其他的event是如何layed out的。
FormatDescriptionEvent(BinlogEventHeader, FormatInfoCallback) - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 的构造方法
 
FormatDescriptionEventCallback - net.neoremind.fountain.support 中的 类
FormatDescriptionEvent事件回调器
FormatDescriptionEventCallback() - 类 net.neoremind.fountain.support.FormatDescriptionEventCallback 的构造方法
 
FormatInfo - net.neoremind.fountain.rowbaselog.event 中的 接口
FormatDescriptionEvent中处理接下来event的头length
FormatInfoCallback - net.neoremind.fountain.rowbaselog.event 中的 接口
 
FountainJavaTypes - net.neoremind.fountain.event.data 中的 类
 
FountainJavaTypes() - 类 net.neoremind.fountain.event.data.FountainJavaTypes 的构造方法
 
FountainMQ - net.neoremind.fountain.common.mq 中的 接口
fountain需要的内存mq的抽象描述。
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
fromBytes(byte[]) - 接口 net.neoremind.fountain.packet.ParsablePacket 中的方法
解析bytes数据包
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.QueryCommandPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.ResultSetPacket 中的方法
 
fromBytes(byte[]) - 类 net.neoremind.fountain.packet.RowValuePacket 中的方法
 
fromString(String) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
由string转化为对象
Function<F,T> - net.neoremind.fountain.util 中的 接口
Determines an output value based on an input value.

G

GB2312 - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
GBK - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
getAffectRows() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
getAfterColumnList() - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
getAfterValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValues(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesCount() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilder(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getAfterValuesOrBuilderList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
getBeforeColumnList() - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
getBeforeValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValues(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesCount() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilder(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBeforeValuesOrBuilderList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
getBinlogFileName() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getBinlogName() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
getBirthTime() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getBoolValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool boolValue = 5;
getBoolValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bool boolValue = 5;
getBoolValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bool boolValue = 5;
getBuffer(Socket, int) - 类 net.neoremind.fountain.util.SocketHelper 中的静态方法
从socket中读取指定长度的数据,该方法会堵塞调用线程直到指定长度的数据完全被获取
getByteArrayValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bytes byteArrayValue = 7;
getByteArrayValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bytes byteArrayValue = 7;
getByteArrayValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bytes byteArrayValue = 7;
getBytesFromObject(Serializable) - 类 net.neoremind.fountain.util.ObjectAccessUtil 中的静态方法
 
getCatalog() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getCharacter() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getCharset() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getCharset() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getCharsetNumber() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
getClassName() - 类 net.neoremind.fountain.pack.impl.NameUnpackClazResolver 中的方法
 
getClaz() - 类 net.neoremind.fountain.pack.impl.NameUnpackClazResolver 中的方法
 
getClaz() - 接口 net.neoremind.fountain.pack.UnpackClazResolver 中的方法
需要指定的class类型
getColumnAlias() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getColumnCount() - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 中的方法
 
getColumnMeta(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMeta(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMeta(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaByFullTableName(String) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
根据表的全名获取列的信息,表的全名比如beidou.cproplan
getColumnMetaCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaCount() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaList() - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
getColumnMetaOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaOrBuilder(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnMetaOrBuilderList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
getColumnName() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getColumnName() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getColumnType() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getCommand() - 类 net.neoremind.fountain.packet.CommandPacket 中的方法
 
getConf() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
getConnectTimeout() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getCurrBinlogPosition() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getCurrGtId() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getDatabaseName() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getDatabaseName() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
getDatabusColumnBitmap() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getDataLen() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
getDataSize() - 接口 net.neoremind.fountain.changedata.BinlogTraceable 中的方法
对象的size
getDataSize() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getDatasourceChoosePolicy() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
getDataType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required sint32 dataType = 1;
getDataType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required sint32 dataType = 1;
getDataType() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required sint32 dataType = 1;
getDbName() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getDecimal() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getDefaultExtra() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getDefaultInstance() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
getDefaultInstance() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
getDefaultInstance() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
getDefaultInstance() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
getDefaultInstance() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
getDefaultInstanceForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
getDefaultValue() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getDelegate() - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 中的方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的静态方法
 
getDescriptor() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
getDescriptorForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
getDescriptorForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
getDescriptorForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
getDescriptorForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
getDescriptorForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
getDisposeEventPosition(String) - 接口 net.neoremind.fountain.eventposition.DisposeEventPositionBridge 中的方法
消费者根据producerName获取DisposeEventPosition对象来记录gt id
getDisposeEventPosition(String) - 类 net.neoremind.fountain.eventposition.DisposeEventPositionBridgeImpl 中的方法
 
getDisposeEventPositionBridge() - 类 net.neoremind.fountain.eventposition.RegistableDisposeEventPosition 中的方法
 
getDoubleByLittleEndian(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取double,小端
getDoubleValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional double doubleValue = 1;
getDoubleValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional double doubleValue = 1;
getDoubleValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional double doubleValue = 1;
getEofFlag() - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
getErrorCode() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
getErrorFlag() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
getEventHeader() - 类 net.neoremind.fountain.event.BaseLogEvent 中的方法
 
getEventLength() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getExtra() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getExtra() - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 中的方法
 
getExtraData() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV2 中的方法
 
getExtraDataLen() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV2 中的方法
 
getExtraHeaders() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getExtraHeadersLength() - 接口 net.neoremind.fountain.rowbaselog.event.FormatInfo 中的方法
剩余的header length,一般是19,但是对于百度的MySQL,会是27,加入了8个byte的groupid
getFieldDescriptionList() - 类 net.neoremind.fountain.packet.ResultSetPacket 中的方法
 
getFieldValueList() - 类 net.neoremind.fountain.packet.RowValuePacket 中的方法
 
getFileExt() - 类 net.neoremind.fountain.eventposition.LocalFileBinlogAndOffsetDisposeEventPosition 中的方法
 
getFileExt() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
返回文件扩展名
getFileExt() - 类 net.neoremind.fountain.eventposition.LocalFileGtIdSetDisposeEventPosition 中的方法
 
getFixedBytes(ByteBuffer, int) - 类 net.neoremind.fountain.util.MysqlValueHelper 中的静态方法
 
getFixedBytes(byte[], Position, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取指定的固定长度字节
getFlags() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getFlags() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getFloatByLittleEndian(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取float,小端
getFloatValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional float floatValue = 2;
getFloatValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional float floatValue = 2;
getFloatValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional float floatValue = 2;
getFmtDescEvent() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getFullName() - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
getFullTableName() - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的方法
 
getGeneralColumnType() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getGroupId() - 接口 net.neoremind.fountain.event.EventHeader 中的方法
 
getGroupId() - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
getGroupId() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getGtId() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getGtId() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
optional sint64 gtId = 1;
getGtId() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
optional sint64 gtId = 1;
getGtId() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
optional sint64 gtId = 1;
getGtId() - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 中的方法
 
getGtIdList() - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
 
getGtIdSet() - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 中的方法
 
getHostName() - 类 net.neoremind.fountain.util.NetUtils 中的静态方法
 
getInitDelayMs() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
getInsertId() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
getInstanceName() - 接口 net.neoremind.fountain.changedata.BinlogTraceable 中的方法
生产者的实例
getInstanceName() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getInstanceName() - 类 net.neoremind.fountain.eventposition.RegistableDisposeEventPosition 中的方法
 
getIntByLittleEndian(byte[], Position, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
读取小端int
getIntervalEnd() - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
getIntervalStart() - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
getIntValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint32 intValue = 3;
getIntValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional sint32 intValue = 3;
getIntValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional sint32 intValue = 3;
getIpAddress() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
getIpAddress() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
getIpAddress() - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
获取当前数据源的ip地址
getIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isNull = 4;
getIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isNull = 4;
getIsNull() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isNull = 4;
getIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool isNull = 8;
getIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bool isNull = 8;
getIsNull() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bool isNull = 8;
getIsPrimay() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isPrimay = 3;
getIsPrimay() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isPrimay = 3;
getIsPrimay() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isPrimay = 3;
getIsUnsiged() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isUnsiged = 5;
getIsUnsiged() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isUnsiged = 5;
getIsUnsiged() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isUnsiged = 5;
getJavaType() - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
getKeyFlag() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getLength() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getLengthCodedBytes(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取lengthCode bytes
getLengthCodedLength(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取coded length
getLocalAddress() - 类 net.neoremind.fountain.util.NetUtils 中的静态方法
 
getLocalHostIP() - 类 net.neoremind.fountain.util.NetUtils 中的静态方法
 
getLogger() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
获取当前的logger对象
getLogger() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
获取当前实现的logger
getLogger() - 类 net.neoremind.fountain.datasource.HANormalMysqlDataSource 中的方法
 
getLogger() - 类 net.neoremind.fountain.eventposition.LocalFileBinlogAndOffsetDisposeEventPosition 中的方法
 
getLogger() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
返回记录日志的对象
getLogger() - 类 net.neoremind.fountain.eventposition.LocalFileGtIdSetDisposeEventPosition 中的方法
 
getLongByLittleEndian(byte[], Position, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
读取小端long
getLongValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint64 longValue = 4;
getLongValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional sint64 longValue = 4;
getLongValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional sint64 longValue = 4;
getMessage() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
getMessage() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
getMetaLen() - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的方法
 
getMetaValue() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getMysqlDataSourceList() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
getMysqlId() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
getMysqlPort() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getMysqlServer() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
getName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required string name = 2;
getName() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required string name = 2;
getName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
getName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
required string name = 1;
getName() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
required string name = 1;
getNameBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
getNameBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required string name = 2;
getNameBytes() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required string name = 2;
getNameBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
getNameBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
required string name = 1;
getNameBytes() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
required string name = 1;
getNetReadTimeout() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getNetWriteTimeout() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getNewSocket() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
创建一个新的socket连接,完成mysql握手和权限验证,并且后续建立network stream,后续使用
getNextBinlogPosition() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getNextPosition() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getNullFlag() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getNullTerminatedByte(ByteBuffer) - 类 net.neoremind.fountain.util.MysqlValueHelper 中的静态方法
 
getNullTerminatedByte(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
读取以null结束的数据
getNullTerminatedString(byte[], Position) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
获取以null结尾的string
getNumber() - 枚举 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.ValueOneofCase 中的方法
 
getObjectMapper() - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
getOffset() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
getOkflag() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
getOptype() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
required sint32 optype = 3;
getOptype() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
required sint32 optype = 3;
getOptype() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
required sint32 optype = 3;
getPacketLength() - 类 net.neoremind.fountain.packet.PacketHeader 中的方法
 
getPacketNumber() - 类 net.neoremind.fountain.packet.PacketHeader 中的方法
 
getParserForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
getParserForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
getParserForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
getParserForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
getParserForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
getPassword() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getPassword() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
getPeriodMs() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
getPointByHostAndPort(String, String, int) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
根据host或者ip和port获取MysqlSyncPoint对象,使用MysqlSyncPoint中的binlogname和offset来同步数据
getPointByHostAndPort(String, int) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
根据host和port获取MysqlSyncPoint对象,使用MysqlSyncPoint中的binlogname和offset来同步数据
getPort() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
getPort() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
getPort() - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
获取当前数据源的端口
getPosition() - 类 net.neoremind.fountain.packet.Position 中的方法
 
getPostHeaderLen(int) - 接口 net.neoremind.fountain.rowbaselog.event.FormatInfo 中的方法
post header 长度
getProtocolHeader(byte[]) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
解析协议头
getProtocolVersion() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getReceiveBufferSize() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getRequiredPermits(BinlogTraceable) - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的方法
从一个数据消息中获取需要权限的个数
getRequiredPermits(BinlogTraceable) - 类 net.neoremind.fountain.common.mq.MemFountainMQ 中的方法
 
getRequiredPermits(BinlogTraceable) - 类 net.neoremind.fountain.common.mq.MultiPermitsMemFountainMQ 中的方法
 
getRestOfScrambleBuff() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getRootPath() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
 
getRows(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRows(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRows(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsCount() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilder(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowsOrBuilderList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
getRowValueList() - 类 net.neoremind.fountain.packet.ResultSetPacket 中的方法
 
getScrambleBuff() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
获取password加密种子
getScrumbleBuff() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
getSeed() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getSendBufferSize() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getSendTime() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getSerializedSize() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
getSerializedSize() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
getSerializedSize() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
getSerializedSize() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
getSerializedSize() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
getServerCapabilities() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getServerCharsetNumber() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getServerId() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getServerStatus() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getServerStatus() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
getServerUUID() - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
getServerUUIDbyte() - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
getShortCharset() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getSid() - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 中的方法
 
getSid() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
getSoTimeout() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getSql() - 类 net.neoremind.fountain.packet.CommandPacket 中的方法
 
getSqlstate() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
getSqlstateMarker() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
getSqlType() - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
getSrcDbHost() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getStatusFlags() - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
getStringValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
getStringValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional string stringValue = 6;
getStringValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional string stringValue = 6;
getStringValueBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
getStringValueBytes() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional string stringValue = 6;
getStringValueBytes() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional string stringValue = 6;
getSyncPoint() - 接口 net.neoremind.fountain.changedata.BinlogTraceable 中的方法
同步点
getSyncPoint() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getSyncPointGroup() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
 
getTableAlias() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getTableData() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getTableDef() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
getTableId() - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
getTableMapEvent(long) - 类 net.neoremind.fountain.event.util.TableEventCache 中的方法
 
getTableMapEvent(long) - 接口 net.neoremind.fountain.rowbaselog.event.TableInfoCallback 中的方法
根据tableId获取缓存的TableMapEvent
getTableMeta(String, long) - 类 net.neoremind.fountain.meta.CachedTableMetaProvider 中的方法
 
getTableMeta(String, long) - 接口 net.neoremind.fountain.meta.TableMetaProvider 中的方法
根据给定的表的名称获取表的列信息元数据,由于表结构不经常变,所以表的元数据信息会被 缓存,但有时表结构也可能被修改,修改后需要重新获取元数据,有关表结构是否已经被修改 的信息由调用方来决定。
getTableMeta() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
getTableMeta(String, long, TableMapEvent.ColumnInfo[]) - 接口 net.neoremind.fountain.rowbaselog.event.TableInfoCallback 中的方法
根据表名和tableid获取meta信息
getTableName() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getTableNameList() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
获取所有的表名,表名为全名,比如beidou.cproplan
getTableRowDatasByFullTableName(String) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
根据表的全名获取表的数据,表的全名比如beidou.cproplan
getTables(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTables(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTables(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesCount() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesCount() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilder(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilder(int) - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilderList() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getTablesOrBuilderList() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
getThreadId() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getTimestamp() - 接口 net.neoremind.fountain.event.EventHeader 中的方法
 
getTimestamp() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getTrxContext() - 类 net.neoremind.fountain.support.ThreadHolder 中的静态方法
获取事务上下文
getTryInterval() - 类 net.neoremind.fountain.datasource.RoundRobinDatasourceChoosePolicy 中的方法
 
getType() - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
getTypeCode() - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
getTypeEnum() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
getTypeEnumByText(String) - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的静态方法
根据以string描述的类型获取枚举类型值
getTypeEnumByValue(int) - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的静态方法
根据枚举的value获取相应的枚举值
getTypeName() - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的方法
 
getTypeString(int) - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态方法
 
getTypeValue() - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的方法
 
getUnknownFields() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
getUnknownFields() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
getUnknownFields() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
getUnknownFields() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
getUnknownFields() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
getUnpackClazResolver() - 类 net.neoremind.fountain.pack.impl.JsonUnpackProtocol 中的方法
 
getUnsignedIntByLittleEndian(byte[], Position, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
读取无符号int,使用long类型接收
getUnsignedLongByLittleEndian(byte[], Position, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
读取无符号long,使用BigInteger接收
getUserName() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getUsername() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
getValue() - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
getValue() - 枚举 net.neoremind.fountain.meta.DatabusColBitmapFlag 中的方法
 
getValue() - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.GtIdMode 中的方法
 
getValue() - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.RowFormat 中的方法
 
getValueOneofCase() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
getValueOneofCase() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
getVersion() - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
getWaitTimeout() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
getWarningCount() - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
getWarningStatus() - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
GroupIdSyncPoint - net.neoremind.fountain.eventposition 中的 接口
支持groupId SyncPoint
GtId - net.neoremind.fountain.eventposition 中的 类
MySQL 5.6版本之后使用的Global Transaction Id,简称为GtId。
GtId() - 类 net.neoremind.fountain.eventposition.GtId 的构造方法
默认构造方法
GtId(String, long, long) - 类 net.neoremind.fountain.eventposition.GtId 的构造方法
构造方法
GTID_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
GTID_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态变量
 
GtidEvent - net.neoremind.fountain.rowbaselog.event 中的 类
GTID event
对于MySQL5.6.5及之后的版本,如果GTID_MODE = ON, 每个事务的replicate都会前置一个type code=EventConstant.GTID_EVENT的事件。
GtidEvent(BinlogEventHeader) - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 的构造方法
构造方法
GtIdEventCallback - net.neoremind.fountain.support 中的 类
GtidEvent事件回调器
GtIdEventCallback() - 类 net.neoremind.fountain.support.GtIdEventCallback 的构造方法
 
GtIdInvalidException - net.neoremind.fountain.exception 中的 异常
GtId非法的运行时异常
GtIdInvalidException() - 异常 net.neoremind.fountain.exception.GtIdInvalidException 的构造方法
 
GtIdInvalidException(String) - 异常 net.neoremind.fountain.exception.GtIdInvalidException 的构造方法
 
GtIdInvalidException(String, Throwable) - 异常 net.neoremind.fountain.exception.GtIdInvalidException 的构造方法
 
GtIdInvalidException(Throwable) - 异常 net.neoremind.fountain.exception.GtIdInvalidException 的构造方法
 
GtIdSet - net.neoremind.fountain.eventposition 中的 类
MySQL 5.6之后引入Gtid_set数据结构,目的是为了轻量级的记录大量的连续全局事务ID, 比如已经在从数据库上执行的全局事务ID, 或者主库上正在运行的全局事务ID。
GtIdSet() - 类 net.neoremind.fountain.eventposition.GtIdSet 的构造方法
 
GtIdSyncPoint - net.neoremind.fountain.eventposition 中的 类
描述MySQL5.6版本的gtid同步点
GtIdSyncPoint() - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 的构造方法
无参数构造方法
GtIdSyncPoint(GtIdSet) - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 的构造方法
构造方法 gtid集合
GtIdSyncPointFactory - net.neoremind.fountain.eventposition.factory 中的 类
 
GtIdSyncPointFactory() - 类 net.neoremind.fountain.eventposition.factory.GtIdSyncPointFactory 的构造方法
 

H

HalfDataSocketTimeoutException - net.neoremind.fountain.exception 中的 异常
当接收event的一部部分数据后socket出现异常时抛出该异常
HalfDataSocketTimeoutException() - 异常 net.neoremind.fountain.exception.HalfDataSocketTimeoutException 的构造方法
 
handle(T, TrxContext) - 接口 net.neoremind.fountain.support.EventCallback 中的方法
在当前ThreadLocal上下文中处理某个event,一般的操作是根据event传输数据的内容设置context一些上下文
handle(BaseLogEvent, TrxContext) - 类 net.neoremind.fountain.support.EventListener 中的方法
当fountain接收到某个binlog event时候会根据具体类型,找到回调器,然后调用,一般会设置一些变量信息到TrxContext中
handle(FormatDescriptionEvent, TrxContext) - 类 net.neoremind.fountain.support.FormatDescriptionEventCallback 中的方法
 
handle(GtidEvent, TrxContext) - 类 net.neoremind.fountain.support.GtIdEventCallback 中的方法
 
handle(QueryLogEvent, TrxContext) - 类 net.neoremind.fountain.support.QueryLogEventCallback 中的方法
 
handle(RotateEvent, TrxContext) - 类 net.neoremind.fountain.support.RotateEventCallback 中的方法
 
handle(T, TrxContext) - 类 net.neoremind.fountain.support.RowsLogEventCallback 中的方法
 
handle(XidLogEvent, TrxContext) - 类 net.neoremind.fountain.support.XidLogEventCallback 中的方法
 
handleEvent(BaseLogEvent) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
HandshakePacket - net.neoremind.fountain.packet 中的 类
mysql登录验证握手包
HandshakePacket() - 类 net.neoremind.fountain.packet.HandshakePacket 的构造方法
 
HANormalMysqlDataSource - net.neoremind.fountain.datasource 中的 类
普通的非mysql binlog数据源的ha实现,该类暂时不会使用.
HANormalMysqlDataSource() - 类 net.neoremind.fountain.datasource.HANormalMysqlDataSource 的构造方法
 
hasBoolValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool boolValue = 5;
hasBoolValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bool boolValue = 5;
hasBoolValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bool boolValue = 5;
hasByteArrayValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bytes byteArrayValue = 7;
hasByteArrayValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bytes byteArrayValue = 7;
hasByteArrayValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bytes byteArrayValue = 7;
hasDataType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required sint32 dataType = 1;
hasDataType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required sint32 dataType = 1;
hasDataType() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required sint32 dataType = 1;
hasDoubleValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional double doubleValue = 1;
hasDoubleValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional double doubleValue = 1;
hasDoubleValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional double doubleValue = 1;
hasFloatValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional float floatValue = 2;
hasFloatValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional float floatValue = 2;
hasFloatValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional float floatValue = 2;
hasGtId() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
optional sint64 gtId = 1;
hasGtId() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
optional sint64 gtId = 1;
hasGtId() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSetOrBuilder 中的方法
optional sint64 gtId = 1;
HASH - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
#号
hasIntValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint32 intValue = 3;
hasIntValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional sint32 intValue = 3;
hasIntValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional sint32 intValue = 3;
hasIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isNull = 4;
hasIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isNull = 4;
hasIsNull() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isNull = 4;
hasIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool isNull = 8;
hasIsNull() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional bool isNull = 8;
hasIsNull() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional bool isNull = 8;
hasIsPrimay() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isPrimay = 3;
hasIsPrimay() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isPrimay = 3;
hasIsPrimay() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isPrimay = 3;
hasIsUnsiged() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isUnsiged = 5;
hasIsUnsiged() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required bool isUnsiged = 5;
hasIsUnsiged() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required bool isUnsiged = 5;
hasLongValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint64 longValue = 4;
hasLongValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional sint64 longValue = 4;
hasLongValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional sint64 longValue = 4;
hasName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
hasName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
required string name = 2;
hasName() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMetaOrBuilder 中的方法
required string name = 2;
hasName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
hasName() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
required string name = 1;
hasName() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.TableDataOrBuilder 中的方法
required string name = 1;
hasOptype() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
required sint32 optype = 3;
hasOptype() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
required sint32 optype = 3;
hasOptype() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.RowDataOrBuilder 中的方法
required sint32 optype = 3;
hasStringValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
hasStringValue() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
optional string stringValue = 6;
hasStringValue() - 接口 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValueOrBuilder 中的方法
optional string stringValue = 6;
HAT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
HEARTBEAT_LOG_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
HTML_AMP - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
HTML_GT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
HTML_LT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
HTML_NBSP - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
HTML_QUOTE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 

I

IGNORABLE_LOG_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
INCIDENT_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
increase() - 类 net.neoremind.fountain.packet.Position 中的方法
 
increase(int) - 类 net.neoremind.fountain.packet.Position 中的方法
 
INFO_SEP - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的静态变量
 
INFO_SEP - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的静态变量
 
init() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
初始化
init() - 类 net.neoremind.fountain.pack.impl.NameUnpackClazResolver 中的方法
初始化方法,spring构建对象时执行,需要配置在init-method中
insertId - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
INTEGER - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type INTEGER.
INTEGER_32_MAX_VALUE - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
internalGetFieldAccessorTable() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
INTVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
INTVAR_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
InvalidUnpackType - net.neoremind.fountain.pack.impl 中的 异常
解包失败异常
InvalidUnpackType() - 异常 net.neoremind.fountain.pack.impl.InvalidUnpackType 的构造方法
 
isChecksumSupport() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
isDelete() - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
isDelete() - 接口 net.neoremind.fountain.event.RowEvent 中的方法
 
isDelete(byte) - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态方法
 
isDelete() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
isEmpty(Collection<?>) - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
判断Collection是否为null或空数组[]。
isEmpty(Collection<?>) - 类 net.neoremind.fountain.util.CollectionUtils 中的静态方法
collection 是否为空
isEOFPacket(byte[]) - 类 net.neoremind.fountain.packet.EOFPacket 中的静态方法
给定的数据是否是eof数据包
isErrorPacket(byte[]) - 类 net.neoremind.fountain.packet.ErrorPacket 中的静态方法
给定的数据包是否为error数据包
isExceedMaxCapacity(int) - 接口 net.neoremind.fountain.common.mq.FountainMQ 中的方法
是否超过队列的最大容量
isExceedMaxCapacity(int) - 类 net.neoremind.fountain.common.mq.MemFountainMQ 中的方法
 
isExceedMaxCapacity(int) - 类 net.neoremind.fountain.common.mq.MultiPermitsMemFountainMQ 中的方法
 
isFromDatabus() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
isInitialized() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
isInsert() - 接口 net.neoremind.fountain.event.RowEvent 中的方法
 
isInsert(byte) - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态方法
 
isInsert() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
isNull() - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
ISNULL_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
ISNULL_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
isNullable() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
ISO_8859_1 - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
isOpen() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
isOpen() - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
数据源是否已经处于打开状态
ISPRIMAY_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
isSame(SyncPoint) - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
isSame(SyncPoint) - 接口 net.neoremind.fountain.eventposition.GroupIdSyncPoint 中的方法
和指定的SyncPoint是否相同
isStringType(ColumnTypeEnum) - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的方法
是否是字符串类型
ISUNSIGED_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
isUnsigned() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
isUpdate() - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
isUpdate() - 接口 net.neoremind.fountain.event.RowEvent 中的方法
 
isUpdate(byte) - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态方法
 
isUpdate() - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
isWrite() - 类 net.neoremind.fountain.event.data.RowData 中的方法
 

J

JAVA_OBJECT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type JAVA_OBJECT.
json2GenericObject(String, TypeReference<T>) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
JSON串转换为Java泛型对象,可以是各种类型,此方法最为强大。
json2Object(String, Class<?>) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
Json字符串转Java对象
json2Object(String, JavaType) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
JsonPackProtocol - net.neoremind.fountain.pack.impl 中的 类
使用json进行打包
JsonPackProtocol() - 类 net.neoremind.fountain.pack.impl.JsonPackProtocol 的构造方法
 
JsonUnpackProtocol - net.neoremind.fountain.pack.impl 中的 类
使用json协议进行解包
JsonUnpackProtocol() - 类 net.neoremind.fountain.pack.impl.JsonUnpackProtocol 的构造方法
 
JsonUtils - net.neoremind.fountain.util 中的 类
JSON工具类
JsonUtils() - 类 net.neoremind.fountain.util.JsonUtils 的构造方法
 

L

LEFT_BRACE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
左大括号
LEFT_BRACKET - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
左中括号
LEFT_CHEV - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
LEFT_PARENTHESES - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
左小括号
LEFT_SQ_BRACKET - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
length() - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
SID block的长度,按照这个计算: 注意,这里只支持1个interval的情况。
LengthEncodedIntegerEOFExp - net.neoremind.fountain.exception 中的 异常
 
LengthEncodedIntegerEOFExp() - 异常 net.neoremind.fountain.exception.LengthEncodedIntegerEOFExp 的构造方法
 
LengthEncodedIntegerErrExp - net.neoremind.fountain.exception 中的 异常
 
LengthEncodedIntegerErrExp() - 异常 net.neoremind.fountain.exception.LengthEncodedIntegerErrExp 的构造方法
 
LengthEncodedIntegerNullExp - net.neoremind.fountain.exception 中的 异常
 
LengthEncodedIntegerNullExp() - 异常 net.neoremind.fountain.exception.LengthEncodedIntegerNullExp 的构造方法
 
limitSize - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的变量
队列容量上限
LOAD_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
loadSyncPoint() - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 中的方法
 
loadSyncPoint() - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
这里简化下从prev中获取
loadSyncPoint() - 接口 net.neoremind.fountain.eventposition.DisposeEventPosition 中的方法
加载同步点
loadSyncPoint() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
 
LocalFileBinlogAndOffsetDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
保存BinlogAndOffsetSyncPoint 类型syncpoint的实现
LocalFileBinlogAndOffsetDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.LocalFileBinlogAndOffsetDisposeEventPosition 的构造方法
 
LocalFileBinlogAndOffsetDisposeEventPosition(String) - 类 net.neoremind.fountain.eventposition.LocalFileBinlogAndOffsetDisposeEventPosition 的构造方法
 
LocalFileDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
采用本地文件来记录gt id的DisposeEventPosition 接口实现
LocalFileDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 的构造方法
 
LocalFileDisposeEventPosition(String) - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 的构造方法
 
LocalFileGtIdSetDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
保存GtIdSyncPoint 类型syncpoint的实现
LocalFileGtIdSetDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.LocalFileGtIdSetDisposeEventPosition 的构造方法
 
LocalFileGtIdSetDisposeEventPosition(String) - 类 net.neoremind.fountain.eventposition.LocalFileGtIdSetDisposeEventPosition 的构造方法
 
LOCALHOST - 类 net.neoremind.fountain.util.NetUtils 中的静态变量
 
logError(Exception) - 接口 net.neoremind.fountain.datasource.DatasourceChooseCallbackHandler 中的方法
记录异常信息
LONGNVARCHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type LONGNVARCHAR.
LONGVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
LONGVARBINARY - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type LONGVARBINARY.
LONGVARCHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type LONGVARCHAR.

M

main(String[]) - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的静态方法
 
MAX_PACKET_LENGTH - 类 net.neoremind.fountain.util.MysqlCommonConstants 中的静态变量
客户端和服务端交换的Packet的最大字节数,即16MB
MAX_PORT - 类 net.neoremind.fountain.util.NetUtils 中的静态变量
 
MEDIUMINT_24_MAX_VALUE - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
MemFountainMQ - net.neoremind.fountain.common.mq 中的 类
FountainMQ缺省实现,每个放入队列的对象 占用队列容量数为1

封装BlockingQueue,必须有界,这是为了防止内存oom

MemFountainMQ(int) - 类 net.neoremind.fountain.common.mq.MemFountainMQ 的构造方法
 
mergeFrom(Message) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
mergeFrom(DataUnitDef.ColumnMeta) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
 
mergeFrom(Message) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
mergeFrom(DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
 
mergeFrom(Message) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
mergeFrom(DataUnitDef.DataSet) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
 
mergeFrom(Message) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
mergeFrom(DataUnitDef.RowData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
 
mergeFrom(Message) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
mergeFrom(DataUnitDef.TableData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
mergeFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
 
message - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
meta - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent.ColumnInfo 中的变量
 
MetaDefine - net.neoremind.fountain.meta 中的 类
数据库原信息定义
MetaDefine() - 类 net.neoremind.fountain.meta.MetaDefine 的构造方法
 
MetaDefine.KEY_FLAG - net.neoremind.fountain.meta 中的 接口
show full fields from TABLE命令中的索引Key列的定义
MetaDefine.NOT_NULL_FLAG - net.neoremind.fountain.meta 中的 接口
show full fields from TABLE命令中的索引Null列的定义
MultiPermitsMemFountainMQ - net.neoremind.fountain.common.mq 中的 类
每个数据消息占用多个队列容量的队列。
MultiPermitsMemFountainMQ(int) - 类 net.neoremind.fountain.common.mq.MultiPermitsMemFountainMQ 的构造方法
构造方法
MULTIPLE_KEY - 接口 net.neoremind.fountain.meta.MetaDefine.KEY_FLAG 中的静态变量
列值可重复

该列是一个非唯一索引的前导列(第一列)或者是一个唯一性索引的组成部分,可以含有空值NULL

MYSQL_TYPE_BIT - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_BLOB - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_DATE - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_DATETIME - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_DATETIME2 - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_DECIMAL - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_DOUBLE - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_ENUM - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_FLOAT - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_GEOMETRY - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_INT24 - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_LONG - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_LONG_BLOB - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_LONGLONG - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_MEDIUM_BLOB - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_NEWDATE - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_NEWDECIMAL - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_NULL - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_SET - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_SHORT - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_STRING - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TIME - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TIME2 - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TIMESTAMP - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TIMESTAMP2 - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TINY - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_TINY_BLOB - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_VAR_STRING - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_VARCHAR - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MYSQL_TYPE_YEAR - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 中的静态变量
已过时。  
MysqlCommonConstants - net.neoremind.fountain.util 中的 类
MySQL默认的一些静态变量
MysqlCommonConstants() - 类 net.neoremind.fountain.util.MysqlCommonConstants 的构造方法
 
MysqlCommonConstants.GtIdMode - net.neoremind.fountain.util 中的 枚举
GtId Mode状态 ON OFF
MysqlCommonConstants.RowFormat - net.neoremind.fountain.util 中的 枚举
MySQL binlog复制的格式 ROW STATEMENT MIXED
MysqlDataSource - net.neoremind.fountain.datasource 中的 接口
抽象描述mysql的数据源,包括本地binlog, rowbase binlog,databus等
mysqlDataSourceList - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的变量
备选的数据源列表
MysqlPacket - net.neoremind.fountain.packet 中的 类
mysql packet抽象
MysqlPacket() - 类 net.neoremind.fountain.packet.MysqlPacket 的构造方法
 
MysqlTypeConstant - net.neoremind.fountain.event.constant 中的 类
已过时。 
MysqlTypeConstant() - 类 net.neoremind.fountain.event.constant.MysqlTypeConstant 的构造方法
已过时。  
MysqlValueHelper - net.neoremind.fountain.util 中的 类
 

N

NAME_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
NAME_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态变量
 
NameUnpackClazResolver - net.neoremind.fountain.pack.impl 中的 类
通过给定的class的fullname给出解包时需要的class
NameUnpackClazResolver() - 类 net.neoremind.fountain.pack.impl.NameUnpackClazResolver 的构造方法
 
NCHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type NCHAR
NCLOB - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type NCLOB.
net.neoremind.fountain.changedata - 软件包 net.neoremind.fountain.changedata
 
net.neoremind.fountain.changedata.pb - 软件包 net.neoremind.fountain.changedata.pb
 
net.neoremind.fountain.common.mq - 软件包 net.neoremind.fountain.common.mq
 
net.neoremind.fountain.datasource - 软件包 net.neoremind.fountain.datasource
 
net.neoremind.fountain.event - 软件包 net.neoremind.fountain.event
 
net.neoremind.fountain.event.constant - 软件包 net.neoremind.fountain.event.constant
 
net.neoremind.fountain.event.data - 软件包 net.neoremind.fountain.event.data
 
net.neoremind.fountain.event.util - 软件包 net.neoremind.fountain.event.util
 
net.neoremind.fountain.eventposition - 软件包 net.neoremind.fountain.eventposition
 
net.neoremind.fountain.eventposition.factory - 软件包 net.neoremind.fountain.eventposition.factory
 
net.neoremind.fountain.exception - 软件包 net.neoremind.fountain.exception
 
net.neoremind.fountain.meta - 软件包 net.neoremind.fountain.meta
 
net.neoremind.fountain.pack - 软件包 net.neoremind.fountain.pack
 
net.neoremind.fountain.pack.impl - 软件包 net.neoremind.fountain.pack.impl
 
net.neoremind.fountain.packet - 软件包 net.neoremind.fountain.packet
 
net.neoremind.fountain.rowbaselog.event - 软件包 net.neoremind.fountain.rowbaselog.event
 
net.neoremind.fountain.support - 软件包 net.neoremind.fountain.support
 
net.neoremind.fountain.thread.annotaion - 软件包 net.neoremind.fountain.thread.annotaion
 
net.neoremind.fountain.util - 软件包 net.neoremind.fountain.util
 
NetUtils - net.neoremind.fountain.util 中的 类
ClassName: NetUtils
Function: 网络工具类
NEW_LOAD_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
newBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
newBuilder(DataUnitDef.ColumnMeta) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
newBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
newBuilder(DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
newBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
newBuilder(DataUnitDef.DataSet) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
newBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
newBuilder(DataUnitDef.RowData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
newBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
newBuilder(DataUnitDef.TableData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
newBuilderForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
newBuilderForType(GeneratedMessage.BuilderParent) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
newBuilderForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
newBuilderForType(GeneratedMessage.BuilderParent) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
newBuilderForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
newBuilderForType(GeneratedMessage.BuilderParent) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
newBuilderForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
newBuilderForType(GeneratedMessage.BuilderParent) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
newBuilderForType() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
newBuilderForType(GeneratedMessage.BuilderParent) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
NEWLINE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
换行符
nextLogEventPos - 类 net.neoremind.fountain.rowbaselog.event.RotateEvent 中的变量
下一个binlog事件的position
nextLogFileName - 类 net.neoremind.fountain.rowbaselog.event.RotateEvent 中的变量
下一个binglog文件名
NO - 接口 net.neoremind.fountain.meta.MetaDefine.NOT_NULL_FLAG 中的静态变量
不可为空
NonePackProtocol - net.neoremind.fountain.pack.impl 中的 类
不做任何处理直接返回,用于producer和consumer在同一jvm内的场景
NonePackProtocol() - 类 net.neoremind.fountain.pack.impl.NonePackProtocol 的构造方法
 
NoneUnpackProtocol - net.neoremind.fountain.pack.impl 中的 类
不做任何处理直接返回
NoneUnpackProtocol() - 类 net.neoremind.fountain.pack.impl.NoneUnpackProtocol 的构造方法
 
NORMAL_HEADER_LENGTH - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的静态变量
 
NULL - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language that identifies the generic SQL value NULL.
NULL_LENGTH - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
NULL_TERMINATED_STRING_DELIMITER - 类 net.neoremind.fountain.util.MysqlCommonConstants 中的静态变量
Strings that are terminated by a [00] byte.
NUMERIC - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type NUMERIC.
NVARCHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type NVARCHAR.

O

ObjectAccessUtil - net.neoremind.fountain.util 中的 类
 
ObjectAccessUtil() - 类 net.neoremind.fountain.util.ObjectAccessUtil 的构造方法
 
offerGroupId() - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
offerGroupId() - 接口 net.neoremind.fountain.eventposition.GroupIdSyncPoint 中的方法
获取groupId
okflag - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
OKPacket - net.neoremind.fountain.packet 中的 类
 
OKPacket() - 类 net.neoremind.fountain.packet.OKPacket 的构造方法
 
open() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
open() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
open() - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
打开一个数据源,用以读取数据
OPTYPE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态变量
 
OTHER - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language that indicates that the SQL type is database-specific and gets mapped to a Java object that can be accessed via the methods getObject and setObject.

P

pack(Object) - 类 net.neoremind.fountain.pack.impl.JsonPackProtocol 中的方法
 
pack(Object) - 类 net.neoremind.fountain.pack.impl.NonePackProtocol 中的方法
 
pack(Object) - 接口 net.neoremind.fountain.pack.PackProtocol 中的方法
将event对象打包成可以下发的对象,可能是json string,byte[]或其他方式
PacketHeader - net.neoremind.fountain.packet 中的 类
MySQL Packet header

每个MySQL数据包都是由的Header和Payload组成(包括Initial Handshake Packet在内的所有数据包)。

PacketHeader() - 类 net.neoremind.fountain.packet.PacketHeader 的构造方法
默认构造方法
PacketHeader(int, byte) - 类 net.neoremind.fountain.packet.PacketHeader 的构造方法
构造方法
PackProtocol - net.neoremind.fountain.pack 中的 接口
把一个java对象根据相应的协议打包,可能打包为bin,或者json,或者其他的\t分割文件
ParamErrorException - net.neoremind.fountain.exception 中的 异常
 
ParamErrorException() - 异常 net.neoremind.fountain.exception.ParamErrorException 的构造方法
 
ParamErrorException(String) - 异常 net.neoremind.fountain.exception.ParamErrorException 的构造方法
 
ParamErrorException(String, Throwable) - 异常 net.neoremind.fountain.exception.ParamErrorException 的构造方法
 
PARENTHESES - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
小括号
ParsablePacket - net.neoremind.fountain.packet 中的 接口
可解析的mysql数据包
parse(ByteBuffer, ColumnData, ColumnMeta) - 接口 net.neoremind.fountain.event.ColumnDataParser 中的方法
由byte[]数据根据协议解析出字段的元数据和字段数据
parse(byte[]) - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
parse(byte[]) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
 
parse(byte[]) - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 中的方法
 
parse(byte[]) - 接口 net.neoremind.fountain.eventposition.SyncPoint 中的方法
转换数组为同步点对象
parseBody(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
parseBody(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV1 中的方法
 
parseColumnsOfRow(ByteBuffer, TableMapEvent) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.event.BaseLogEvent 中的方法
解析二进制数据填充event属性数据
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RotateEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.StopEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.UnkownBinlogEvent 中的方法
 
parseData(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.XidLogEvent 中的方法
 
parseDelimitedFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseDelimitedFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseDelimitedFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseDelimitedFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseDelimitedFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseDelimitedFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(ByteString, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(byte[]) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(byte[], ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(CodedInputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态方法
 
parseFrom(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(ByteString, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(byte[]) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(byte[], ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(CodedInputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态方法
 
parseFrom(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(ByteString, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(byte[]) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(byte[], ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(CodedInputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态方法
 
parseFrom(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(ByteString, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(byte[]) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(byte[], ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(CodedInputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态方法
 
parseFrom(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(ByteString, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(byte[]) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(byte[], ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(InputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(InputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(CodedInputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseFrom(CodedInputStream, ExtensionRegistryLite) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态方法
 
parseHeader(ByteBuffer) - 接口 net.neoremind.fountain.event.EventHeader 中的方法
 
parseHeader(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
parseHeader(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
parseHeader(ByteBuffer) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV2 中的方法
 
PARSER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的静态变量
 
PARSER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
PARSER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态变量
 
PARSER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的静态变量
 
PARSER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态变量
 
parseSingleRow(ByteBuffer, TableMapEvent) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的方法
 
parseSingleRow(ByteBuffer, TableMapEvent) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV1 中的方法
 
PERCENT - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
百分号
PIPE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
PLUS - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
pop() - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的方法
 
pop(long) - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的方法
 
pop() - 接口 net.neoremind.fountain.common.mq.FountainMQ 中的方法
从队列中读取一个消息,如果队列中没有消息,则堵塞直到有一个消息进入
pop(long) - 接口 net.neoremind.fountain.common.mq.FountainMQ 中的方法
从队列中读取一个消息,支持超时版本,如果队列中没有消息,则堵塞直到有一个消息进入 或者超时,超时时返回false
Position - net.neoremind.fountain.packet 中的 类
字节数组位置
Position() - 类 net.neoremind.fountain.packet.Position 的构造方法
 
Position(int) - 类 net.neoremind.fountain.packet.Position 的构造方法
 
prepareChoosedDatasouce(T) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
初始化选中的数据源
prepareChoosedDatasouce(MysqlDataSource) - 类 net.neoremind.fountain.datasource.HANormalMysqlDataSource 中的方法
 
PREVIOUS_GTIDS_LOG_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
PRIMARY_KEY - 接口 net.neoremind.fountain.meta.MetaDefine.KEY_FLAG 中的静态变量
主键或者主键组成部分
printMysqlInfo() - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
打印当前mysql的信息
ProtocolHelper - net.neoremind.fountain.util 中的 类
mysql binlog协议解析工具
ProtocolHelper() - 类 net.neoremind.fountain.util.ProtocolHelper 的构造方法
 
ProtoUtils - net.neoremind.fountain.changedata.pb 中的 类
changedata set to proto的工具类
push(BinlogTraceable) - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的方法
 
push(BinlogTraceable, long) - 类 net.neoremind.fountain.common.mq.AbstractMaxCapacityFountainMQ 中的方法
 
push(BinlogTraceable) - 接口 net.neoremind.fountain.common.mq.FountainMQ 中的方法
push一个消息,对于有界mq,如果容量已满,此方法会堵塞直到容量被至少是否一个unit
push(BinlogTraceable, long) - 接口 net.neoremind.fountain.common.mq.FountainMQ 中的方法
push 一个消息,支持超时的版本,如果容量已满,此方法会堵塞直到容量被至少是否一个unit 或者超时,超时时返回false

Q

Q_AUTO_INCREMENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_CATALOG_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_CATALOG_NZ_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_CHARSET_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_CHARSET_DATABASE_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_FLAGS2_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
variable 的类型
Q_LC_TIME_NAMES_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_SQL_MODE_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_TABLE_MAP_FOR_UPDATE_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
Q_TIME_ZONE_CODE - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
query(String) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
query(String) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
query(String) - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
执行查询sql
query - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
QUERY_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
QueryCommandPacket - net.neoremind.fountain.packet 中的 类
查询指令数据包,继承自CommandPacket
QueryCommandPacket() - 类 net.neoremind.fountain.packet.QueryCommandPacket 的构造方法
构造方法,无参数
QueryLogEvent - net.neoremind.fountain.rowbaselog.event 中的 类
 
QueryLogEvent(BinlogEventHeader) - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 的构造方法
 
QueryLogEventCallback - net.neoremind.fountain.support 中的 类
QueryLogEvent事件回调器
QueryLogEventCallback() - 类 net.neoremind.fountain.support.QueryLogEventCallback 的构造方法
 
queryTableMeta(String) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
queryTableMeta(String) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
调用如下的命令获取列信息,保存为ColumnMeta列表返回: mysql> show full fields from City; +------------+----------+------+-----+---------+----------------+ | Field | Type | Null | Key | Default | Extra | +------------+----------+------+-----+---------+----------------+ | Id | int(11) | NO | PRI | NULL | auto_increment | | Name | char(35) | NO | | | | | Country | char(3) | NO | UNI | | | | District | char(20) | YES | MUL | | | | Population | int(11) | NO | | 0 | | +------------+----------+------+-----+---------+----------------+ 5 rows in set (0.00 sec)
queryTableMeta(String) - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
查询给定表的schema
QUESTION - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
问号
QUESTION_MARK - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
QUOTATION - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
单引号
QUOTE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 

R

RAND_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
readObject(byte[]) - 类 net.neoremind.fountain.util.ObjectAccessUtil 中的静态方法
 
ReadonlyDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
用于fountain-producer和fountaion-consumer在同一jvm中,producer使用该类只读取文件中 存储的gt id, 而不会记录gt id,记录gt id的行为交给consumer实现。
ReadonlyDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.ReadonlyDisposeEventPosition 的构造方法
 
REAL - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type REAL.
REF - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type REF.
RegistableDisposeEventPosition - net.neoremind.fountain.eventposition 中的 类
支持注册的DisposeEventPosition抽象实现
RegistableDisposeEventPosition() - 类 net.neoremind.fountain.eventposition.RegistableDisposeEventPosition 的构造方法
 
register(String, DisposeEventPosition) - 接口 net.neoremind.fountain.eventposition.DisposeEventPositionBridge 中的方法
生产者把自己的名称和所使用的 DisposeEventPosition注册进来
register(String, DisposeEventPosition) - 类 net.neoremind.fountain.eventposition.DisposeEventPositionBridgeImpl 中的方法
 
registerAllExtensions(ExtensionRegistry) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef 中的静态方法
 
registerInstance(String) - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 中的方法
 
registerInstance(String) - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
registerInstance(String) - 类 net.neoremind.fountain.eventposition.DelayGroupIdDisposeEventPosition 中的方法
 
registerInstance(String) - 类 net.neoremind.fountain.eventposition.DelayGtIdDisposeEventPosition 中的方法
 
registerInstance(String) - 接口 net.neoremind.fountain.eventposition.DisposeEventPosition 中的方法
注册生产者实例的名称,在采用文件保存gt id时会使用该name作为文件名称
registerInstance(String) - 类 net.neoremind.fountain.eventposition.RegistableDisposeEventPosition 中的方法
 
removeAfterValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
removeBeforeValues(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
removeColumnMeta(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
removeRows(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
removeTables(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
reserved - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
reserved - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
ResultSetHeaderPacket - net.neoremind.fountain.packet 中的 类
描述Text Protocol结果集的头的包
ResultSetHeaderPacket() - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 的构造方法
 
ResultSetPacket - net.neoremind.fountain.packet 中的 类
描述Text Protocol返回结果数据包
ResultSetPacket() - 类 net.neoremind.fountain.packet.ResultSetPacket 的构造方法
 
RETURN - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
RIGHT_BRACE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
右大括号
RIGHT_BRACKET - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
右中括号
RIGHT_CHEV - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
RIGHT_PARENTHESES - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
右小括号
RIGHT_SQ_BRACKET - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
RMB - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
人民币
ROTATE_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
RotateEvent - net.neoremind.fountain.rowbaselog.event 中的 类
binlog文件的结尾,通常(只要master不当机)就是ROTATE_EVENT或者STOP_EVENT
RotateEvent(BinlogEventHeader) - 类 net.neoremind.fountain.rowbaselog.event.RotateEvent 的构造方法
Fixed data part:

8 bytes.

RotateEventCallback - net.neoremind.fountain.support 中的 类
RotateEvent事件回调器
RotateEventCallback() - 类 net.neoremind.fountain.support.RotateEventCallback 的构造方法
 
RoundRobinDatasourceChoosePolicy - net.neoremind.fountain.datasource 中的 类
Round Robin方式的选择datasource的策略
RoundRobinDatasourceChoosePolicy() - 类 net.neoremind.fountain.datasource.RoundRobinDatasourceChoosePolicy 的构造方法
 
RowData - net.neoremind.fountain.event.data 中的 类
 
RowData() - 类 net.neoremind.fountain.event.data.RowData 的构造方法
 
rowDataList - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
RowEvent - net.neoremind.fountain.event 中的 接口
 
ROWID - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type ROWID
ROWS_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的静态变量
 
ROWS_QUERY_LOG_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
RowsLogEvent - net.neoremind.fountain.rowbaselog.event 中的 类
 
RowsLogEvent(EventHeader, int, byte, TableInfoCallback, ColumnDataParserFactory) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 的构造方法
 
RowsLogEventCallback<T extends RowsLogEvent> - net.neoremind.fountain.support 中的 类
RowsLogEvent事件回调器

主要针对百度MySQL Ares 5.1版本,在BinlogEventHeader中存在一个groupid,就是gtid,设置到TrxContext.currGtId中

RowsLogEventCallback() - 类 net.neoremind.fountain.support.RowsLogEventCallback 的构造方法
 
RowsLogEventV1 - net.neoremind.fountain.rowbaselog.event 中的 类
 
RowsLogEventV1(EventHeader, int, byte, TableInfoCallback, ColumnDataParserFactory) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV1 的构造方法
 
RowsLogEventV2 - net.neoremind.fountain.rowbaselog.event 中的 类
 
RowsLogEventV2(EventHeader, int, byte, TableInfoCallback, ColumnDataParserFactory) - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEventV2 的构造方法
 
RowValuePacket - net.neoremind.fountain.packet 中的 类
描述Text Protocol 协议的row 数据包
RowValuePacket() - 类 net.neoremind.fountain.packet.RowValuePacket 的构造方法
 

S

safeCloseCurrent() - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
安全的关闭数据源,并记录日志
saveSyncPoint(SyncPoint) - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
saveSyncPoint(SyncPoint) - 类 net.neoremind.fountain.eventposition.DelayGroupIdDisposeEventPosition 中的方法
 
saveSyncPoint(SyncPoint) - 类 net.neoremind.fountain.eventposition.DelayGtIdDisposeEventPosition 中的方法
 
saveSyncPoint(SyncPoint) - 接口 net.neoremind.fountain.eventposition.DisposeEventPosition 中的方法
保存同步点
saveSyncPoint(SyncPoint) - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
 
saveSyncPoint(SyncPoint) - 类 net.neoremind.fountain.eventposition.ReadonlyDisposeEventPosition 中的方法
 
SEMICOLON - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
分号
serverStatus - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
serverVersion - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的变量
50 bytes.
setAffectRows(byte[]) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
setAfterColumnList(List<ColumnData>) - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
setAfterValues(int, DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
setAfterValues(int, DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue afterValues = 2;
setBeforeColumnList(List<ColumnData>) - 类 net.neoremind.fountain.event.data.RowData 中的方法
 
setBeforeValues(int, DataUnitDef.ColumnValue) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
setBeforeValues(int, DataUnitDef.ColumnValue.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnValue beforeValues = 1;
setBinlogFileName(String) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setBinlogName(String) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
setBirthTime(long) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setBoolValue(boolean) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool boolValue = 5;
setByteArrayValue(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bytes byteArrayValue = 7;
setCatalog(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setCharacter(int) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setCharset(String) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setCharset(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setCharsetNumber(byte) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
setClassName(String) - 类 net.neoremind.fountain.pack.impl.NameUnpackClazResolver 中的方法
 
setColumnAlias(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setColumnCount(long) - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 中的方法
 
setColumnMeta(int, DataUnitDef.ColumnMeta) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
setColumnMeta(int, DataUnitDef.ColumnMeta.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.ColumnMeta columnMeta = 2;
setColumnMetaList(List<ColumnMeta>) - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
setColumnName(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setColumnName(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setColumnType(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setCommand(byte) - 类 net.neoremind.fountain.packet.CommandPacket 中的方法
 
setConf(DatasourceConfigure) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
setConnectTimeout(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setCurrBinlogPosition(Long) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setCurrGtId(Long) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setDatabaseName(String) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setDatabaseName(String) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
setDatabusColumnBitmap(int) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setDataSize(int) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setDatasourceChoosePolicy(DatasourceChoosePolicy) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
setDataType(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required sint32 dataType = 1;
setDbName(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setDecimal(byte) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setDefaultExtra(byte[]) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setDefaultValue(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setDelegate(DisposeEventPosition) - 类 net.neoremind.fountain.eventposition.AbstractProxyDisposeEventPosition 中的方法
 
setDisposeEventPositionBridge(DisposeEventPositionBridge) - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
setDisposeEventPositionBridge(DisposeEventPositionBridge) - 类 net.neoremind.fountain.eventposition.DelayGroupIdDisposeEventPosition 中的方法
 
setDisposeEventPositionBridge(DisposeEventPositionBridge) - 类 net.neoremind.fountain.eventposition.DelayGtIdDisposeEventPosition 中的方法
 
setDisposeEventPositionBridge(DisposeEventPositionBridge) - 类 net.neoremind.fountain.eventposition.RegistableDisposeEventPosition 中的方法
 
setDoubleValue(double) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional double doubleValue = 1;
setEofFlag(byte) - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
setErrorCode(int) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
setErrorFlag(byte) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
setEventLength(int) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setExtra(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setExtra(byte[]) - 类 net.neoremind.fountain.packet.ResultSetHeaderPacket 中的方法
 
setExtraHeaders(byte[]) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setFieldDescriptionList(List<FieldDescriptionPacket>) - 类 net.neoremind.fountain.packet.ResultSetPacket 中的方法
 
setFieldValueList(List<String>) - 类 net.neoremind.fountain.packet.RowValuePacket 中的方法
 
setFlags(int) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setFlags(int) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setFloatValue(float) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional float floatValue = 2;
setFmtDescEvent(FormatDescriptionEvent) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setFromDatabus(boolean) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setFullName(String) - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
setGeneralColumnType(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setGtId(BigInteger) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setGtId(long) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
optional sint64 gtId = 1;
setGtId(long) - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 中的方法
 
setGtIdList(List<GtId>) - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
 
setGtIdSet(GtIdSet) - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 中的方法
 
setInitDelayMs(long) - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
setInsertId(byte[]) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
setInstanceName(String) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setIntervalEnd(long) - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
setIntervalStart(long) - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
setIntValue(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint32 intValue = 3;
setIsChecksumSupport(boolean) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setIsNull(boolean) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isNull = 4;
setIsNull(boolean) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional bool isNull = 8;
setIsNull(boolean) - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
setIsPrimay(boolean) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isPrimay = 3;
setIsUnsiged(boolean) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required bool isUnsiged = 5;
setJavaType(int) - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
setKeyFlag(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setLength(long) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setLongValue(long) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional sint64 longValue = 4;
setMessage(String) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
setMessage(String) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
setMetaValue(int) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setMysqlDataSourceList(List<T>) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
setMysqlId(String) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
setMysqlPort(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setMysqlServer(String) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setName(String) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
setName(String) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
setNameBytes(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta.Builder 中的方法
required string name = 2;
setNameBytes(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
required string name = 1;
setNetReadTimeout(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setNetWriteTimeout(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setNextBinlogPosition(Long) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setNextPosition(long) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setNull(boolean) - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
setNullFlag(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setOffset(BigInteger) - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
setOkflag(byte) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
setOptype(int) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData.Builder 中的方法
required sint32 optype = 3;
setPacketLength(int) - 类 net.neoremind.fountain.packet.PacketHeader 中的方法
 
setPacketNumber(byte) - 类 net.neoremind.fountain.packet.PacketHeader 中的方法
 
setPassword(String) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setPassword(String) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
setPeriodMs(long) - 类 net.neoremind.fountain.eventposition.AsyncFixedRateDisposeEventPosition 中的方法
 
setProtocolVersion(byte) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setReceiveBufferSize(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setRestOfScrambleBuff(byte[]) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setRootPath(String) - 类 net.neoremind.fountain.eventposition.LocalFileDisposeEventPosition 中的方法
 
setRows(int, DataUnitDef.RowData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
setRows(int, DataUnitDef.RowData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.RowData rows = 3;
setRowValueList(List<RowValuePacket>) - 类 net.neoremind.fountain.packet.ResultSetPacket 中的方法
 
setScrumbleBuff(byte[]) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
setSeed(byte[]) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setSendBufferSize(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setSendTime(long) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setServerCapabilities(int) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setServerCharsetNumber(byte) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setServerId(int) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setServerStatus(int) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setServerStatus(int) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
setServerUUID(String) - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
setServerUUIDbyte(byte[]) - 类 net.neoremind.fountain.eventposition.GtId 中的方法
 
setShortCharset(String) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setSid(byte[]) - 类 net.neoremind.fountain.rowbaselog.event.GtidEvent 中的方法
 
setSid(byte[]) - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
setSoTimeout(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setSql(String) - 类 net.neoremind.fountain.packet.CommandPacket 中的方法
 
setSqlstate(byte[]) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
setSqlstateMarker(byte) - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
setSqlType(int) - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
setSrcDbHost(String) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setStatusFlags(byte[]) - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
setStringValue(String) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
setStringValueBytes(ByteString) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.Builder 中的方法
optional string stringValue = 6;
setSyncPoint(SyncPoint) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setTableAlias(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setTableData(Map<String, List<RowData>>) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setTableDef(Map<String, List<ColumnMeta>>) - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
setTableId(long) - 类 net.neoremind.fountain.meta.TableMeta 中的方法
 
setTableMapEvent(TableMapEvent) - 类 net.neoremind.fountain.event.util.TableEventCache 中的方法
 
setTableName(String) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setTables(int, DataUnitDef.TableData) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
setTables(int, DataUnitDef.TableData.Builder) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet.Builder 中的方法
repeated .com.baidu.fountain.changedata.pb.TableData tables = 2;
setThreadId(int) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setTimestamp(long) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setTrxContext(TrxContext) - 类 net.neoremind.fountain.support.ThreadHolder 中的静态方法
初始化线程上下文
setTryInterval(long) - 类 net.neoremind.fountain.datasource.RoundRobinDatasourceChoosePolicy 中的方法
 
setType(byte) - 类 net.neoremind.fountain.packet.FieldDescriptionPacket 中的方法
 
setTypeCode(byte) - 类 net.neoremind.fountain.rowbaselog.event.BinlogEventHeader 中的方法
 
setTypeEnum(ColumnTypeEnum) - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
setUnpackClazResolver(UnpackClazResolver) - 类 net.neoremind.fountain.pack.impl.JsonUnpackProtocol 中的方法
 
setUserName(String) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setUsername(String) - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
 
setValue(Object) - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
setValue(int) - 枚举 net.neoremind.fountain.meta.DatabusColBitmapFlag 中的方法
 
setValue(String) - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.GtIdMode 中的方法
 
setValue(String) - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.RowFormat 中的方法
 
setVersion(String) - 类 net.neoremind.fountain.packet.HandshakePacket 中的方法
 
setWaitTimeout(int) - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
setWarningCount(int) - 类 net.neoremind.fountain.packet.EOFPacket 中的方法
 
setWarningStatus(int) - 类 net.neoremind.fountain.packet.OKPacket 中的方法
 
SINGLE_QUOTE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
单引号
SLASH - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
斜杠
SLAVE_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
SMALLINT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type SMALLINT.
SMALLINT_16_MAX_VALUE - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
SocketHelper - net.neoremind.fountain.util 中的 类
操作socket的帮住类,支持写入读取数据到socket,封装操作socket的内部细节和异常处理
SocketHelper() - 类 net.neoremind.fountain.util.SocketHelper 的构造方法
 
SPACE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
空格
SQLXML - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type XML.
STAR - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
START_EVENT_V3 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
statusVariableLength - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
STOP_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
StopEvent - net.neoremind.fountain.rowbaselog.event 中的 类
binlog文件的结尾,通常(只要master不当机)就是ROTATE_EVENT或者STOP_EVENT
StopEvent(BinlogEventHeader) - 类 net.neoremind.fountain.rowbaselog.event.StopEvent 的构造方法
A master writes the event to the binary log when it shuts down

A slave writes the event to the relay log when it shuts down or when a RESET SLAVE statement is executed

A STOP_EVENT has no payload or post-header.

StringPool - net.neoremind.fountain.util 中的 接口
char、string等常用字符公共类
StringPool.Charset - net.neoremind.fountain.util 中的 接口
编码格式常量定义
StringPool.Symbol - net.neoremind.fountain.util 中的 接口
定义常用符号,方便统一维护
STRINGVALUE_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的静态变量
 
STRUCT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type STRUCT.
SYNC_POINT_CACHE - 类 net.neoremind.fountain.support.ThreadHolder 中的静态变量
SyncPoint的内存缓存,缓存当producer中已经接收到的最后的SyncPoint,当数据源不可用并选择新的数据源时 直接使用该SyncPoint继续接收。
SyncPoint - net.neoremind.fountain.eventposition 中的 接口
描述mysql的数据同步点,用来代替EventPosition.
SyncPointFactory - net.neoremind.fountain.eventposition.factory 中的 接口
生成SyncPoint对象的工厂

T

TAB - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
TABLE_MAP_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
TableEventCache - net.neoremind.fountain.event.util 中的 类
 
TableEventCache() - 类 net.neoremind.fountain.event.util.TableEventCache 的构造方法
 
TableEventCallback - net.neoremind.fountain.rowbaselog.event 中的 接口
用于保存TableMapEvent数据的回调
tableId - 类 net.neoremind.fountain.rowbaselog.event.RowsLogEvent 中的变量
 
tableId - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
Fixed data part:

6 bytes.

TableInfoCallback - net.neoremind.fountain.rowbaselog.event 中的 接口
获取表信息的回调接口描述
TableMapEvent - net.neoremind.fountain.rowbaselog.event 中的 类
 
TableMapEvent(BinlogEventHeader, TableEventCallback) - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 的构造方法
构造方法
TableMapEvent.ColumnInfo - net.neoremind.fountain.rowbaselog.event 中的 类
描述列信息
TableMapEvent.ColumnInfo() - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent.ColumnInfo 的构造方法
 
TableMeta - net.neoremind.fountain.meta 中的 类
表结构
TableMeta() - 类 net.neoremind.fountain.meta.TableMeta 的构造方法
 
TableMetaProvider - net.neoremind.fountain.meta 中的 接口
row base binlog中不提供表中的列名称,只提供列索引,但解析binlog数据后下发时需要知道 列名,这些信息需要从其他来源获取,本接口就是表中列信息提供者的抽象描述
tableName - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
tableNameLength - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent 中的变量
 
TABLES_FIELD_NUMBER - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的静态变量
 
TaskExcutor<T> - net.neoremind.fountain.datasource 中的 接口
任务执行器,用于doHaTask 方法,一般使用匿名类,任务的具体执行逻辑延迟到doHaTask方法调用时。
ThreadHolder - net.neoremind.fountain.support 中的 类
ThreadLocal线程保存辅助类
ThreadHolder() - 类 net.neoremind.fountain.support.ThreadHolder 的构造方法
 
threadId - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
Query_log_event/QUERY_EVENT Fixed data part: 4 bytes.
ThreadSafe - net.neoremind.fountain.thread.annotaion 中的 注释类型
用于说明类或者方法时非线程安全的,只是帮助调用者识别调用的对象是否支持线程安全
TIME - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type TIME.
TIMESTAMP - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type TIMESTAMP.
TINYINT - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type TINYINT.
TINYINT_8_MAX_VALUE - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态变量
 
toAsciiString(byte[], int, int) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
转换byte to ansi string
toAsciiString(byte[]) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
转换byte to ansi string
toBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
toBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
toBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
toBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
toBuilder() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
toBytes() - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
toBytes() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
 
toBytes() - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 中的方法
 
toBytes() - 接口 net.neoremind.fountain.eventposition.SyncPoint 中的方法
convert 同步点对象为byte数组
toBytes() - 类 net.neoremind.fountain.packet.ClientAuthPacket 中的方法
转化为bytes
toBytes() - 类 net.neoremind.fountain.packet.PacketHeader 中的方法
小尾端表示
toBytes() - 类 net.neoremind.fountain.packet.QueryCommandPacket 中的方法
转换成bytes
toJson(Object) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
Java对象转Json字符串
toJson(Object, boolean) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
toJsonBytes(Object) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
toJsonBytes(Object, boolean) - 类 net.neoremind.fountain.util.JsonUtils 中的静态方法
 
toString() - 类 net.neoremind.fountain.changedata.ChangeDataSet 中的方法
 
toString() - 类 net.neoremind.fountain.datasource.DatasourceConfigure 中的方法
 
toString() - 类 net.neoremind.fountain.event.data.ColumnData 中的方法
 
toString() - 类 net.neoremind.fountain.eventposition.BaiduGroupIdSyncPoint 中的方法
 
toString() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint.MysqlSyncPoint 中的方法
 
toString() - 类 net.neoremind.fountain.eventposition.BinlogAndOffsetSyncPoint 中的方法
 
toString() - 类 net.neoremind.fountain.eventposition.GtId 中的方法
按照05b47d41-7b10-11e2-9fff-00241db92e69:1-19这个格式打印
toString() - 类 net.neoremind.fountain.eventposition.GtIdSet 中的方法
按照05b47d41-7b10-11e2-9fff-00241db92e69:1-19;4f65e570-7b32-11e2-a0de-00241db92e69:1这个格式打印
toString() - 类 net.neoremind.fountain.eventposition.GtIdSyncPoint 中的方法
 
toString() - 类 net.neoremind.fountain.meta.ColumnMeta 中的方法
 
toString() - 类 net.neoremind.fountain.packet.ErrorPacket 中的方法
 
toString() - 类 net.neoremind.fountain.rowbaselog.event.FormatDescriptionEvent 中的方法
 
toString() - 类 net.neoremind.fountain.support.TrxContext 中的方法
 
toUnsignedByte(int) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
 
toUnsignedInt(long) - 类 net.neoremind.fountain.util.UnsignedNumberHelper 中的静态方法
用long数据类型表示无符号的int,把高4个字节置为0
transform(Collection<F>, Function<? super F, ? extends T>) - 类 net.neoremind.fountain.util.CollectionUtil 中的静态方法
列表转换
TRX_CONTEXT - 类 net.neoremind.fountain.support.ThreadHolder 中的静态变量
事务上下文
TrxContext - net.neoremind.fountain.support 中的 类
事务上下文,一般用于在接收binlog的主处理流程中保存一些上下文信息,例如包括: 当前正在处理事务的gtid 当前正在处理事务的binlog filename和position binlog最先接到固定的一个FormatDescriptionEvent,包含MySQL的一些基本信息,例如版本
type - 类 net.neoremind.fountain.rowbaselog.event.TableMapEvent.ColumnInfo 中的变量
 

U

UNDERLINE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
下划线
UNDERSCORE - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
UNIQUE_KEY - 接口 net.neoremind.fountain.meta.MetaDefine.KEY_FLAG 中的静态变量
唯一索引的第一列(前导列),并别不能含有空值NULL
UNKNOWN_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
event 的类型
UnkownBinlogEvent - net.neoremind.fountain.rowbaselog.event 中的 类
 
UnkownBinlogEvent(EventHeader) - 类 net.neoremind.fountain.rowbaselog.event.UnkownBinlogEvent 的构造方法
 
unpack(Object) - 类 net.neoremind.fountain.pack.impl.JsonUnpackProtocol 中的方法
 
unpack(Object) - 类 net.neoremind.fountain.pack.impl.NoneUnpackProtocol 中的方法
 
unpack(Object) - 接口 net.neoremind.fountain.pack.UnpackProtocol 中的方法
解包方法
UnpackClazResolver - net.neoremind.fountain.pack 中的 接口
解包数据时,把byte[]转化为java对象时需要提供类名称,有些类 可能是复杂的泛型,需要构造出其class,本接口就是构造class对象的 抽象描述
UnpackProtocol - net.neoremind.fountain.pack 中的 接口
把byte[]解析成java对象的抽象描述
UnsignedNumberHelper - net.neoremind.fountain.util 中的 类
转换数字为无符号的工具类
UnsignedNumberHelper() - 类 net.neoremind.fountain.util.UnsignedNumberHelper 的构造方法
 
UnThreadSafe - net.neoremind.fountain.thread.annotaion 中的 注释类型
用于说明类或者方法时非线程安全的,只是帮助调用者识别调用的对象是否支持线程安全
update(String) - 类 net.neoremind.fountain.datasource.AbstractHADatasource 中的方法
 
update(String) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
 
update(Socket, String) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
封装mysql query text协议,实现update语句的执行
update(String) - 接口 net.neoremind.fountain.datasource.MysqlDataSource 中的方法
执行修改数据的sql
UPDATE_ROWS_EVENT_V0 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
UPDATE_ROWS_EVENT_V1 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
UPDATE_ROWS_EVENT_V2 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
updateSettings(Socket) - 类 net.neoremind.fountain.datasource.AbstractMysqlDataSource 中的方法
对新构建的mysql 连接设置配置信息: wait_timeout net_write_timeout net_read_timeout charset
US_ASCII - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
USER_VAR_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
UTF_16 - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
UTF_16BE - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
UTF_16LE - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 
UTF_8 - 接口 net.neoremind.fountain.util.StringPool.Charset 中的静态变量
 

V

valueOf(String) - 枚举 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.ValueOneofCase 中的静态方法
返回带有指定名称的该类型的枚举常量。
valueOf(int) - 枚举 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.ValueOneofCase 中的静态方法
 
valueOf(String) - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的静态方法
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 net.neoremind.fountain.meta.DatabusColBitmapFlag 中的静态方法
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.GtIdMode 中的静态方法
返回带有指定名称的该类型的枚举常量。
valueOf(String) - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.RowFormat 中的静态方法
返回带有指定名称的该类型的枚举常量。
values() - 枚举 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue.ValueOneofCase 中的静态方法
按照声明该枚举类型的常量的顺序,返回 包含这些常量的数组。
values() - 枚举 net.neoremind.fountain.meta.ColumnTypeEnum 中的静态方法
按照声明该枚举类型的常量的顺序,返回 包含这些常量的数组。
values() - 枚举 net.neoremind.fountain.meta.DatabusColBitmapFlag 中的静态方法
按照声明该枚举类型的常量的顺序,返回 包含这些常量的数组。
values() - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.GtIdMode 中的静态方法
按照声明该枚举类型的常量的顺序,返回 包含这些常量的数组。
values() - 枚举 net.neoremind.fountain.util.MysqlCommonConstants.RowFormat 中的静态方法
按照声明该枚举类型的常量的顺序,返回 包含这些常量的数组。
VARBINARY - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type VARBINARY.
VARCHAR - 类 net.neoremind.fountain.event.data.FountainJavaTypes 中的静态变量
The constant in the Java programming language, sometimes referred to as a type code, that identifies the generic SQL type VARCHAR.
variableMap - 类 net.neoremind.fountain.rowbaselog.event.QueryLogEvent 中的变量
 
VERTICAL - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
竖线

W

warningStatus - 类 net.neoremind.fountain.packet.OKPacket 中的变量
 
WRITE_ROWS_EVENT_V0 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
WRITE_ROWS_EVENT_V1 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
WRITE_ROWS_EVENT_V2 - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
writeByte(Socket, byte[]) - 类 net.neoremind.fountain.util.SocketHelper 中的静态方法
写入指定的数据到socket
writeIntWithByteByLittleEndian(int, int, ByteArrayOutputStream) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
输出指定位数int
writeLengthCodedBinary(byte[], ByteArrayOutputStream) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
输出length code bytes
writeNullTerminatedString(String, ByteArrayOutputStream) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
输出以null结尾的string
writeReplace() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
writeReplace() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
writeReplace() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
writeReplace() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
writeReplace() - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
writeTo(CodedOutputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnMeta 中的方法
 
writeTo(CodedOutputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.ColumnValue 中的方法
 
writeTo(CodedOutputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.DataSet 中的方法
 
writeTo(CodedOutputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.RowData 中的方法
 
writeTo(CodedOutputStream) - 类 net.neoremind.fountain.changedata.pb.DataUnitDef.TableData 中的方法
 
writeUnsignedIntByLittleEndian(int, ByteArrayOutputStream) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
输出小端无符号int
writeUnsignedLongByLittleEndian(long, ByteArrayOutputStream) - 类 net.neoremind.fountain.util.ProtocolHelper 中的静态方法
输出小端无符号int

X

xid - 类 net.neoremind.fountain.rowbaselog.event.XidLogEvent 中的变量
 
XID_EVENT - 类 net.neoremind.fountain.rowbaselog.event.EventConstant 中的静态变量
 
XidLogEvent - net.neoremind.fountain.rowbaselog.event 中的 类
Transaction ID for 2PC, written whenever a COMMIT is expected.
XidLogEvent(BinlogEventHeader) - 类 net.neoremind.fountain.rowbaselog.event.XidLogEvent 的构造方法
 
XidLogEventCallback - net.neoremind.fountain.support 中的 类
XidLogEvent事件回调器
XidLogEventCallback() - 类 net.neoremind.fountain.support.XidLogEventCallback 的构造方法
 

Y

Y - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 
YES - 接口 net.neoremind.fountain.meta.MetaDefine.NOT_NULL_FLAG 中的静态变量
可为空
YES - 接口 net.neoremind.fountain.util.StringPool.Symbol 中的静态变量
 

A B C D E F G H I J L M N O P Q R S T U V W X Y

Copyright © 2016 neoremind. All rights reserved.