alibaba / canal
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
1% | 12% | 36% | 22% | 26%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java1% | 14% | 38% | 22% | 23%
vue0% | 0% | 42% | 24% | 33%
xml0% | 0% | 33% | 24% | 41%
proto0% | 0% | 0% | 80% | 19%
js0% | 0% | 0% | 18% | 81%
scss0% | 0% | 0% | 49% | 50%
yaml0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
tpl0% | 0% | 0% | 0% | 100%
py0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
css0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
dbsync16% | 14% | 41% | 11% | 15%
parse0% | 37% | 26% | 19% | 16%
client-adapter0% | 9% | 51% | 23% | 14%
instance0% | 38% | 18% | 26% | 16%
connector0% | 13% | 38% | 22% | 26%
store0% | 57% | 0% | 13% | 29%
deployer0% | 18% | 32% | 30% | 18%
client0% | 0% | 73% | 7% | 18%
admin0% | 0% | 24% | 22% | 53%
server0% | 0% | 47% | 20% | 31%
driver0% | 0% | 20% | 35% | 43%
meta0% | 0% | 56% | 17% | 26%
ROOT0% | 0% | 91% | 0% | 8%
common0% | 0% | 15% | 15% | 69%
example0% | 0% | 18% | 36% | 44%
protocol0% | 0% | 16% | 42% | 40%
prometheus0% | 0% | 0% | 57% | 42%
sink0% | 0% | 0% | 36% | 63%
charts0% | 0% | 0% | 0% | 100%
filter0% | 0% | 0% | 0% | 100%
docker0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
LogBuffer.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
1058 104
RowsLogBuffer.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
906 18
LogEventConvert.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync
894 48
CanalParameter.java
in instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model
868 201
MysqlEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
774 51
ESSyncService.java
in client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/service
680 15
MysqlConnection.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
600 59
MQMessageUtils.java
in connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer
575 9
MemoryEventStoreWithBuffer.java
in store/src/main/java/com/alibaba/otter/canal/store/memory
547 48
AbstractEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound
546 51
PhTypeUtil.java
in client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support
543 33
DatabaseTableMeta.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb
535 33
PhoenixSyncService.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service
528 13
CanalController.java
in deployer/src/main/java/com/alibaba/otter/canal/deployer
520 18
SimpleCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/impl
476 40
MysqlMultiStageCoprocessor.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
459 46
NodeServer.vue
in admin/admin-ui/src/views/canalServer
456 -
MysqlConnector.java
in driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql
449 40
ESConnection.java
in client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support
427 52
ESConnection.java
in client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support
426 52
ClickHouseBatchSyncService.java
in client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service
418 17
CanalInstanceWithManager.java
in instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager
414 14
LogDecoder.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
413 7
RdbSyncService.java
in client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service
405 17
QueryLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
400 28
ES6xTemplate.java
in client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support
400 20
TableMapLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
399 24
CanalServerWithEmbedded.java
in server/src/main/java/com/alibaba/otter/canal/server/embedded
395 29
ES7xTemplate.java
in client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support
394 20
ES8xTemplate.java
in client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support
391 20
CharsetConversion.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
381 9
LocalBinLogConnection.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
378 28
PhoenixEtlService.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service
363 7
ExtensionLoader.java
in connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi
356 16
JsonConversion.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
352 13
CanalPulsarMQProducer.java
in connector/pulsarmq-connector/src/main/java/com/alibaba/otter/canal/connector/pulsarmq/producer
350 11
HbaseSyncService.java
in client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/service
346 8
ExtensionLoader.java
in client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support
344 15
SchemaItem.java
in client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config
338 57
KuduTemplate.java
in client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/support
336 10
ESConnection.java
in client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support
332 50
SessionHandler.java
in server/src/main/java/com/alibaba/otter/canal/server/netty/handler
330 8
HttpHelper.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds
328 6
CanalRocketMQProducer.java
in connector/rocketmq-connector/src/main/java/com/alibaba/otter/canal/connector/rocketmq/producer
328 8
MappingConfig.java
in client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/config
316 63
Util.java
in client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support
308 17
ClusterCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/impl
300 31
BinlogDownloadQueue.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds
295 15
PulsarMQCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/pulsarmq
291 23
SyncUtil.java
in client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/support
291 6
Files With Most Units (Top 50)
File# lines# units
CanalParameter.java
in instance/manager/src/main/java/com/alibaba/otter/canal/instance/manager/model
868 201
LogBuffer.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
1058 104
MappingConfig.java
in client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/config
316 63
MysqlConnection.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
600 59
SchemaItem.java
in client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config
338 57
CanalClientConfig.java
in client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support
202 54
MappingConfig.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/config
223 52
ESConnection.java
in client-adapter/es6x/src/main/java/com/alibaba/otter/canal/client/adapter/es6x/support
426 52
ESConnection.java
in client-adapter/es7x/src/main/java/com/alibaba/otter/canal/client/adapter/es7x/support
427 52
MysqlEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
774 51
AbstractEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound
546 51
ESConnection.java
in client-adapter/es8x/src/main/java/com/alibaba/otter/canal/client/adapter/es8x/support
332 50
LogEventConvert.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync
894 48
MemoryEventStoreWithBuffer.java
in store/src/main/java/com/alibaba/otter/canal/store/memory
547 48
MysqlMultiStageCoprocessor.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
459 46
ESSyncConfig.java
in client-adapter/escore/src/main/java/com/alibaba/otter/canal/client/adapter/es/core/config
187 46
MappingConfig.java
in client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/config
236 44
MysqlConnector.java
in driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql
449 40
SimpleCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/impl
476 40
MappingConfig.java
in client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/config
163 40
MappingConfig.java
in client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/config
163 40
AbstractMysqlEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
240 37
KuduMappingConfig.java
in client-adapter/kudu/src/main/java/com/alibaba/otter/canal/client/adapter/kudu/config
145 36
TableMeta.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound
152 34
DatabaseTableMeta.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb
535 33
PhTypeUtil.java
in client-adapter/hbase/src/main/java/com/alibaba/otter/canal/client/adapter/hbase/support
543 33
ClusterCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/impl
300 31
FlatMessage.java
in protocol/src/main/java/com/alibaba/otter/canal/protocol
123 30
MemoryMetaManager.java
in meta/src/main/java/com/alibaba/otter/canal/meta
156 30
MetaHistoryDO.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao
110 29
CanalServerWithEmbedded.java
in server/src/main/java/com/alibaba/otter/canal/server/embedded
395 29
QueryLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
400 28
LocalBinLogConnection.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
378 28
FileMixedMetaManager.java
in meta/src/main/java/com/alibaba/otter/canal/meta
260 28
Event.java
in store/src/main/java/com/alibaba/otter/canal/store/model
133 27
SpringInstanceConfigMonitor.java
in deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor
226 27
FieldPacket.java
in driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/packets/server
127 26
CanalInstanceConfig.java
in admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model
117 26
TableMapLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
399 24
SimpleAdminConnector.java
in admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/connector
267 24
Dml.java
in client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support
107 24
ChannelFutureAggregator.java
in server/src/main/java/com/alibaba/otter/canal/server/netty/listener
139 24
RocketMQCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/rocketmq
284 23
PulsarMQCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/pulsarmq
291 23
AuthenticationInfo.java
in parse/src/main/java/com/alibaba/otter/canal/parse/support
135 22
NodeServer.java
in admin/admin-web/src/main/java/com/alibaba/otter/canal/admin/model
99 22
MQProperties.java
in connector/core/src/main/java/com/alibaba/otter/canal/connector/core/config
80 22
MetaSnapshotDO.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb/dao
81 21
KafkaCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/kafka
251 21
LogHeader.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
124 20
Files With Long Lines (Top 50)

