Path	Lines of Code
admin/admin-ui/babel.config.js	5
admin/admin-ui/build/index.js	28
admin/admin-ui/mock/index.js	51
admin/admin-ui/mock/mock-server.js	52
admin/admin-ui/mock/table.js	27
admin/admin-ui/mock/user.js	70
admin/admin-ui/postcss.config.js	5
admin/admin-ui/public/index.html	16
admin/admin-ui/src/App.vue	10
admin/admin-ui/src/api/canalCluster.js	40
admin/admin-ui/src/api/canalConfig.js	20
admin/admin-ui/src/api/canalInstance.js	70
admin/admin-ui/src/api/nodeServer.js	52
admin/admin-ui/src/api/table.js	8
admin/admin-ui/src/api/user.js	28
admin/admin-ui/src/components/Breadcrumb/index.vue	72
admin/admin-ui/src/components/Hamburger/index.vue	41
admin/admin-ui/src/components/Pagination/index.vue	98
admin/admin-ui/src/components/SvgIcon/index.vue	58
admin/admin-ui/src/icons/index.js	6
admin/admin-ui/src/layout/components/AppMain.vue	37
admin/admin-ui/src/layout/components/Navbar.vue	124
admin/admin-ui/src/layout/components/Sidebar/FixiOSBug.js	24
admin/admin-ui/src/layout/components/Sidebar/Item.vue	27
admin/admin-ui/src/layout/components/Sidebar/Link.vue	32
admin/admin-ui/src/layout/components/Sidebar/Logo.vue	74
admin/admin-ui/src/layout/components/Sidebar/SidebarItem.vue	89
admin/admin-ui/src/layout/components/Sidebar/index.vue	54
admin/admin-ui/src/layout/components/index.js	3
admin/admin-ui/src/layout/index.vue	86
admin/admin-ui/src/layout/mixin/ResizeHandler.js	40
admin/admin-ui/src/main.js	22
admin/admin-ui/src/permission.js	45
admin/admin-ui/src/router/index.js	113
admin/admin-ui/src/settings.js	5
admin/admin-ui/src/store/getters.js	8
admin/admin-ui/src/store/index.js	16
admin/admin-ui/src/store/modules/app.js	44
admin/admin-ui/src/store/modules/settings.js	25
admin/admin-ui/src/store/modules/user.js	75
admin/admin-ui/src/styles/element-ui.scss	32
admin/admin-ui/src/styles/index.scss	62
admin/admin-ui/src/styles/mixin.scss	24
admin/admin-ui/src/styles/sidebar.scss	166
admin/admin-ui/src/styles/transition.scss	35
admin/admin-ui/src/styles/variables.scss	18
admin/admin-ui/src/utils/auth.js	11
admin/admin-ui/src/utils/get-page-title.js	8
admin/admin-ui/src/utils/index.js	88
admin/admin-ui/src/utils/request.js	56
admin/admin-ui/src/utils/scrollTo.js	39
admin/admin-ui/src/utils/validate.js	7
admin/admin-ui/src/views/404.vue	225
admin/admin-ui/src/views/canalServer/CanalCluster.vue	199
admin/admin-ui/src/views/canalServer/CanalConfig.vue	116
admin/admin-ui/src/views/canalServer/CanalInstance.vue	226
admin/admin-ui/src/views/canalServer/CanalInstanceAdd.vue	114
admin/admin-ui/src/views/canalServer/CanalInstanceLogDetail.vue	49
admin/admin-ui/src/views/canalServer/CanalInstanceUpdate.vue	104
admin/admin-ui/src/views/canalServer/CanalLogDetail.vue	47
admin/admin-ui/src/views/canalServer/NodeServer.vue	456
admin/admin-ui/src/views/dashboard/index.vue	30
admin/admin-ui/src/views/login/index.vue	211
admin/admin-ui/src/views/sys/UserInfo.vue	80
admin/admin-ui/vue.config.js	110
admin/admin-web/src/main/assembly/dev.xml	52
admin/admin-web/src/main/assembly/release.xml	53
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/CanalAdminApplication.java	12
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/common/DaemonThreadFactory.java	11
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/common/TemplateConfigLoader.java	41
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/common/Threads.java	14
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/common/exception/ServiceException.java	21
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/config/EbeanConfig.java	29
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/config/SpringContext.java	18
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/config/WebConfig.java	90
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/connector/AdminConnector.java	21
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/connector/SimpleAdminConnector.java	267
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/connector/SimpleAdminConnectors.java	38
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/CanalClusterController.java	81
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/CanalConfigController.java	32
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/CanalInstanceController.java	77
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/NodeServerController.java	61
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/PollingConfigController.java	74
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/controller/UserController.java	70
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/handler/CustomExceptionHandler.java	28
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/BaseModel.java	29
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/CanalCluster.java	47
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/CanalConfig.java	76
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/CanalInstanceConfig.java	117
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/Model.java	61
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/NodeServer.java	99
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/Pager.java	62
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model/User.java	84
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/CanalClusterService.java	10
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/CanalConfigService.java	8
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/CanalInstanceService.java	16
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/NodeServerService.java	15
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/PollingConfigService.java	9
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/UserService.java	6
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/CanalClusterServiceImpl.java	40
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/CanalConfigServiceImpl.java	104
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/CanalInstanceServiceImpl.java	271
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/NodeServerServiceImpl.java	165
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/PollingConfigServiceImpl.java	118
admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/service/impl/UserServiceImpl.java	52
admin/admin-web/src/main/resources/canal_manager.sql	78
admin/admin-web/src/main/resources/logback.xml	42
admin/admin-web/src/main/resources/public/static/css/chunk-14b5f7a4.f3e06673.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-22553be3.f3e06673.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-2301924a.160e7b4a.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-2b9b6c5c.c89f8844.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-37c49cbf.efc21a9c.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-4f09fed2.70ec0b86.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-5afa45f5.a34bb177.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-5b373aad.b966d36b.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-69386cf0.741ff14e.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-7ec889b7.c0585512.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-98f505d0.5280f88f.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-bd1d44ee.1528199a.css	1
admin/admin-web/src/main/resources/public/static/css/chunk-da289616.c89f8844.css	1
admin/admin-web/src/main/resources/public/static/js/chunk-37c49cbf.64d26540.js	1
admin/admin-web/src/main/resources/public/static/js/chunk-37c49cbf.92ebe0ae.js	1
charts/canal-admin/Chart.yaml	6
charts/canal-admin/templates/_helpers.tpl	57
charts/canal-admin/templates/deployment.yaml	75
charts/canal-admin/templates/hpa.yaml	32
charts/canal-admin/templates/ingress.yaml	43
charts/canal-admin/templates/secret.yaml	9
charts/canal-admin/templates/service.yaml	15
charts/canal-admin/templates/serviceaccount.yaml	13
charts/canal-admin/values.yaml	70
charts/canal-server/Chart.yaml	6
charts/canal-server/templates/_helpers.tpl	57
charts/canal-server/templates/hpa.yaml	32
charts/canal-server/templates/secret.yaml	9
charts/canal-server/templates/service.yaml	23
charts/canal-server/templates/serviceaccount.yaml	13
charts/canal-server/templates/statefulsets.yaml	80
charts/canal-server/values.yaml	63
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/ClickHouseAdapter.java	255
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/ConfigLoader.java	30
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/MappingConfig.java	163
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config/MirrorDbConfig.java	33
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/monitor/ClickHouseConfigMonitor.java	102
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseBatchSyncService.java	418
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseEtlService.java	153
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service/ClickHouseMirrorDbBatchSyncService.java	127
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/BatchExecutor.java	91
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SingleDml.java	92
client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/support/SyncUtil.java	275
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/OuterAdapter.java	23
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/ProxyOuterAdapter.java	75
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/AbstractEtlService.java	101
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/AdapterConfig.java	8
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/CanalClientConfig.java	202
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Constant.java	4
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/DaemonThreadFactory.java	11
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/DatasourceConfig.java	56
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Dml.java	107
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/EtlResult.java	26
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/ExtensionLoader.java	344
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/FileName2KeyMapping.java	18
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/JdbcTypeUtil.java	153
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MappingConfigsLoader.java	62
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/MessageUtil.java	172
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/OuterAdapterConfig.java	39
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Result.java	39
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/SPI.java	12
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/URLClassExtensionLoader.java	68
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/Util.java	308
client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support/YamlUtils.java	92
client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/ES6xAdapter.java	103
client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/etl/ESEtlService.java	171
client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ES6xTemplate.java	400
client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support/ESConnection.java	426
client-adapter/es6x/src/main/java/org/elasticsearch/client/RequestConvertersExt.java	12
client-adapter/es6x/src/main/java/org/elasticsearch/client/RestHighLevelClientExt.java	16
client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/ES7xAdapter.java	102
client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/etl/ESEtlService.java	173
client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ES7xTemplate.java	394
client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support/ESConnection.java	427
client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/ES8xAdapter.java	97
client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/etl/ESEtlService.java	173
client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ES8xTemplate.java	391
client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support/ESConnection.java	332
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/ESAdapter.java	162
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config/ESSyncConfig.java	187
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config/ESSyncConfigLoader.java	32
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config/SchemaItem.java	338
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config/SqlParser.java	225
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/monitor/ESConfigMonitor.java	110
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/service/ESSyncService.java	680
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/support/ESBulkRequest.java	25
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/support/ESSyncUtil.java	283
client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/support/ESTemplate.java	21
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/HbaseAdapter.java	235
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/config/MappingConfig.java	316
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/config/MappingConfigLoader.java	30
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/monitor/HbaseConfigMonitor.java	98
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseEtlService.java	238
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service/HbaseSyncService.java	346
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/HRow.java	58
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/HbaseTemplate.java	144
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/PhType.java	61
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/PhTypeUtil.java	543
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/Type.java	55
client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support/TypeUtil.java	175
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/KuduAdapter.java	209
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/config/KuduMappingConfig.java	145
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/config/KuduMappingConfigLoader.java	30
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/monitor/KuduConfigMonitor.java	99
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/service/KuduEtlService.java	108
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/service/KuduSyncService.java	155
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/support/KuduTemplate.java	336
client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/support/SyncUtil.java	44
client-adapter/launcher/src/main/assembly/dev.xml	96
client-adapter/launcher/src/main/assembly/release.xml	101
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/CanalAdapterApplication.java	14
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/common/EtlLock.java	97
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/common/Mode.java	5
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/common/SyncSwitch.java	206
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/AdapterCanalConfig.java	61
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/AdapterConfigHolder.java	26
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/BootstrapConfiguration.java	27
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/CuratorClient.java	30
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/DruidConfig.java	18
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/config/SpringContext.java	18
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/AdapterProcessor.java	227
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterLoader.java	111
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/loader/CanalAdapterService.java	75
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/ApplicationConfigMonitor.java	72
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/ConfigItem.java	38
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/DbRemoteConfigLoader.java	189
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/RemoteAdapterMonitor.java	6
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/RemoteAdapterMonitorImpl.java	46
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/RemoteConfigLoader.java	7
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/monitor/remote/RemoteConfigLoaderFactory.java	22
client-adapter/launcher/src/main/java/com/alibaba/otter/canal/adapter/launcher/rest/CommonRest.java	153
client-adapter/launcher/src/main/resources/logback.xml	75
client-adapter/logger/src/main/java/com/alibaba/otter/canal/client/adapter/logger/LoggerAdapterExample.java	29
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/PhoenixAdapter.java	247
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/config/ConfigLoader.java	31
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/config/ConfigurationManager.java	27
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/config/MappingConfig.java	223
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/monitor/PhoenixConfigMonitor.java	102
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service/PhoenixEtlService.java	363
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service/PhoenixSyncService.java	528
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/BatchExecutor.java	91
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/PhoenixSupportUtil.java	79
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/SingleDml.java	76
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/SyncUtil.java	255
client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/support/TypeUtil.java	125
client-adapter/phoenix/src/main/resources/hbase-site.xml	72
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/RdbAdapter.java	254
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/ConfigLoader.java	30
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/MappingConfig.java	163
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config/MirrorDbConfig.java	33
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/monitor/RdbConfigMonitor.java	102
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbEtlService.java	150
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbMirrorDbSyncService.java	121
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service/RdbSyncService.java	405
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/BatchExecutor.java	76
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SingleDml.java	92
client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support/SyncUtil.java	291
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/TablestoreAdapter.java	276
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/common/PropertyConstants.java	7
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/config/ConfigLoader.java	32
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/config/MappingConfig.java	236
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/enums/TablestoreFieldType.java	8
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/service/TablestoreEtlService.java	107
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/service/TablestoreSyncService.java	268
client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/support/SyncUtil.java	190
client/src/main/java/com/alibaba/otter/canal/client/CanalConnector.java	19
client/src/main/java/com/alibaba/otter/canal/client/CanalConnectors.java	37
client/src/main/java/com/alibaba/otter/canal/client/CanalMQConnector.java	14
client/src/main/java/com/alibaba/otter/canal/client/CanalMessageDeserializer.java	51
client/src/main/java/com/alibaba/otter/canal/client/CanalNodeAccessStrategy.java	6
client/src/main/java/com/alibaba/otter/canal/client/ConsumerBatchMessage.java	32
client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterCanalConnector.java	300
client/src/main/java/com/alibaba/otter/canal/client/impl/ClusterNodeAccessStrategy.java	86
client/src/main/java/com/alibaba/otter/canal/client/impl/ServerNotFoundException.java	20
client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleCanalConnector.java	476
client/src/main/java/com/alibaba/otter/canal/client/impl/SimpleNodeAccessStrategy.java	27
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningData.java	24
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningListener.java	6
client/src/main/java/com/alibaba/otter/canal/client/impl/running/ClientRunningMonitor.java	189
client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaCanalConnector.java	251
client/src/main/java/com/alibaba/otter/canal/client/kafka/KafkaOffsetCanalConnector.java	67
client/src/main/java/com/alibaba/otter/canal/client/kafka/MessageDeserializer.java	17
client/src/main/java/com/alibaba/otter/canal/client/kafka/protocol/KafkaFlatMessage.java	18
client/src/main/java/com/alibaba/otter/canal/client/kafka/protocol/KafkaMessage.java	18
client/src/main/java/com/alibaba/otter/canal/client/pulsarmq/PulsarMQCanalConnector.java	291
client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/AliyunCredentialsProvider.java	27
client/src/main/java/com/alibaba/otter/canal/client/rabbitmq/RabbitMQCanalConnector.java	250
client/src/main/java/com/alibaba/otter/canal/client/rocketmq/RocketMQCanalConnector.java	284
codeformat.xml	291
codetemplates.xml	27
common/src/main/java/com/alibaba/otter/canal/common/AbstractCanalLifeCycle.java	19
common/src/main/java/com/alibaba/otter/canal/common/CanalException.java	23
common/src/main/java/com/alibaba/otter/canal/common/CanalLifeCycle.java	6
common/src/main/java/com/alibaba/otter/canal/common/alarm/CanalAlarmHandler.java	5
common/src/main/java/com/alibaba/otter/canal/common/alarm/LogAlarmHandler.java	10
common/src/main/java/com/alibaba/otter/canal/common/utils/AddressUtils.java	80
common/src/main/java/com/alibaba/otter/canal/common/utils/BooleanMutex.java	77
common/src/main/java/com/alibaba/otter/canal/common/utils/CanalToStringStyle.java	28
common/src/main/java/com/alibaba/otter/canal/common/utils/CommonUtils.java	34
common/src/main/java/com/alibaba/otter/canal/common/utils/ExecutorTemplate.java	63
common/src/main/java/com/alibaba/otter/canal/common/utils/FileUtils.java	105
common/src/main/java/com/alibaba/otter/canal/common/utils/JsonUtils.java	60
common/src/main/java/com/alibaba/otter/canal/common/utils/MQUtil.java	48
common/src/main/java/com/alibaba/otter/canal/common/utils/NamedThreadFactory.java	42
common/src/main/java/com/alibaba/otter/canal/common/utils/PropertiesUtils.java	24
common/src/main/java/com/alibaba/otter/canal/common/utils/UriUtils.java	66
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ByteSerializer.java	20
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/StringSerializer.java	20
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZkClientx.java	86
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZooKeeperx.java	95
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/ZookeeperPathUtils.java	91
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/running/ServerRunningData.java	37
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/running/ServerRunningListener.java	7
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/running/ServerRunningMonitor.java	218
common/src/main/java/com/alibaba/otter/canal/common/zookeeper/running/ServerRunningMonitors.java	21
common/src/main/java/com/google/common/collect/MigrateMap.java	106
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/config/CanalConstants.java	15
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/config/MQProperties.java	80
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/consumer/CommonMessage.java	93
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/AviaterRegexFilter.java	72
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/PatternUtils.java	28
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/filter/RegexFunction.java	19
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/AbstractMQProducer.java	101
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQDestination.java	59
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer/MQMessageUtils.java	575
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/CanalMQProducer.java	13
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/CanalMsgConsumer.java	14
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/ExtensionLoader.java	356
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/ProxyCanalMQProducer.java	56
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/ProxyCanalMsgConsumer.java	73
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/SPI.java	12
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi/URLClassExtensionLoader.java	66
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/Callback.java	5
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/CanalMessageSerializerUtil.java	106
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/DateUtil.java	33
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/JdbcTypeUtil.java	153
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/MessageUtil.java	113
connector/core/src/main/java/com/alibaba/otter/canal/connector/core/util/TimeZone.java	19
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/config/KafkaConstants.java	7
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/config/KafkaProducerConfig.java	34
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/consumer/CanalKafkaConsumer.java	120
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/consumer/KafkaMessageDeserializer.java	17
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/producer/CanalKafkaProducer.java	232
connector/kafka-connector/src/main/java/com/alibaba/otter/canal/connector/kafka/producer/KafkaMessageSerializer.java	15
connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/config/PulsarMQConstants.java	19
connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/config/PulsarMQProducerConfig.java	53
connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/consumer/CanalPulsarMQConsumer.java	203
connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/producer/CanalPulsarMQProducer.java	350
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/config/RabbitMQConstants.java	13
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/config/RabbitMQProducerConfig.java	60
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/CanalRabbitMQConsumer.java	190
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/consumer/ConsumerBatchMessage.java	32
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/AliyunCredentialsProvider.java	27
connector/rabbitmq-connector/src/main/java/com/alibaba/otter/canal/connector/rabbitmq/producer/CanalRabbitMQProducer.java	191
connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/config/RocketMQConstants.java	15
connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/config/RocketMQProducerConfig.java	60
connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/CanalRocketMQConsumer.java	209
connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/consumer/ConsumerBatchMessage.java	32
connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer/CanalRocketMQProducer.java	328
connector/tcp-connector/src/main/java/com/alibaba/otter/canal/connector/tcp/config/TCPConstants.java	9
connector/tcp-connector/src/main/java/com/alibaba/otter/canal/connector/tcp/consumer/CanalTCPConsumer.java	85
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/CharsetConversion.java	381
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/DirectLogFetcher.java	253
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/FileLogFetcher.java	103
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/JsonConversion.java	352
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/JsonDiffConversion.java	116
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogBuffer.java	1058
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogContext.java	70
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogDecoder.java	413
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogEvent.java	239
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogFetcher.java	30
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/LogPosition.java	54
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/NameCache.java	152
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/AppendBlockLogEvent.java	29
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/BeginLoadQueryLogEvent.java	7
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/CreateFileLogEvent.java	35
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/DeleteFileLogEvent.java	16
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/DeleteRowsLogEvent.java	11
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/ExecuteLoadLogEvent.java	16
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/ExecuteLoadQueryLogEvent.java	43
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/FormatDescriptionLogEvent.java	226
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/GtidLogEvent.java	55
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/HeartbeatLogEvent.java	24
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/HeartbeatV2LogEvent.java	15
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/IgnorableLogEvent.java	8
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/IncidentLogEvent.java	31
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/IntvarLogEvent.java	28
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/LoadLogEvent.java	130
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/LogHeader.java	124
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/PreviousGtidsLogEvent.java	8
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/QueryLogEvent.java	400
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RandLogEvent.java	19
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RotateLogEvent.java	41
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogBuffer.java	906
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsLogEvent.java	130
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/RowsQueryLogEvent.java	17
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/StartLogEventV3.java	25
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/StopLogEvent.java	8
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/TableMapLogEvent.java	399
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/TransactionContextLogEvent.java	8
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/TransactionPayloadLogEvent.java	66
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/UnknownLogEvent.java	7
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/UpdateRowsLogEvent.java	15
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/UserVarLogEvent.java	77
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/ViewChangeEvent.java	8
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/WriteRowsLogEvent.java	11
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/XaPrepareLogEvent.java	45
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/XidLogEvent.java	14
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/AnnotateRowsEvent.java	20
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/BinlogCheckPointLogEvent.java	19
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/DeleteRowsCompressLogEvent.java	10
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/MariaGtidListLogEvent.java	25
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/MariaGtidLogEvent.java	20
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/QueryCompressedLogEvent.java	12
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/StartEncryptionLogEvent.java	10
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/UpdateRowsCompressLogEvent.java	10
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event/mariadb/WriteRowsCompressLogEvent.java	10
dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/exception/TableIdNotFoundException.java	20
deployer/src/main/assembly/dev.xml	54
deployer/src/main/assembly/release.xml	58
deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalConstants.java	50
deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalController.java	520
deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalLauncher.java	112
deployer/src/main/java/com/alibaba/otter/canal/deployer/CanalStarter.java	124
deployer/src/main/java/com/alibaba/otter/canal/deployer/InstanceConfig.java	67
deployer/src/main/java/com/alibaba/otter/canal/deployer/admin/CanalAdminController.java	220
deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/InstanceAction.java	7
deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/InstanceConfigMonitor.java	6
deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/ManagerInstanceConfigMonitor.java	150
deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor/SpringInstanceConfigMonitor.java	226
deployer/src/main/resources/logback.xml	106
deployer/src/main/resources/spring/base-instance.xml	35
deployer/src/main/resources/spring/default-instance.xml	201
deployer/src/main/resources/spring/file-instance.xml	188
deployer/src/main/resources/spring/group-instance.xml	285
deployer/src/main/resources/spring/memory-instance.xml	176
deployer/src/main/resources/spring/tsdb/h2-tsdb.xml	53
deployer/src/main/resources/spring/tsdb/mysql-tsdb.xml	55
deployer/src/main/resources/spring/tsdb/sql-map/sqlmap-config.xml	13
deployer/src/main/resources/spring/tsdb/sql-map/sqlmap_history.xml	39
deployer/src/main/resources/spring/tsdb/sql-map/sqlmap_snapshot.xml	43
deployer/src/main/resources/spring/tsdb/sql/create_table.sql	38
docker/image/alidata/init/fix-hosts.py	42
docker/image/canal_manager.sql	78
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlConnector.java	449
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlQueryExecutor.java	126
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/MysqlUpdateExecutor.java	35
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/Capability.java	28
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/CommandPacket.java	15
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/GTIDSet.java	6
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/HeaderPacket.java	37
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/IPacket.java	6
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MariaGTIDSet.java	46
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MariaGtid.java	56
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/MysqlGTIDSet.java	69
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/PacketWithHeaderPacket.java	22
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/UUIDSet.java	129
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/AuthSwitchResponsePacket.java	14
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/BinlogDumpCommandPacket.java	32
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/BinlogDumpGTIDCommandPacket.java	32
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/ClientAuthenticationPacket.java	98
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/ClientAuthenticationSHA2Packet.java	46
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QueryCommandPacket.java	24
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/QuitCommandPacket.java	18
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/RegisterSlaveCommandPacket.java	40
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/SemiAckCommandPacket.java	24
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/client/SslRequestCommandPacket.java	30
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/AuthSwitchRequestMoreData.java	17
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/AuthSwitchRequestPacket.java	21
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/DataPacket.java	10
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/EOFPacket.java	25
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/ErrorPacket.java	38
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/FieldPacket.java	127
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/HandshakeInitializationPacket.java	59
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/OKPacket.java	71
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/Reply323Packet.java	19
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/ResultSetHeaderPacket.java	35
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/ResultSetPacket.java	31
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server/RowDataPacket.java	28
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java	155
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannelPool.java	252
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/NettySocketChannel.java	193
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/NettySocketChannelPool.java	86
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannel.java	13
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java	53
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/ssl/SslInfo.java	74
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/ssl/SslMode.java	8
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/BinlogDumpCommandBuilder.java	30
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/ByteHelper.java	147
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/ChannelBufferHelper.java	50
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/CharsetUtil.java	193
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/GtidUtil.java	13
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/LengthCodedStringReader.java	32
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/MSC.java	14
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/MySQLPasswordEncrypter.java	124
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/utils/PacketManager.java	39
example/src/main/assembly/dev.xml	54
example/src/main/assembly/release.xml	54
example/src/main/conf/logback.xml	63
example/src/main/java/com/alibaba/otter/canal/example/AbstractCanalClientTest.java	67
example/src/main/java/com/alibaba/otter/canal/example/BaseCanalClientTest.java	216
example/src/main/java/com/alibaba/otter/canal/example/ClusterCanalClientTest.java	25
example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientPermanceTest.java	59
example/src/main/java/com/alibaba/otter/canal/example/SimpleCanalClientTest.java	29
example/src/main/java/com/alibaba/otter/canal/example/kafka/AbstractKafkaTest.java	15
example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientExample.java	102
example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaClientFlatMessageExample.java	102
example/src/main/java/com/alibaba/otter/canal/example/kafka/CanalKafkaOffsetClientExample.java	114
example/src/main/java/com/alibaba/otter/canal/example/kafka/KafkaClientRunningTest.java	34
example/src/main/java/com/alibaba/otter/canal/example/rocketmq/AbstractRocektMQTest.java	12
example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientExample.java	111
example/src/main/java/com/alibaba/otter/canal/example/rocketmq/CanalRocketMQClientFlatMessageExample.java	92
example/src/main/resources/logback.xml	21
filter/src/main/java/com/alibaba/otter/canal/filter/CanalEventFilter.java	5
filter/src/main/java/com/alibaba/otter/canal/filter/PatternUtils.java	28
filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterELFilter.java	23
filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterRegexFilter.java	74
filter/src/main/java/com/alibaba/otter/canal/filter/aviater/AviaterSimpleFilter.java	37
filter/src/main/java/com/alibaba/otter/canal/filter/aviater/RegexFunction.java	20
filter/src/main/java/com/alibaba/otter/canal/filter/exception/CanalFilterException.java	20
instance/core/src/main/java/com/alibaba/otter/canal/instance/core/AbstractCanalInstance.java	191
instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalInstance.java	18
instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalInstanceGenerator.java	4
instance/core/src/main/java/com/alibaba/otter/canal/instance/core/CanalMQConfig.java	52
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalConfigClient.java	10
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/CanalInstanceWithManager.java	414
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/ManagerCanalInstanceGenerator.java	15
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/PlainCanalInstanceGenerator.java	64
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model/Canal.java	60
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model/CanalParameter.java	868
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model/CanalStatus.java	11
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/HttpHelper.java	146
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanal.java	36
instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/plain/PlainCanalConfigClient.java	123
instance/spring/src/main/java/com/alibaba/otter/canal/instance/spring/CanalInstanceWithSpring.java	41
instance/spring/src/main/java/com/alibaba/otter/canal/instance/spring/SpringCanalInstanceGenerator.java	45
instance/spring/src/main/java/com/alibaba/otter/canal/instance/spring/support/PropertyPlaceholderConfigurer.java	136
instance/spring/src/main/java/com/alibaba/otter/canal/instance/spring/support/SocketAddressEditor.java	23
meta/src/main/java/com/alibaba/otter/canal/meta/CanalMetaManager.java	25
meta/src/main/java/com/alibaba/otter/canal/meta/FileMixedMetaManager.java	260
meta/src/main/java/com/alibaba/otter/canal/meta/MemoryMetaManager.java	156
meta/src/main/java/com/alibaba/otter/canal/meta/MixedMetaManager.java	99
meta/src/main/java/com/alibaba/otter/canal/meta/PeriodMixedMetaManager.java	100
meta/src/main/java/com/alibaba/otter/canal/meta/ZooKeeperMetaManager.java	257
meta/src/main/java/com/alibaba/otter/canal/meta/exception/CanalMetaManagerException.java	20
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
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/CanalInstanceExports.java	69
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/InstanceRegistry.java	6
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/PrometheusProvider.java	9
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/PrometheusService.java	100
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/EntryCollector.java	114
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/MetaCollector.java	74
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/ParserCollector.java	134
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusCanalEventDownStreamHandler.java	71
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/PrometheusClientInstanceProfiler.java	124
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/SinkCollector.java	70
prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl/StoreCollector.java	176
protocol/src/main/java/com/alibaba/otter/canal/protocol/AdminProtocol.proto	74
protocol/src/main/java/com/alibaba/otter/canal/protocol/CanalProtocol.proto	136
protocol/src/main/java/com/alibaba/otter/canal/protocol/ClientIdentity.java	79
protocol/src/main/java/com/alibaba/otter/canal/protocol/EntryProtocol.proto	172
protocol/src/main/java/com/alibaba/otter/canal/protocol/FlatMessage.java	123
protocol/src/main/java/com/alibaba/otter/canal/protocol/Message.java	65
protocol/src/main/java/com/alibaba/otter/canal/protocol/SecurityUtil.java	208
protocol/src/main/java/com/alibaba/otter/canal/protocol/exception/CanalClientException.java	20
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/EntryPosition.java	110
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/LogIdentity.java	53
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/LogPosition.java	54
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/MetaqPosition.java	31
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/Position.java	10
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/PositionRange.java	89
protocol/src/main/java/com/alibaba/otter/canal/protocol/position/TimePosition.java	42
server/src/main/java/com/alibaba/otter/canal/admin/CanalAdmin.java	18
server/src/main/java/com/alibaba/otter/canal/admin/handler/ClientAuthenticationHandler.java	87
server/src/main/java/com/alibaba/otter/canal/admin/handler/HandshakeInitializationHandler.java	39
server/src/main/java/com/alibaba/otter/canal/admin/handler/SessionHandler.java	145
server/src/main/java/com/alibaba/otter/canal/admin/netty/AdminNettyUtils.java	52
server/src/main/java/com/alibaba/otter/canal/admin/netty/CanalAdminWithNetty.java	78
server/src/main/java/com/alibaba/otter/canal/server/CanalMQStarter.java	205
server/src/main/java/com/alibaba/otter/canal/server/CanalServer.java	7
server/src/main/java/com/alibaba/otter/canal/server/CanalServerStarter.java	4
server/src/main/java/com/alibaba/otter/canal/server/CanalService.java	17
server/src/main/java/com/alibaba/otter/canal/server/embedded/CanalServerWithEmbedded.java	395
server/src/main/java/com/alibaba/otter/canal/server/exception/CanalServerException.java	20
server/src/main/java/com/alibaba/otter/canal/server/netty/CanalServerWithNetty.java	86
server/src/main/java/com/alibaba/otter/canal/server/netty/CanalServerWithNettyProfiler.java	26
server/src/main/java/com/alibaba/otter/canal/server/netty/ClientInstanceProfiler.java	6
server/src/main/java/com/alibaba/otter/canal/server/netty/NettyUtils.java	85
server/src/main/java/com/alibaba/otter/canal/server/netty/handler/ClientAuthenticationHandler.java	110
server/src/main/java/com/alibaba/otter/canal/server/netty/handler/FixedHeaderFrameDecoder.java	12
server/src/main/java/com/alibaba/otter/canal/server/netty/handler/HandshakeInitializationHandler.java	38
server/src/main/java/com/alibaba/otter/canal/server/netty/handler/SessionHandler.java	330
server/src/main/java/com/alibaba/otter/canal/server/netty/listener/ChannelFutureAggregator.java	139
server/src/main/java/com/alibaba/otter/canal/spi/CanalMetricsProvider.java	4
server/src/main/java/com/alibaba/otter/canal/spi/CanalMetricsService.java	10
server/src/main/java/com/alibaba/otter/canal/spi/NopCanalMetricsService.java	25
sink/src/main/java/com/alibaba/otter/canal/sink/AbstractCanalEventDownStreamHandler.java	13
sink/src/main/java/com/alibaba/otter/canal/sink/AbstractCanalEventSink.java	35
sink/src/main/java/com/alibaba/otter/canal/sink/CanalEventDownStreamHandler.java	7
sink/src/main/java/com/alibaba/otter/canal/sink/CanalEventSink.java	10
sink/src/main/java/com/alibaba/otter/canal/sink/entry/EntryEventSink.java	185
sink/src/main/java/com/alibaba/otter/canal/sink/entry/HeartBeatEntryEventHandler.java	28
sink/src/main/java/com/alibaba/otter/canal/sink/entry/group/GroupBarrier.java	9
sink/src/main/java/com/alibaba/otter/canal/sink/entry/group/GroupEventSink.java	48
sink/src/main/java/com/alibaba/otter/canal/sink/entry/group/TimelineBarrier.java	75
sink/src/main/java/com/alibaba/otter/canal/sink/entry/group/TimelineTransactionBarrier.java	77
sink/src/main/java/com/alibaba/otter/canal/sink/exception/CanalSinkException.java	20
store/src/main/java/com/alibaba/otter/canal/store/AbstractCanalGroupStore.java	17
store/src/main/java/com/alibaba/otter/canal/store/AbstractCanalStoreScavenge.java	80
store/src/main/java/com/alibaba/otter/canal/store/CanalEventStore.java	23
store/src/main/java/com/alibaba/otter/canal/store/CanalGroupEventStore.java	4
store/src/main/java/com/alibaba/otter/canal/store/CanalStoreConstants.java	8
store/src/main/java/com/alibaba/otter/canal/store/CanalStoreException.java	20
store/src/main/java/com/alibaba/otter/canal/store/CanalStoreScavenge.java	6
store/src/main/java/com/alibaba/otter/canal/store/StoreInfo.java	17
store/src/main/java/com/alibaba/otter/canal/store/helper/CanalEventUtils.java	65
store/src/main/java/com/alibaba/otter/canal/store/memory/MemoryEventStoreWithBuffer.java	547
store/src/main/java/com/alibaba/otter/canal/store/model/BatchMode.java	11
store/src/main/java/com/alibaba/otter/canal/store/model/Event.java	133
store/src/main/java/com/alibaba/otter/canal/store/model/Events.java	27