apache / rocketmq-connect
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 793 files with 54,500 lines of code in files.
    • 492 files that are 366+ days old (31,337 lines of code)
    • 216 files that are 181-365 days old (16,443 lines of code)
    • 54 files that are 91-180 days old (3,411 lines of code)
    • 31 files that are 31-90 days old (3,309 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
57% | 30% | 6% | 6% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 793 files with 54,500 lines of code in files.
    • 275 files have been last changed 366+ days ago (9,581 lines of code)
    • 359 files have been last changed 181-365 days ago (25,405 lines of code)
    • 84 files have been last changed 91-180 days ago (9,920 lines of code)
    • 75 files have been last changed 31-90 days ago (9,594 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
17% | 46% | 18% | 17% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, md, sh, yaml, properties, txt, gitignore, avsc, py, json, yml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java56% | 30% | 6% | 6% | 0%
xml92% | 7% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
yaml100% | 0% | 0% | 0% | 0%
avsc100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java16% | 47% | 18% | 18% | 0%
xml72% | 7% | 19% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
avsc100% | 0% | 0% | 0% | 0%
yaml11% | 88% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
connectors55% | 28% | 4% | 10% | 0%
rocketmq-connect-runtime73% | 19% | 7% | 0% | 0%
transforms100% | 0% | 0% | 0% | 0%
rocketmq-connect-cli100% | 0% | 0% | 0% | 0%
rocketmq-connect-sample100% | 0% | 0% | 0% | 0%
style100% | 0% | 0% | 0% | 0%
distribution100% | 0% | 0% | 0% | 0%
schema-converter0% | 100% | 0% | 0% | 0%
metric-exporter0% | 0% | 100% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
connectors22% | 45% | 4% | 27% | 0%
rocketmq-connect-cli97% | 0% | 2% | 0% | 0%
rocketmq-connect-runtime4% | 51% | 36% | 7% | 0%
style100% | 0% | 0% | 0% | 0%
rocketmq-connect-sample49% | 5% | 45% | 0% | 0%
distribution100% | 0% | 0% | 0% | 0%
transforms13% | 86% | 0% | 0% | 0%
schema-converter0% | 55% | 44% | 0% | 0%
metric-exporter0% | 0% | 100% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
FileSinkTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 61 1 2019-08-01 2022-06-22 9 4 877036922@qq.com sunxiaojian926@163.com
Worker.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 739 44 2019-08-04 2023-04-21 44 13 877036922@qq.com 877036922@qq.com
RestHandler.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/rest
 260 17 2019-08-05 2022-12-26 20 11 877036922@qq.com yechun@corp.netease.com
FileSourceTask.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 212 4 2019-08-13 2023-04-04 11 8 877036922@qq.com clooker@163.com
logback.xml
in rocketmq-connect-runtime/src/main/resources
 174 - 2019-08-13 2023-03-24 6 2 877036922@qq.com 877036922@qq.com
ClusterManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 124 12 2019-08-13 2023-02-28 14 7 duhengforever@apache.org sunxiaojian926@163.com
package.xml
in rocketmq-connect-runtime/src/main/resources
 24 - 2019-08-13 2023-04-03 6 4 duhengforever@apache.org 877036922@qq.com
LoggerName.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 4 - 2019-08-13 2022-03-01 3 1 877036922@qq.com 877036922@qq.com
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33 2019-08-16 2023-05-15 40 14 san@chenyiliu.com sunxiaojian926@163.com
ConnectUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 398 24 2019-08-16 2023-04-14 20 9 san@chenyiliu.com 877036922@qq.com
BrokerBasedLog.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils/datasync
 296 17 2019-08-16 2023-02-28 14 8 san@chenyiliu.com sunxiaojian926@163.com
RebalanceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 73 4 2019-08-21 2023-05-16 17 9 duhengforever@apache.org 877036922@qq.com
DefaultAllocateConnAndTaskStrategy.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 60 2 2019-08-21 2022-09-28 7 4 duhengforever@apache.org sunxiaojian926@163.com
RebalanceService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 51 5 2019-08-21 2022-09-28 8 6 duhengforever@apache.org sunxiaojian926@163.com
ClusterManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 17 1 2019-08-21 2023-02-28 10 4 duhengforever@apache.org sunxiaojian926@163.com
AllocateConnAndTaskStrategy.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 9 - 2019-08-21 2022-09-28 4 3 duhengforever@apache.org sunxiaojian926@163.com
126 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
91 - 2019-08-28 2022-03-01 3 3 694201046@qq.com 877036922@qq.com
profiles_settings.xml
in style/copyright
 47 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
Apache.xml
in style/copyright
 7 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
ConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 29 1 2019-09-24 2023-02-28 14 6 zero.xu@bytedance.com sunxiaojian926@163.com
AllocateConnAndTaskStrategyByConsistentHash.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/strategy
 74 5 2019-10-22 2022-09-28 4 3 zero.xu@bytedance.com sunxiaojian926@163.com
WorkerSinkTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 671 36 2019-11-19 2022-12-26 30 13 877036922@qq.com ashen@moesrc.com
WorkerTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 253 31 2020-07-28 2022-09-28 7 4 affeisme@gmail.com sunxiaojian926@163.com
MemoryBasedKeyValueStore.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/store
 48 11 2020-07-28 2022-09-28 4 3 affeisme@gmail.com sunxiaojian926@163.com
WorkerTaskState.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 10 - 2020-07-28 2022-08-24 3 3 affeisme@gmail.com sunxiaojian926@163.com
ConnectAdminStartup.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli
 146 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
ConnectKeyValue.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 101 19 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
FileAndPropertyUtil.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 86 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedTasks.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 65 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
CreateConnectorSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 65 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedConnectors.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 59 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
ServerUtil.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 51 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
QueryConnectorStatusSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
QueryConnectorConfigSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
StopConnectorSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetClusterInfoSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
ReloadPluginsSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedInfoCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetConfigInfoSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
StopAllSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
RestSender.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 35 1 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
package.xml
in rocketmq-connect-cli/src/main/resources
 24 - 2020-09-20 2023-04-03 3 2 jliu_1996@163.com 877036922@qq.com
Config.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 17 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
SubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 10 - 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
CLIConfigDefine.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 4 - 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
PositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 27 2 2021-03-27 2023-02-28 10 4 30995057+git-yang@users.nor... sunxiaojian926@163.com
WorkerState.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 5 - 2021-08-18 2022-03-01 2 2 30995057+git-yang@users.nor... 877036922@qq.com
user.avsc
in rocketmq-connect-runtime/src/main/resources
 9 - 2021-09-09 2022-03-01 2 2 lizhiboo@yeah.net 877036922@qq.com
WorkerDirectTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 198 21 2021-10-26 2022-11-03 18 9 30995057+git-yang@users.nor... yechun@corp.netease.com
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
CLIConfigDefine.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 4 - 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
LoggerName.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 4 - 2019-08-13 2022-03-01 3 1 877036922@qq.com 877036922@qq.com
WorkerState.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 5 - 2021-08-18 2022-03-01 2 2 30995057+git-yang@users.nor... 877036922@qq.com
Apache.xml
in style/copyright
 7 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
user.avsc
in rocketmq-connect-runtime/src/main/resources
 9 - 2021-09-09 2022-03-01 2 2 lizhiboo@yeah.net 877036922@qq.com
SubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 10 - 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
FileConstants.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 10 1 2022-03-01 2022-03-01 1 1 877036922@qq.com 877036922@qq.com
Config.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 17 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
RestSender.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 35 1 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
StopAllSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetConfigInfoSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedInfoCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
ReloadPluginsSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetClusterInfoSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 37 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
StopConnectorSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
QueryConnectorConfigSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
QueryConnectorStatusSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 42 5 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
FileUtils.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 43 1 2022-03-01 2022-03-01 1 1 877036922@qq.com 877036922@qq.com
profiles_settings.xml
in style/copyright
 47 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
FileConfig.java
in rocketmq-connect-sample/src/main/java/org/apache/rocketmq/connect/file
 49 10 2022-03-01 2022-03-01 1 1 877036922@qq.com 877036922@qq.com
ServerUtil.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 51 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedConnectors.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 59 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
CreateConnectorSubCommand.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 65 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
GetAllocatedTasks.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/command
 65 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
FileAndPropertyUtil.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/utils
 86 4 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
91 - 2019-08-28 2022-03-01 3 3 694201046@qq.com 877036922@qq.com
ConnectKeyValue.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli/commom
 101 19 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
126 - 2019-08-28 2022-03-01 2 2 694201046@qq.com 877036922@qq.com
ConnectAdminStartup.java
in rocketmq-connect-cli/src/main/java/org/apache/rocketmq/connect/cli
 146 6 2020-09-20 2022-03-01 2 2 jliu_1996@163.com 877036922@qq.com
RedisEventProcessorCallback.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor
 4 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
DivideStrategyEnum.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/strategy
 5 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
DivideStrategyEnum.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/strategy
 5 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
Parser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 5 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
Apache.xml
in connectors/rocketmq-connect-redis/style/copyright
 6 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
ConstDefine.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common
 7 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
SyncMod.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common
 7 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
DataType.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 8 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
DataType.java
in connectors/rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/common
 8 - 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
SortParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
FlushDbParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
ScriptParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
LPopParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
BitFieldParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
PersistParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
XGroupParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
IncrParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
MultiParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
ExecParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
DecrParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
RPopParser.java
in connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser
 10 1 2022-03-02 2022-03-02 1 1 877036922@qq.com 877036922@qq.com
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
LoggerName.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common
 6 - 2023-05-17 2023-05-17 1 1 877036922@qq.com 877036922@qq.com
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultColumnConverter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter
 366 8 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 250 11 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DbStructure.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 221 7 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 178 23 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultJdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 170 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 166 18 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractJdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 111 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
OpenMLDBDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb
 96 10 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
CachedConnectionProvider.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection
 89 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DatabaseDialectLoader.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 87 9 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MySqlDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql
 87 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcWriter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 80 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 78 4 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
QueryContext.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 73 18 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
IncrementContext.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 63 11 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
SchemaMapping.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 63 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceConnector.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 55 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnMapping.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 52 7 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnDefAdjuster.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 48 2 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkConnector.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 36 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
TableLoadMode.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 25 3 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceTaskConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 15 2 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MysqlDatabaseDialectFactory.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql
 15 1 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
OpenMLDBDatabaseDialectFactory.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb
 15 1 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcColumnConverter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter
 10 - 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ConnectionProvider.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection
 9 - 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcUrlInfo.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 6 - 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 6 - 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
QueryMode.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 5 - 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ReplicatorCheckpointTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 247 12 2023-04-05 2023-05-17 5 2 877036922@qq.com 877036922@qq.com
ReplicatorCheckpointConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 151 8 2023-04-05 2023-05-17 4 2 877036922@qq.com 877036922@qq.com
TpsLimiter.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/stats
 57 4 2023-03-24 2023-03-24 1 1 877036922@qq.com 877036922@qq.com
UnAckMessage.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/context
 38 6 2023-03-24 2023-03-24 1 1 877036922@qq.com 877036922@qq.com
IotdbSourceTask.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector
 101 8 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbQuery.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source
 85 3 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbConfig.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config
 80 8 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
DeviceEntity.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source
 63 8 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbSourceConnector.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/connector
 62 4 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
SchemaProcessor.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config
 39 3 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbReplicator.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/replicator/source
 34 6 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbConstant.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/config
 9 1 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
IotdbRuntimeException.java
in connectors/rocketmq-connect-iotdb/src/main/java/org/apache/rocketmq/connect/iotdb/exception
 7 1 2023-03-14 2023-03-14 1 1 wqdyxnbd@163.com wqdyxnbd@163.com
AbstractStateManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 285 22 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractPositionManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 190 17 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
LocalStateManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local
 132 9 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
RetryUtil.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/utils
 123 8 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
RocketMQClientUtil.java
in metric-exporter/src/main/java/org/apache/rocketmq/connect/metrics/reporter
 122 8 2023-02-28 2023-04-14 2 2 sunxiaojian926@163.com 877036922@qq.com
LocalConfigManagementServiceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service/local
 113 9 2023-02-28 2023-02-28 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ReplicatorSourceTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 647 22 2022-12-07 2023-05-17 10 4 lizhiboo@yeah.net 877036922@qq.com
ReplicatorConnectorConfig.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/config
 522 104 2022-12-07 2023-05-17 6 4 lizhiboo@yeah.net 877036922@qq.com
AbstractConfigManagementService.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 433 30 2022-07-28 2023-05-17 10 4 sunxiaojian926@163.com 877036922@qq.com
ReplicatorSourceConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 251 13 2022-12-07 2023-05-17 7 4 lizhiboo@yeah.net 877036922@qq.com
ReplicatorCheckpointTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 247 12 2023-04-05 2023-05-17 5 2 877036922@qq.com 877036922@qq.com
ReplicatorHeartbeatTask.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 213 9 2022-12-07 2023-05-17 3 3 lizhiboo@yeah.net 877036922@qq.com
ReplicatorCheckpointConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 151 8 2023-04-05 2023-05-17 4 2 877036922@qq.com 877036922@qq.com
ReplicatorUtils.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/utils
 95 9 2022-12-07 2023-05-17 4 2 lizhiboo@yeah.net 877036922@qq.com
ReplicatorHeartbeatConnector.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator
 69 5 2022-12-07 2023-05-17 4 3 lizhiboo@yeah.net 877036922@qq.com
LoggerName.java
in connectors/rocketmq-replicator/src/main/java/org/apache/rocketmq/replicator/common
 6 - 2023-05-17 2023-05-17 1 1 877036922@qq.com 877036922@qq.com
RebalanceImpl.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/service
 73 4 2019-08-21 2023-05-16 17 9 duhengforever@apache.org 877036922@qq.com
GenericDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 828 42 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
WorkerSourceTask.java
in rocketmq-connect-runtime/src/main/java/org/apache/rocketmq/connect/runtime/connectorwrapper
 578 33 2019-08-16 2023-05-15 40 14 san@chenyiliu.com sunxiaojian926@163.com
DefaultColumnConverter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/converter
 366 8 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ExpressionBuilder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 266 40 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
SourceOffsetCompute.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset
 261 5 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 250 11 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
FieldsMetadata.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata
 244 7 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
DatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 230 16 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
TimestampIncrementingCriteria.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 226 17 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
DbStructure.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 221 7 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
TimestampIncrementingQuerier.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier
 192 10 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 178 23 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
DefaultJdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 170 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 166 18 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnDefinition.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column
 163 23 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
BufferedRecords.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 148 7 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
TableId.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table
 113 11 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractJdbcRecordBinder.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/binder
 111 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
BulkQuerier.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier
 100 5 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
Querier.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier
 97 11 2022-05-16 2023-05-15 4 1 sunxiaojian926@163.com sunxiaojian926@163.com
OpenMLDBDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/openmldb
 96 10 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
IdentifierRules.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 93 8 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
CachedConnectionProvider.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connection
 89 6 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
TableDefinition.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table
 88 12 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
DatabaseDialectLoader.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect
 87 9 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MySqlDatabaseDialect.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/mysql
 87 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcWriter.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 80 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
TimestampIncrementingOffset.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset
 78 7 2022-05-16 2023-05-15 4 2 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSinkTask.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 78 4 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
QueryContext.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 73 18 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
ColumnId.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column
 72 10 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
AbstractConfig.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config
 68 10 2022-05-16 2023-05-15 5 1 sunxiaojian926@163.com sunxiaojian926@163.com
RecordValidator.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink
 68 4 2022-07-28 2023-05-15 2 1 sunxiaojian926@163.com sunxiaojian926@163.com
DebeziumTimeTypes.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common
 67 2 2022-06-22 2023-05-15 4 2 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcDriverInfo.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/util
 63 8 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
IncrementContext.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 63 11 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
SchemaMapping.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/common
 63 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
SinkRecordField.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata
 59 10 2022-05-16 2023-05-15 3 1 sunxiaojian926@163.com sunxiaojian926@163.com
JdbcSourceConnector.java
in connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source
 55 5 2023-05-15 2023-05-15 1 1 sunxiaojian926@163.com sunxiaojian926@163.com