There are 142 files with lines longer than 120 characters. In total, there are 480 long lines.

File# lines# units# long lines
291 - 56
MQMessageUtils.java
in connector/core/src/main/java/com/alibaba/otter/canal/connector/core/producer
575 9 30
group-instance.xml
in deployer/src/main/resources/spring
285 - 26
27 - 16
memory-instance.xml
in deployer/src/main/resources/spring
176 - 14
file-instance.xml
in deployer/src/main/resources/spring
188 - 14
default-instance.xml
in deployer/src/main/resources/spring
201 - 14
AbstractEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound
546 51 13
MysqlEventParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql
774 51 11
ExtensionLoader.java
in connector/core/src/main/java/com/alibaba/otter/canal/connector/core/spi
356 16 11
PhoenixEtlService.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service
363 7 9
ClickHouseBatchSyncService.java
in client-adapter/clickhouse/src/main/java/com/alibaba/otter/canal/client/adapter/clickhouse/service
418 17 9
ParserCollector.java
in prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl
134 8 9
ExtensionLoader.java
in client-adapter/common/src/main/java/com/alibaba/otter/canal/client/adapter/support
344 15 8
LogEventConvert.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync
894 48 7
PhoenixSyncService.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix/service
528 13 7
CanalServerWithEmbedded.java
in server/src/main/java/com/alibaba/otter/canal/server/embedded
395 29 7
NettySocketChannel.java
in driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket
193 9 5
EntryEventSink.java
in sink/src/main/java/com/alibaba/otter/canal/sink/entry
185 16 5
sqlmap_history.xml
in deployer/src/main/resources/spring/tsdb/sql-map
39 - 5
MixedMetaManager.java
in meta/src/main/java/com/alibaba/otter/canal/meta
99 11 5
FormatDescriptionLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
226 10 4
RocketMQCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/rocketmq
284 23 4
RdbSyncService.java
in client-adapter/rdb/src/main/java/com/alibaba/otter/canal/client/adapter/rdb/service
405 17 4
ChannelFutureAggregator.java
in server/src/main/java/com/alibaba/otter/canal/server/netty/listener
139 24 4
CanalController.java
in deployer/src/main/java/com/alibaba/otter/canal/deployer
520 18 4
mysql-tsdb.xml
in deployer/src/main/resources/spring/tsdb
55 - 4
DatabaseTableMeta.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/tsdb
535 33 3
NodeServer.vue
in admin/admin-ui/src/views/canalServer
456 - 3
TablestoreAdapter.java
in client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore
276 14 3
TablestoreSyncService.java
in client-adapter/tablestore/src/main/java/com/alibaba/otter/canal/client/adapter/tablestore/service
268 12 3
PhoenixAdapter.java
in client-adapter/phoenix/src/main/java/com/alibaba/otter/canal/client/adapter/phoenix
247 14 3
SessionHandler.java
in server/src/main/java/com/alibaba/otter/canal/server/netty/handler
330 8 3
EntryCollector.java
in prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl
114 7 3
StoreCollector.java
in prometheus/src/main/java/com/alibaba/otter/canal/prometheus/impl
176 5 3
SpringInstanceConfigMonitor.java
in deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor
226 27 3
ManagerInstanceConfigMonitor.java
in deployer/src/main/java/com/alibaba/otter/canal/deployer/monitor
150 13 3
h2-tsdb.xml
in deployer/src/main/resources/spring/tsdb
53 - 3
sqlmap_snapshot.xml
in deployer/src/main/resources/spring/tsdb/sql-map
43 - 3
base-instance.xml
in deployer/src/main/resources/spring
35 - 3
QueryLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
400 28 2
LoadLogEvent.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog/event
130 14 2
LogBuffer.java
in dbsync/src/main/java/com/taobao/tddl/dbsync/binlog
1058 104 2
BioSocketChannelPool.java
in driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket
252 9 2
SimpleDdlParser.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/ddl
163 7 2
HttpHelper.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds
328 6 2
BinlogDownloadQueue.java
in parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/rds
295 15 2
index.vue
in admin/admin-ui/src/views/login
211 - 2
dev.xml
in admin/admin-web/src/main/assembly
52 - 2
KafkaOffsetCanalConnector.java
in client/src/main/java/com/alibaba/otter/canal/client/kafka
67 4 2