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.