Path	Lines of Code
parse/src/main/java/com/alibaba/otter/canal/parse/CanalEventParser.java	4
parse/src/main/java/com/alibaba/otter/canal/parse/CanalHASwitchable.java	6
parse/src/main/java/com/alibaba/otter/canal/parse/exception/CanalHAException.java	20
parse/src/main/java/com/alibaba/otter/canal/parse/exception/CanalParseException.java	20
parse/src/main/java/com/alibaba/otter/canal/parse/exception/PositionNotFoundException.java	19
parse/src/main/java/com/alibaba/otter/canal/parse/exception/ServerIdNotMatchException.java	20
parse/src/main/java/com/alibaba/otter/canal/parse/ha/CanalHAController.java	7
parse/src/main/java/com/alibaba/otter/canal/parse/ha/HeartBeatHAController.java	40
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractBinlogParser.java	18
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/AbstractEventParser.java	546
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/BinlogParser.java	8
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/ErosaConnection.java	17
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/EventTransactionBuffer.java	118
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/HeartBeatCallback.java	5
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/MultiStageCoprocessor.java	8
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/ParserExceptionHandler.java	4
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/SinkFunction.java	4
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/TableMeta.java	152
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/group/GroupEventParser.java	38
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/AbstractMysqlEventParser.java	240
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/DbsyncMysqlEventParser.java	3
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinLogConnection.java	378
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/LocalBinlogEventParser.java	139
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java	600
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java	774
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlMultiStageCoprocessor.java	459
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/SlaveEntryPosition.java	18
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/DirectLogFetcher.java	118
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/LogEventConvert.java	894
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/TableMetaCache.java	225
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DdlResult.java	85
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/DruidDdlParser.java	216
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl/SimpleDdlParser.java	163
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/local/BinLogFileQueue.java	191
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/local/BufferedFileDataInput.java	70
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/BinlogDownloadQueue.java	295
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/HttpHelper.java	328
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogEventParserProxy.java	122
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsBinlogOpenApi.java	89
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/RdsLocalBinlogEventParser.java	181
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/data/BinlogFile.java	58
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/data/DescribeBinlogFileResult.java	45
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/data/RdsBackupPolicy.java	44
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/data/RdsItem.java	15
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/request/AbstractRequest.java	178
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/request/DescribeBackupPolicyRequest.java	27
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds/request/DescribeBinlogFilesRequest.java	39
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DatabaseTableMeta.java	535
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/DefaultTableMetaTSDBFactory.java	9
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/MemoryTableMeta.java	280
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/TableMetaTSDB.java	12
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/TableMetaTSDBBuilder.java	39
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/TableMetaTSDBFactory.java	5
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaBaseDAO.java	47
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaHistoryDAO.java	32
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaHistoryDO.java	110
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaHistoryMapper.java	9
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaSnapshotDAO.java	33
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaSnapshotDO.java	81
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao/MetaSnapshotMapper.java	9
parse/src/main/java/com/alibaba/otter/canal/parse/index/AbstractLogPositionManager.java	4
parse/src/main/java/com/alibaba/otter/canal/parse/index/CanalLogPositionManager.java	8
parse/src/main/java/com/alibaba/otter/canal/parse/index/FailbackLogPositionManager.java	60
parse/src/main/java/com/alibaba/otter/canal/parse/index/FileMixedLogPositionManager.java	145
parse/src/main/java/com/alibaba/otter/canal/parse/index/MemoryLogPositionManager.java	30
parse/src/main/java/com/alibaba/otter/canal/parse/index/MetaLogPositionManager.java	57
parse/src/main/java/com/alibaba/otter/canal/parse/index/MixedLogPositionManager.java	62
parse/src/main/java/com/alibaba/otter/canal/parse/index/PeriodMixedLogPositionManager.java	87
parse/src/main/java/com/alibaba/otter/canal/parse/index/ZooKeeperLogPositionManager.java	35
parse/src/main/java/com/alibaba/otter/canal/parse/support/AuthenticationInfo.java	135
parse/src/main/java/com/alibaba/otter/canal/parse/support/HaAuthenticationInfo.java	23
parse/src/main/resources/ddl/derby/meta_history.sql	21
parse/src/main/resources/ddl/derby/meta_snapshot.sql	17
parse/src/main/resources/ddl/h2/meta_history.sql	21
parse/src/main/resources/ddl/h2/meta_snapshot.sql	17
parse/src/main/resources/ddl/mysql/meta_history.sql	21
parse/src/main/resources/ddl/mysql/meta_snapshot.sql	17