apache / inlong
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 5,140 files with 482,413 lines of code.
    • 1 file changed more than 100 times (886 lines of code)
    • 10 files changed 51-100 times (6,744 lines of code)
    • 81 files changed 21-50 times (22,649 lines of code)
    • 1,025 files changed 6-20 times (153,279 lines of code)
    • 4,023 files changed 1-5 times (298,855 lines of code)
<1% | 1% | 4% | 31% | 61%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 5,140 files with 482,413 lines of code.
    • 1 file changed by more than 25 contributors (886 lines of code)
    • 57 files changed by 11-25 contributors (16,528 lines of code)
    • 466 files changed by 6-10 contributors (77,607 lines of code)
    • 2,790 files changed by 2-5 contributors (266,188 lines of code)
    • 1,826 files changed by 1 contributor (121,204 lines of code)
<1% | 3% | 16% | 55% | 25%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, txt, xml, ts, tsx, yaml, go, h, properties, sh, cc, md, sql, js, json, py, css, svg, ini, proto, less, scala, cmd, mod, html, gitignore, npmrc, cpp, clang-format, gitmodules, eslintignore, gitattributes, tpl, rdf
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
sql36% | 34% | 0% | 13% | 14%
java0% | 1% | 5% | 32% | 61%
xml0% | 5% | 16% | 31% | 47%
yaml0% | 0% | 11% | 43% | 44%
ts0% | 0% | <1% | 57% | 41%
tsx0% | 0% | 0% | 25% | 74%
go0% | 0% | 0% | 26% | 73%
cc0% | 0% | 0% | 35% | 64%
h0% | 0% | 0% | 8% | 91%
tpl0% | 0% | 0% | 100% | 0%
py0% | 0% | 0% | 53% | 46%
proto0% | 0% | 0% | 5% | 94%
js0% | 0% | 0% | 0% | 100%
css0% | 0% | 0% | 0% | 100%
scala0% | 0% | 0% | 0% | 100%
less0% | 0% | 0% | 0% | 100%
cpp0% | 0% | 0% | 0% | 100%
cmd0% | 0% | 0% | 0% | 100%
rdf0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
inlong-manager<1% | 6% | 11% | 36% | 44%
inlong-dataproxy0% | 4% | 7% | 60% | 27%
inlong-tubemq0% | 0% | 4% | 60% | 35%
inlong-agent0% | 0% | 20% | 36% | 42%
inlong-sort0% | 0% | <1% | 7% | 91%
inlong-sdk0% | 0% | 2% | 26% | 70%
docker0% | 0% | 15% | 65% | 18%
inlong-sort-standalone0% | 0% | 1% | 45% | 53%
inlong-dashboard0% | 0% | <1% | 38% | 61%
inlong-audit0% | 0% | 0% | 31% | 68%
inlong-common0% | 0% | 0% | 19% | 80%
inlong-distribution0% | 0% | 0% | 54% | 45%
ROOT0% | 0% | 0% | 0% | 100%
codestyle0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
apache_inlong_manager.sql
in inlong-manager/manager-web/sql
 886 - 2021-12-09 2024-11-19 140 32 dockerzhang@apache.org 76141879+fuweng11@users.nor...
StreamSourceServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source
 492 19 2022-02-22 2024-12-18 78 18 healchow@gmail.com 76141879+fuweng11@users.nor...
AgentServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 830 27 2022-03-03 2025-02-17 77 19 healchow@gmail.com 76141879+fuweng11@users.nor...
apache_inlong_manager.sql
in inlong-manager/manager-test/src/main/resources/h2
 834 - 2022-06-21 2024-11-19 75 22 stormleo@qq.com 76141879+fuweng11@users.nor...
InlongClusterServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster
 1272 50 2022-06-07 2024-12-08 71 19 healchow@gmail.com 76141879+fuweng11@users.nor...
StreamSinkServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink
 782 29 2022-02-21 2025-03-03 66 14 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongGroupServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group
 827 35 2022-05-20 2025-02-21 65 14 healchow@gmail.com jameszow@163.com
ServerMessageHandler.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source
 550 18 2021-07-06 2024-10-25 62 15 gosonzhang@apache.org 4675739@qq.com
StreamSourceEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 623 - 2022-02-22 2024-09-19 55 10 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongGroupImpl.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 262 22 2022-02-21 2024-04-18 51 10 48468934+kipshi@users.norep... 76141879+fuweng11@users.nor...
AuditServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 272 9 2022-01-18 2025-04-16 51 15 44659300+yunqingmoswu@users... 76141879+fuweng11@users.nor...
ConfigManager.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config
 464 38 2021-07-06 2024-04-26 46 15 gosonzhang@apache.org 4675739@qq.com
ProxySink.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks
 235 12 2021-07-06 2025-02-25 45 17 gosonzhang@apache.org wenweihuang@apache.org
ManagerFetcher.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher
 245 13 2021-07-06 2025-04-02 45 19 gosonzhang@apache.org wenweihuang@apache.org
InlongGroupEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 578 - 2022-02-21 2025-02-21 45 15 48468934+kipshi@users.norep... jameszow@163.com
InlongConstants.java
in inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts
 94 - 2022-06-27 2025-02-11 41 16 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongStreamServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream
 829 33 2022-07-31 2024-12-18 41 11 45899072+ciscozhou@users.no... 76141879+fuweng11@users.nor...
InlongClusterController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 273 22 2022-04-26 2024-10-28 40 14 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongStreamImpl.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 407 23 2022-02-21 2023-09-05 40 12 48468934+kipshi@users.norep... 76141879+fuweng11@users.nor...
StreamSourceEntityMapper.java
in inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper
 62 - 2022-02-22 2024-09-19 38 9 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongGroupController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 216 20 2022-02-21 2025-02-21 38 15 healchow@gmail.com jameszow@163.com
AbstractSourceOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source
 522 16 2022-06-27 2025-02-17 38 11 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongStreamController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 218 12 2022-02-21 2024-07-17 37 12 healchow@gmail.com 76141879+fuweng11@users.nor...
ErrorCodeEnum.java
in inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums
 145 2 2022-02-21 2024-07-08 36 14 healchow@gmail.com aloyszhang@apache.org
InlongClientImpl.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 280 25 2022-02-19 2023-05-29 36 15 48468934+kipshi@users.norep... healchow@apache.org
HeartbeatManager.java
in inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core
 177 12 2022-03-03 2025-04-02 35 15 635617254@qq.com wenweihuang@apache.org
LogFileSource.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources
 325 21 2023-10-30 2025-02-14 35 3 hww_justin@163.com wenweihuang@apache.org
DataProxyConfigRepository.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository
 531 26 2021-09-29 2024-07-11 35 12 946240095@qq.com 76141879+fuweng11@users.nor...
DataProxyController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi
 69 6 2021-07-28 2024-06-17 33 12 heal.chow@gmail.com 76141879+fuweng11@users.nor...
InlongClusterEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 245 - 2022-04-26 2023-11-06 33 7 healchow@gmail.com vernedeng@apache.org
SortSourceServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 366 10 2022-03-08 2024-07-11 33 9 dengfan@pku.edu.cn 76141879+fuweng11@users.nor...
StreamSinkEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 464 - 2022-02-21 2024-03-19 33 7 healchow@gmail.com vernedeng@apache.org
Node.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node
 111 4 2022-04-21 2024-07-29 32 17 44659300+yunqingmoswu@users... 93303124+xxsc0529@users.nor...
DefaultInlongStreamBuilder.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 242 10 2022-02-21 2023-09-05 32 9 48468934+kipshi@users.norep... 76141879+fuweng11@users.nor...
ProxyConfigManager.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config
 907 32 2022-01-20 2025-02-27 32 10 dockerzhang@apache.org 4675739@qq.com
AgentConstants.java
in inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant
 93 - 2022-02-24 2025-03-26 31 13 healchow@gmail.com wenweihuang@apache.org
DefaultSortConfigOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort
 234 6 2022-07-29 2024-09-03 31 10 healchow@gmail.com 76141879+fuweng11@users.nor...
BrokerServiceServer.java
in inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker
 1135 20 2021-07-06 2024-10-23 31 7 gosonzhang@apache.org 4675739@qq.com
StreamSinkController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 143 9 2022-02-21 2024-11-19 30 10 healchow@gmail.com 76141879+fuweng11@users.nor...
Constants.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration
 205 - 2021-07-19 2025-01-07 30 15 dockerzhang@apache.org 60374114+qy-liuhuo@users.no...
InlongGroupTransfer.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util
 123 3 2022-02-21 2023-05-29 29 10 48468934+kipshi@users.norep... healchow@apache.org
PulsarSourceOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar
 174 5 2022-06-27 2023-12-27 29 13 107663475+wilburjiang0@user... 76141879+fuweng11@users.nor...
TMaster.java
in inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master
 2196 46 2021-07-06 2023-05-29 29 6 gosonzhang@apache.org healchow@apache.org
InlongClusterNodeEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 256 - 2022-04-26 2024-10-22 28 8 healchow@gmail.com 76141879+fuweng11@users.nor...
TaskProfileDto.java
in inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo
 520 14 2023-10-26 2024-12-30 28 6 hww_justin@163.com hww_justin@163.com
FlinkSqlParser.java
in inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl
 719 37 2022-05-22 2024-04-21 28 12 44659300+yunqingmoswu@users... vernedeng@apache.org
InlongClient.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api
 45 1 2022-02-19 2023-05-29 27 13 48468934+kipshi@users.norep... healchow@apache.org
InlongGroupService.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group
 50 - 2022-05-20 2025-02-21 27 10 healchow@gmail.com jameszow@163.com
InlongClusterService.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster
 62 - 2022-06-07 2024-07-17 27 13 healchow@gmail.com shuiqingliu14@gmail.com
ConfigConstants.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts
 99 - 2021-07-06 2023-09-14 27 11 gosonzhang@apache.org 4675739@qq.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
apache_inlong_manager.sql
in inlong-manager/manager-web/sql
 886 - 2021-12-09 2024-11-19 140 32 dockerzhang@apache.org 76141879+fuweng11@users.nor...
apache_inlong_manager.sql
in inlong-manager/manager-test/src/main/resources/h2
 834 - 2022-06-21 2024-11-19 75 22 stormleo@qq.com 76141879+fuweng11@users.nor...
AgentServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 830 27 2022-03-03 2025-02-17 77 19 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongClusterServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster
 1272 50 2022-06-07 2024-12-08 71 19 healchow@gmail.com 76141879+fuweng11@users.nor...
ManagerFetcher.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher
 245 13 2021-07-06 2025-04-02 45 19 gosonzhang@apache.org wenweihuang@apache.org
StreamSourceServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source
 492 19 2022-02-22 2024-12-18 78 18 healchow@gmail.com 76141879+fuweng11@users.nor...
ProxySink.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks
 235 12 2021-07-06 2025-02-25 45 17 gosonzhang@apache.org wenweihuang@apache.org
Node.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node
 111 4 2022-04-21 2024-07-29 32 17 44659300+yunqingmoswu@users... 93303124+xxsc0529@users.nor...
InlongConstants.java
in inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts
 94 - 2022-06-27 2025-02-11 41 16 healchow@gmail.com 76141879+fuweng11@users.nor...
LoadNode.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node
 104 1 2022-04-21 2024-07-29 22 16 44659300+yunqingmoswu@users... 93303124+xxsc0529@users.nor...
ServerMessageHandler.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source
 550 18 2021-07-06 2024-10-25 62 15 gosonzhang@apache.org 4675739@qq.com
AuditServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 272 9 2022-01-18 2025-04-16 51 15 44659300+yunqingmoswu@users... 76141879+fuweng11@users.nor...
ConfigManager.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config
 464 38 2021-07-06 2024-04-26 46 15 gosonzhang@apache.org 4675739@qq.com
InlongGroupEntityMapper.xml
in inlong-manager/manager-dao/src/main/resources/mappers
 578 - 2022-02-21 2025-02-21 45 15 48468934+kipshi@users.norep... jameszow@163.com
InlongGroupController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 216 20 2022-02-21 2025-02-21 38 15 healchow@gmail.com jameszow@163.com
InlongClientImpl.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 280 25 2022-02-19 2023-05-29 36 15 48468934+kipshi@users.norep... healchow@apache.org
HeartbeatManager.java
in inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core
 177 12 2022-03-03 2025-04-02 35 15 635617254@qq.com wenweihuang@apache.org
Constants.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration
 205 - 2021-07-19 2025-01-07 30 15 dockerzhang@apache.org 60374114+qy-liuhuo@users.no...
StreamSinkServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink
 782 29 2022-02-21 2025-03-03 66 14 healchow@gmail.com 76141879+fuweng11@users.nor...
InlongGroupServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group
 827 35 2022-05-20 2025-02-21 65 14 healchow@gmail.com jameszow@163.com
InlongClusterController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 273 22 2022-04-26 2024-10-28 40 14 healchow@gmail.com 76141879+fuweng11@users.nor...
ErrorCodeEnum.java
in inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums
 145 2 2022-02-21 2024-07-08 36 14 healchow@gmail.com aloyszhang@apache.org
BinlogReader.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader
 246 15 2022-02-26 2024-08-08 27 14 zpengag@connect.ust.hk hww_justin@163.com
TaskManager.java
in inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task
 460 40 2021-07-06 2025-04-02 27 14 gosonzhang@apache.org wenweihuang@apache.org
UserController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 73 6 2021-07-06 2023-08-21 23 14 gosonzhang@apache.org vernedeng@apache.org
WorkflowApproverServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl
 113 6 2021-07-06 2023-09-13 22 14 gosonzhang@apache.org vernedeng@apache.org
AgentConstants.java
in inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant
 93 - 2022-02-24 2025-03-26 31 13 healchow@gmail.com wenweihuang@apache.org
PulsarSourceOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar
 174 5 2022-06-27 2023-12-27 29 13 107663475+wilburjiang0@user... 76141879+fuweng11@users.nor...
InlongClient.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api
 45 1 2022-02-19 2023-05-29 27 13 48468934+kipshi@users.norep... healchow@apache.org
InlongClusterService.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster
 62 - 2022-06-07 2024-07-17 27 13 healchow@gmail.com shuiqingliu14@gmail.com
WorkflowServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow
 218 15 2021-07-06 2024-04-18 27 13 gosonzhang@apache.org 76141879+fuweng11@users.nor...
AgentManager.java
in inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core
 115 11 2021-07-06 2024-06-14 25 13 gosonzhang@apache.org hww_justin@163.com
TaskTypeEnum.java
in inlong-common/src/main/java/org/apache/inlong/common/enums
 44 3 2022-02-24 2024-12-02 17 13 healchow@gmail.com hww_justin@163.com
InlongStreamImpl.java
in inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl
 407 23 2022-02-21 2023-09-05 40 12 48468934+kipshi@users.norep... 76141879+fuweng11@users.nor...
InlongStreamController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 218 12 2022-02-21 2024-07-17 37 12 healchow@gmail.com 76141879+fuweng11@users.nor...
DataProxyConfigRepository.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository
 531 26 2021-09-29 2024-07-11 35 12 946240095@qq.com 76141879+fuweng11@users.nor...
DataProxyController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi
 69 6 2021-07-28 2024-06-17 33 12 heal.chow@gmail.com 76141879+fuweng11@users.nor...
FlinkSqlParser.java
in inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl
 719 37 2022-05-22 2024-04-21 28 12 44659300+yunqingmoswu@users... vernedeng@apache.org
JobConstants.java
in inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant
 12 - 2022-02-24 2024-04-30 26 12 healchow@gmail.com hww_justin@163.com
AbstractSinkOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink
 233 11 2022-06-19 2024-06-15 23 12 45899072+ciscozhou@users.no... 76141879+fuweng11@users.nor...
ExtractNode.java
in inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node
 86 2 2022-04-21 2025-01-22 22 12 44659300+yunqingmoswu@users... vernedeng@apache.org
AgentUtils.java
in inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils
 258 26 2021-07-06 2023-11-08 21 12 gosonzhang@apache.org hww_justin@163.com
FieldInfoUtils.java
in inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util
 309 14 2022-07-31 2024-08-30 19 12 healchow@gmail.com 76141879+fuweng11@users.nor...
PluginUtils.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils
 101 6 2021-07-06 2024-04-30 18 12 gosonzhang@apache.org hww_justin@163.com
WorkflowApproverController.java
in inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller
 70 4 2021-07-06 2023-11-28 18 12 gosonzhang@apache.org 76141879+fuweng11@users.nor...
MemoryChannel.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/channel
 129 9 2021-07-06 2023-05-29 14 12 gosonzhang@apache.org healchow@apache.org
InlongStreamServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream
 829 33 2022-07-31 2024-12-18 41 11 45899072+ciscozhou@users.no... 76141879+fuweng11@users.nor...
AbstractSourceOperator.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source
 522 16 2022-06-27 2025-02-17 38 11 healchow@gmail.com 76141879+fuweng11@users.nor...
ConfigConstants.java
in inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts
 99 - 2021-07-06 2023-09-14 27 11 gosonzhang@apache.org 4675739@qq.com
generatorConfig.xml
in inlong-manager/manager-dao/src/main/resources
 47 - 2021-07-06 2023-05-26 26 11 gosonzhang@apache.org dengfan@pku.edu.cn
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
hbase-default.xml
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/src/main/resources
 1734 - 2023-10-16 2023-10-16 1 1 47296299+fancycoderzf@users... 47296299+fancycoderzf@users...
hbase-default.xml
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hbase/src/main/resources
 1734 - 2023-05-18 2023-05-18 1 1 ganfengtan@users.noreply.gi... ganfengtan@users.noreply.gi...
MySqlStreamingChangeEventSource.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql
 896 43 2023-06-26 2023-06-26 1 1 111486498+e-mhui@users.nore... 111486498+e-mhui@users.nore...
TcpClientMgr.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp
 690 23 2025-01-21 2025-02-13 6 1 4675739@qq.com 4675739@qq.com
connpool.go
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool
 682 29 2023-06-01 2025-01-22 8 1 24350715@qq.com 24350715@qq.com
FlinkCatalog.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg
 657 54 2023-09-01 2023-09-01 1 1 vernedeng@apache.org vernedeng@apache.org
FileOffsetStorage.java
in inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetfile
 630 21 2024-10-23 2024-10-23 1 1 4675739@qq.com 4675739@qq.com
HadoopPathBasedPartFileWriter.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem
 615 32 2023-06-06 2023-06-06 1 1 liaorui@users.noreply.githu... liaorui@users.noreply.githu...
FlinkCatalog.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg
 585 53 2023-05-18 2023-05-18 1 1 ganfengtan@users.noreply.gi... ganfengtan@users.noreply.gi...
PostgresConnection.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection
 584 27 2023-09-15 2023-09-15 1 1 490305218@qq.com 490305218@qq.com
ModuleManager.java
in inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer
 575 38 2024-03-18 2024-12-02 14 1 hww_justin@163.com hww_justin@163.com
index.tsx
in inlong-dashboard/src/ui/pages/common/DirtyModal
 565 14 2024-11-20 2024-11-26 2 1 165994047+wohainilaodou@use... 165994047+wohainilaodou@use...
KafkaConnectorOptionsUtil.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 537 24 2024-11-26 2024-11-26 1 1 zhanghengyuan1118@outlook.com zhanghengyuan1118@outlook.com
AuditReporterImpl.java
in inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit
 514 55 2024-03-13 2025-04-03 15 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
KafkaDynamicSource.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 508 21 2024-11-26 2024-11-26 1 1 zhanghengyuan1118@outlook.com zhanghengyuan1118@outlook.com
sdk_conf.cc
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/config
 498 12 2023-08-17 2024-08-22 17 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
FlinkSink.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink
 460 36 2023-10-11 2023-10-11 1 1 vernedeng@apache.org vernedeng@apache.org
ProxyClientConfig.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/common
 451 65 2025-01-19 2025-02-13 5 1 4675739@qq.com 4675739@qq.com
HiveTableUtil.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/util
 443 14 2023-06-06 2023-06-06 1 1 liaorui@users.noreply.githu... liaorui@users.noreply.githu...
MetricDataHolder.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric
 441 31 2025-01-22 2025-02-13 6 1 4675739@qq.com 4675739@qq.com
HttpClientMgr.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/http
 440 12 2025-01-22 2025-02-13 4 1 4675739@qq.com 4675739@qq.com
TcpNettyClient.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp
 420 23 2025-01-21 2025-02-13 3 1 4675739@qq.com 4675739@qq.com
utils.cc
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/utils
 417 19 2023-09-09 2024-08-23 5 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
KvUtils.java
in inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode
 405 4 2024-04-29 2024-04-29 1 1 luchunliang@apache.org luchunliang@apache.org
InLongTcpMsgSender.java
in inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp
 402 16 2025-01-21 2025-02-13 4 1 4675739@qq.com 4675739@qq.com
tcp_client.cc
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client
 385 22 2023-09-11 2024-08-22 5 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
IcebergFilesCommitter.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink
 385 14 2023-10-11 2023-10-11 1 1 vernedeng@apache.org vernedeng@apache.org
JdbcOutputFormat.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal
 378 18 2024-04-26 2024-04-26 1 1 aloyszhang@apache.org aloyszhang@apache.org
KafkaDynamicSink.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 369 14 2024-05-16 2024-05-16 1 1 58425449+xiaoyou201@users.n... 58425449+xiaoyou201@users.n...
KafkaDynamicTableFactory.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 369 7 2024-11-26 2024-11-26 1 1 zhanghengyuan1118@outlook.com zhanghengyuan1118@outlook.com
metrics.go
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy
 367 11 2023-06-01 2024-07-21 2 1 24350715@qq.com 24350715@qq.com
proxy_manager.cc
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/manager
 358 21 2023-09-11 2024-08-23 14 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
recv_group.cc
in inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/group
 358 9 2023-09-09 2024-08-22 8 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
KafkaDynamicSink.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 357 14 2024-11-26 2024-11-26 1 1 zhanghengyuan1118@outlook.com zhanghengyuan1118@outlook.com
index.tsx
in inlong-dashboard/src/ui/components/FieldParseModule
 347 3 2023-04-29 2023-05-19 3 1 featzhang@outlook.com featzhang@outlook.com
ApiService.java
in inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/node
 345 16 2024-10-21 2025-01-05 2 1 43397300+doleyzi@users.nore... 43397300+doleyzi@users.nore...
DateUtils.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/regex
 345 13 2024-11-19 2024-12-30 2 1 hww_justin@163.com hww_justin@163.com
TopicCommand.java
in inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli
 342 8 2023-09-06 2023-09-06 1 1 47296299+fancycoderzf@users... 47296299+fancycoderzf@users...
Sender.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/dataproxy
 337 14 2025-02-25 2025-04-02 2 1 wenweihuang@apache.org wenweihuang@apache.org
UpsertKafkaDynamicTableFactory.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table
 336 20 2024-11-26 2024-11-26 1 1 zhanghengyuan1118@outlook.com zhanghengyuan1118@outlook.com
config.tsx
in inlong-dashboard/src/ui/pages/ModuleAudit/AuditModule
 331 4 2024-07-23 2024-11-01 4 1 165994047+wohainilaodou@use... 165994047+wohainilaodou@use...
PostgresScanFetchTask.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/source/fetch
 328 19 2023-09-15 2023-09-15 1 1 490305218@qq.com 490305218@qq.com
ElasticsearchSinkBase.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch
 322 22 2024-08-02 2024-08-02 1 1 58425449+xiaoyou201@users.n... 58425449+xiaoyou201@users.n...
RocksDBDAO.java
in inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/collections
 320 28 2023-05-18 2023-05-18 1 1 ganfengtan@users.noreply.gi... ganfengtan@users.noreply.gi...
ElasticsearchSinkBase.java
in inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch
 319 22 2024-07-25 2024-07-25 1 1 58425449+xiaoyou201@users.n... 58425449+xiaoyou201@users.n...
index.tsx
in inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSources
 318 7 2023-06-20 2023-12-07 4 1 88174078+bluewang@users.nor... 88174078+bluewang@users.nor...
MessageCommand.java
in inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli
 317 9 2023-09-06 2023-09-06 1 1 47296299+fancycoderzf@users... 47296299+fancycoderzf@users...
FileTask.java
in inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/local
 317 21 2024-12-10 2024-12-30 2 1 hww_justin@163.com hww_justin@163.com
TemplateServiceImpl.java
in inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream
 313 13 2024-06-07 2024-07-15 5 1 76141879+fuweng11@users.nor... 76141879+fuweng11@users.nor...
StreamWriteFunction.java
in inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink
 309 26 2024-05-22 2024-05-22 1 1 58425449+xiaoyou201@users.n... 58425449+xiaoyou201@users.n...
Correlations

File Size vs. Number of Changes: 5144 points

inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/AuditColumn.java x: 13 lines of code y: 1 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/SqlConstants.java x: 218 lines of code y: 3 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/entities/StatData.java x: 40 lines of code y: 2 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/utils/AuditUtils.java x: 89 lines of code y: 2 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/auditor/Audit.java x: 147 lines of code y: 2 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java x: 210 lines of code y: 2 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/config/AirflowConfig.java x: 77 lines of code y: 4 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/util/ConcurrentHashSet.java x: 43 lines of code y: 1 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go x: 308 lines of code y: 8 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/message.go x: 18 lines of code y: 2 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/channel/BufferQueueChannel.java x: 119 lines of code y: 7 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/metrics/status/SortTaskStatusRepository.java x: 116 lines of code y: 1 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java x: 193 lines of code y: 14 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/FetchCallback.java x: 66 lines of code y: 12 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/v2/SortCluster.java x: 103 lines of code y: 3 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/SortFlinkConfigOperator.java x: 251 lines of code y: 5 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java x: 40 lines of code y: 3 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java x: 71 lines of code y: 2 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricOption.java x: 205 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/MysqlTableFactory.java x: 479 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/RowDataDebeziumDeserializeSchema.java x: 562 lines of code y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java x: 197 lines of code y: 16 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/BaseSender.java x: 273 lines of code y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/Constant.java x: 9 lines of code y: 2 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/CsvDeserializationInfo.java x: 93 lines of code y: 7 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgCsv2DeserializationInfo.java x: 91 lines of code y: 5 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgCsvDeserializationInfo.java x: 108 lines of code y: 5 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgKvDeserializationInfo.java x: 114 lines of code y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgTlogKvDeserializationInfo.java x: 112 lines of code y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/KvDeserializationInfo.java x: 112 lines of code y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/AuditService.java x: 16 lines of code y: 16 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java x: 272 lines of code y: 51 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditIdEnum.java x: 103 lines of code y: 5 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java x: 30 lines of code y: 5 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/base/TableFormatUtils.java x: 510 lines of code y: 6 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/base/TextFormatBuilder.java x: 69 lines of code y: 3 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/FailureHandler.java x: 15 lines of code y: 4 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/IgnoreFailureHandler.java x: 40 lines of code y: 5 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/NoOpFailureHandler.java x: 44 lines of code y: 4 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/util/StringUtils.java x: 489 lines of code y: 12 # changes inlong-sort/sort-formats/format-row/format-csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvDeserializationSchema.java x: 146 lines of code y: 4 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/row/InLongMsgUtils.java x: 338 lines of code y: 2 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogUtils.java x: 257 lines of code y: 6 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java x: 285 lines of code y: 4 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvUtils.java x: 132 lines of code y: 6 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java x: 261 lines of code y: 4 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvMixedFormatConverter.java x: 100 lines of code y: 6 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgUtils.java x: 327 lines of code y: 7 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogFormatDeserializer.java x: 133 lines of code y: 3 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogUtils.java x: 227 lines of code y: 5 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java x: 312 lines of code y: 3 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java x: 258 lines of code y: 3 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvUtils.java x: 123 lines of code y: 4 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java x: 288 lines of code y: 5 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvUtils.java x: 130 lines of code y: 5 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java x: 278 lines of code y: 3 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvUtils.java x: 112 lines of code y: 3 # changes inlong-sort/sort-formats/format-rowdata/format-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvRowDataDeserializationSchema.java x: 214 lines of code y: 4 # changes inlong-sort/sort-formats/format-rowdata/format-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvRowDataDeserializationSchema.java x: 227 lines of code y: 4 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java x: 514 lines of code y: 15 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditRules.java x: 6 lines of code y: 1 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/util/AuditManagerUtils.java x: 225 lines of code y: 6 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java x: 52 lines of code y: 22 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/AgentEventMetricItem.java x: 49 lines of code y: 1 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/EventReportUtils.java x: 74 lines of code y: 1 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java x: 246 lines of code y: 7 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/FileStaticManager.java x: 128 lines of code y: 6 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java x: 177 lines of code y: 35 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/TaskManager.java x: 460 lines of code y: 27 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java x: 245 lines of code y: 45 # changes inlong-agent/conf/log4j2.xml x: 196 lines of code y: 9 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java x: 93 lines of code y: 31 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java x: 165 lines of code y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/LogAbstractTask.java x: 179 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/TcpMsgSenderConfig.java x: 239 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQConsumer.java x: 259 lines of code y: 9 # changes inlong-dashboard/src/ui/pages/GroupDetail/index.tsx x: 210 lines of code y: 8 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-python/inlong_dataproxy.cpp x: 63 lines of code y: 4 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java x: 100 lines of code y: 11 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/PulsarExtractNode.java x: 175 lines of code y: 15 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/InlongGroupEntity.java x: 35 lines of code y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java x: 782 lines of code y: 66 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SourceType.java x: 35 lines of code y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsResourceOperator.java x: 103 lines of code y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/cls/ClsSinkOperator.java x: 149 lines of code y: 7 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigManager.java x: 907 lines of code y: 32 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/group/send_group.cc x: 376 lines of code y: 7 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/ParquetSourceData.java x: 130 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/table/MultipleElasticsearchSinkFunctionBase.java x: 263 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/InLongFactoryExample.java x: 112 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/InLongHttpClientExample.java x: 46 lines of code y: 2 # changes inlong-dashboard/src/ui/pages/Clusters/NodeEditModal.tsx x: 342 lines of code y: 13 # changes inlong-dashboard/src/ui/pages/Clusters/NodeManage.tsx x: 714 lines of code y: 8 # changes inlong-dashboard/src/ui/pages/Login/index.tsx x: 61 lines of code y: 3 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java x: 235 lines of code y: 45 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/dataproxy/SenderManager.java x: 84 lines of code y: 1 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java x: 453 lines of code y: 25 # changes inlong-dashboard/src/plugins/nodes/defaults/SQL.ts x: 38 lines of code y: 1 # changes inlong-dashboard/src/plugins/nodes/defaults/index.ts x: 94 lines of code y: 9 # changes inlong-dashboard/src/plugins/sources/common/SourceDefaultInfo.ts x: 200 lines of code y: 13 # changes inlong-dashboard/src/plugins/sources/defaults/SQL.ts x: 234 lines of code y: 1 # changes inlong-dashboard/src/plugins/sources/defaults/index.ts x: 88 lines of code y: 9 # changes inlong-dashboard/src/ui/components/CheckCard/index.tsx x: 131 lines of code y: 4 # changes inlong-dashboard/src/ui/pages/SynchronizeDashboard/index.tsx x: 199 lines of code y: 4 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongGroupEntityMapper.java x: 54 lines of code y: 23 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml x: 578 lines of code y: 45 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupBriefInfo.java x: 48 lines of code y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupService.java x: 50 lines of code y: 27 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java x: 827 lines of code y: 65 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongGroupController.java x: 216 lines of code y: 38 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/DataNodeType.java x: 24 lines of code y: 17 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/sql/SqlDataNodeDTO.java x: 29 lines of code y: 1 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/sql/SqlSourceDTO.java x: 64 lines of code y: 1 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java x: 830 lines of code y: 77 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/mysql/MySQLDataNodeOperator.java x: 91 lines of code y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java x: 522 lines of code y: 38 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java x: 37 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/cos/COSSourceOperator.java x: 137 lines of code y: 2 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java x: 123 lines of code y: 17 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/sql/SqlSourceOperator.java x: 140 lines of code y: 1 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/LogFileSource.java x: 325 lines of code y: 35 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/file/AbstractSource.java x: 355 lines of code y: 20 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/AbstractTask.java x: 129 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/CronTask.java x: 34 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MsgSenderMultiFactory.java x: 100 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MsgSenderSingleFactory.java x: 117 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java x: 441 lines of code y: 6 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/BaseMsgSenderFactory.java x: 300 lines of code y: 5 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/MsgSenderFactory.java x: 27 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/common/ProxyClientConfig.java x: 451 lines of code y: 5 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/common/SdkConsts.java x: 84 lines of code y: 6 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/PkgCacheQuota.java x: 127 lines of code y: 1 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/http/HttpClientMgr.java x: 440 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpCallFuture.java x: 101 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpClientMgr.java x: 690 lines of code y: 6 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpNettyClient.java x: 420 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/codec/EncodeObject.java x: 140 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/http/HttpMsgSenderConfig.java x: 185 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/http/InLongHttpMsgSender.java x: 126 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/InLongTcpMsgSender.java x: 402 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/ExampleUtils.java x: 221 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/SequentialID.java x: 13 lines of code y: 7 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/ProxyUtils.java x: 139 lines of code y: 20 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/InlongConstants.java x: 94 lines of code y: 41 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetaSyncInfo.java x: 46 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TimeCostInfo.java x: 107 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/TrafficInfo.java x: 117 lines of code y: 3 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java x: 389 lines of code y: 14 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java x: 430 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/HttpClientExample.java x: 79 lines of code y: 15 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/TcpClientExample.java x: 61 lines of code y: 19 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/codec/DecodeObject.java x: 97 lines of code y: 2 # changes inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java x: 110 lines of code y: 8 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/discoverer.go x: 207 lines of code y: 3 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ConfigHolder.java x: 8 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/http/HttpAsyncObj.java x: 22 lines of code y: 1 # changes inlong-common/src/main/java/org/apache/inlong/common/enums/MetaField.java x: 41 lines of code y: 10 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/ExtractNode.java x: 86 lines of code y: 22 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go x: 682 lines of code y: 8 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/ClientHandler.java x: 69 lines of code y: 1 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/codec/ProtocolEncoder.java x: 93 lines of code y: 1 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java x: 11 lines of code y: 24 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/TcpEventInfo.java x: 76 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/common/EventInfo.java x: 99 lines of code y: 1 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/store/InstanceStore.java x: 77 lines of code y: 3 # changes inlong-common/src/main/java/org/apache/inlong/common/msg/AttributeConstants.java x: 34 lines of code y: 12 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration/Constants.java x: 205 lines of code y: 30 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java x: 105 lines of code y: 10 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java x: 324 lines of code y: 18 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/IcebergSource.java x: 451 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/reader/IcebergSourceReader.java x: 84 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java x: 171 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java x: 194 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java x: 494 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java x: 367 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/UpsertKafkaDynamicTableFactory.java x: 329 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/MySqlTableSource.java x: 326 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/MySqlSource.java x: 167 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/MySqlSourceBuilder.java x: 117 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/reader/MySqlSourceReader.java x: 345 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableFactory.java x: 178 lines of code y: 8 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java x: 233 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java x: 194 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarUnorderedSourceReader.java x: 179 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableSource.java x: 160 lines of code y: 5 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/oceanbase/OceanBaseJdbcUtils.java x: 158 lines of code y: 3 # changes inlong-dashboard/src/plugins/sources/defaults/COS.ts x: 242 lines of code y: 1 # changes inlong-dashboard/src/plugins/streams/common/StreamDefaultInfo.ts x: 281 lines of code y: 14 # changes inlong-dashboard/src/ui/pages/GroupDetail/DataSources/index.tsx x: 337 lines of code y: 7 # changes inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/index.tsx x: 290 lines of code y: 7 # changes inlong-dashboard/src/ui/pages/GroupDetail/DataStream/index.tsx x: 278 lines of code y: 5 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/InstanceProfile.java x: 228 lines of code y: 10 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/TaskProfile.java x: 137 lines of code y: 12 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java x: 170 lines of code y: 26 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java x: 520 lines of code y: 28 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/COSSource.java x: 304 lines of code y: 2 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/SQLTask.java x: 112 lines of code y: 1 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/local/FileTask.java x: 317 lines of code y: 2 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/local/WatchEntity.java x: 248 lines of code y: 2 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/DataNodeEntityMapper.java x: 31 lines of code y: 12 # changes inlong-manager/manager-dao/src/main/resources/mappers/DataNodeEntityMapper.xml x: 254 lines of code y: 20 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeService.java x: 25 lines of code y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java x: 244 lines of code y: 24 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/utils/RowToFieldDataUtils.java x: 211 lines of code y: 1 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/FieldInfo.java x: 23 lines of code y: 5 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/pojo/SinkInfo.java x: 49 lines of code y: 6 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java x: 190 lines of code y: 12 # changes inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/store/config/JdbcConfig.java x: 26 lines of code y: 2 # changes inlong-audit/audit-store/src/main/java/org/apache/inlong/audit/store/metric/MetricsManager.java x: 63 lines of code y: 2 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java x: 492 lines of code y: 78 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java x: 829 lines of code y: 41 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/field/format/VarCharFormatInfo.java x: 49 lines of code y: 2 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go x: 601 lines of code y: 7 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigEntry.java x: 72 lines of code y: 8 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/FileInstance.java x: 11 lines of code y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/KafkaTask.java x: 49 lines of code y: 5 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/PostgreSQLTask.java x: 83 lines of code y: 3 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/PulsarTask.java x: 57 lines of code y: 5 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/cos/FileScanner.java x: 132 lines of code y: 1 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java x: 1272 lines of code y: 71 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarQueueResourceOperator.java x: 285 lines of code y: 9 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/sub/info.go x: 136 lines of code y: 5 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go x: 796 lines of code y: 8 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/heartbeat.go x: 215 lines of code y: 8 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/remote/remote.go x: 457 lines of code y: 5 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/rpc/master.go x: 226 lines of code y: 7 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/EncryptConfigEntry.java x: 106 lines of code y: 7 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/HostInfo.java x: 45 lines of code y: 5 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EventLoopUtil.java x: 81 lines of code y: 5 # changes inlong-dashboard/src/ui/pages/AgentModule/CreateModal.tsx x: 186 lines of code y: 4 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaIdConfig.java x: 57 lines of code y: 8 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/CommonInstance.java x: 185 lines of code y: 8 # changes inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java x: 44 lines of code y: 17 # changes inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java x: 575 lines of code y: 14 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/DatabaseSqlSource.java x: 56 lines of code y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/KafkaSource.java x: 147 lines of code y: 21 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MongoDBSource.java x: 147 lines of code y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java x: 166 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/OracleSource.java x: 171 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PostgreSQLSource.java x: 161 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java x: 152 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java x: 579 lines of code y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/SQLServerSource.java x: 170 lines of code y: 12 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java x: 13 lines of code y: 5 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupInfo.java x: 108 lines of code y: 18 # changes inlong-dashboard/src/plugins/sync/common/SyncDefaultInfo.ts x: 311 lines of code y: 12 # changes inlong-dashboard/src/ui/pages/SynchronizeDetail/Info/index.tsx x: 216 lines of code y: 10 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/dolphinscheduler/DolphinScheduleUtils.java x: 575 lines of code y: 3 # changes inlong-dashboard/src/ui/pages/common/DirtyModal/index.tsx x: 565 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java x: 172 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSourceBuilder.java x: 218 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/reader/KafkaSourceReader.java x: 152 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java x: 181 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptions.java x: 275 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptionsUtil.java x: 537 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSink.java x: 357 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java x: 508 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java x: 369 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/UpsertKafkaDynamicTableFactory.java x: 336 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQTableDeserializationSchema.java x: 176 lines of code y: 6 # changes inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSink/index.tsx x: 276 lines of code y: 5 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/FileTask.java x: 64 lines of code y: 7 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/SinkRequest.java x: 76 lines of code y: 12 # changes inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql x: 834 lines of code y: 75 # changes inlong-manager/manager-web/sql/apache_inlong_manager.sql x: 886 lines of code y: 140 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java x: 143 lines of code y: 30 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileDataAddTaskRequest.java x: 19 lines of code y: 3 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java x: 68 lines of code y: 14 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceDTO.java x: 77 lines of code y: 16 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceRequest.java x: 60 lines of code y: 13 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeInstallOperator.java x: 197 lines of code y: 8 # changes inlong-dashboard/src/plugins/sources/defaults/File.ts x: 210 lines of code y: 11 # changes inlong-dashboard/src/ui/pages/ModuleAudit/IdModule/index.tsx x: 165 lines of code y: 7 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/ScheduleEntity.java x: 29 lines of code y: 4 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupRequest.java x: 109 lines of code y: 20 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/schedule/ScheduleInfo.java x: 73 lines of code y: 6 # changes inlong-dashboard/src/ui/pages/Clusters/AgentBatchUpdateModal.tsx x: 243 lines of code y: 2 # changes inlong-dashboard/src/ui/pages/ModuleAudit/IpModule/index.tsx x: 184 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/DynamicTubeMQDeserializationSchema.java x: 23 lines of code y: 6 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQDynamicTableFactory.java x: 195 lines of code y: 6 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQTableSource.java x: 256 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java x: 369 lines of code y: 6 # changes inlong-dashboard/src/ui/pages/GroupDetail/Audit/config.tsx x: 342 lines of code y: 15 # changes inlong-dashboard/src/ui/pages/ConsumeDashboard/index.tsx x: 157 lines of code y: 4 # changes inlong-dashboard/src/ui/pages/GroupDashboard/index.tsx x: 197 lines of code y: 7 # changes inlong-dashboard/src/plugins/sources/defaults/PostgreSQL.ts x: 263 lines of code y: 6 # changes inlong-dashboard/src/plugins/sources/defaults/Pulsar.ts x: 319 lines of code y: 6 # changes inlong-dashboard/src/ui/pages/GroupDataTemplate/index.tsx x: 197 lines of code y: 5 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java x: 235 lines of code y: 16 # changes inlong-dashboard/src/ui/pages/Clusters/index.tsx x: 187 lines of code y: 6 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java x: 251 lines of code y: 8 # changes inlong-dashboard/src/ui/pages/GroupDetail/DataStream/PreviewModal.tsx x: 177 lines of code y: 7 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/OperationTarget.java x: 19 lines of code y: 4 # changes inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml x: 314 lines of code y: 8 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongClusterController.java x: 273 lines of code y: 40 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/StatConstants.java x: 88 lines of code y: 16 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServerMessageHandler.java x: 550 lines of code y: 62 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java x: 237 lines of code y: 20 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java x: 65 lines of code y: 16 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamSourceController.java x: 105 lines of code y: 12 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/TBaseConstants.java x: 58 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerConfig.java x: 480 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java x: 1135 lines of code y: 31 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java x: 539 lines of code y: 19 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/metadata/BrokerMetadataManager.java x: 286 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/metadata/MetadataManager.java x: 41 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java x: 701 lines of code y: 18 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/DefaultOffsetManager.java x: 821 lines of code y: 20 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetHistoryInfo.java x: 234 lines of code y: 6 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetRecordService.java x: 125 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetService.java x: 48 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetfile/FileOffsetStorage.java x: 630 lines of code y: 1 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetfile/GroupOffsetStgInfo.java x: 162 lines of code y: 1 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetstorage/ZkOffsetStorage.java x: 310 lines of code y: 6 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/stats/BrokerSrvStatsHolder.java x: 281 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/web/BrokerAdminServlet.java x: 1564 lines of code y: 21 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/TServerConstants.java x: 70 lines of code y: 18 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/fielddef/WebFieldDef.java x: 315 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/fileconfig/AbstractFileConfig.java x: 338 lines of code y: 11 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterNodeEntityMapper.xml x: 256 lines of code y: 28 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java x: 351 lines of code y: 23 # changes inlong-dashboard/src/plugins/sinks/defaults/Redis.ts x: 451 lines of code y: 10 # changes inlong-dashboard/src/ui/pages/GroupDetail/DataStorage/DetailModal.tsx x: 189 lines of code y: 5 # changes inlong-common/src/main/java/org/apache/inlong/common/enums/DataProxyErrCode.java x: 72 lines of code y: 10 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/KvSourceDecoder.java x: 67 lines of code y: 5 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java x: 151 lines of code y: 13 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/selector/impl/DBDataSource.java x: 199 lines of code y: 1 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenStreamTransformController.java x: 76 lines of code y: 8 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/TransformFunction.java x: 14 lines of code y: 3 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/arithmetic/GreatestFunction.java x: 49 lines of code y: 3 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/compression/CompressFunction.java x: 92 lines of code y: 3 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/json/JsonArrayAppendFunction.java x: 85 lines of code y: 4 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/json/JsonArrayInsertFunction.java x: 90 lines of code y: 4 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/function/json/JsonInsertFunction.java x: 214 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBConnectorDeserializationSchema.java x: 723 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBSource.java x: 200 lines of code y: 2 # changes inlong-manager/manager-dao/src/main/resources/mappers/ComponentHeartbeatEntityMapper.xml x: 64 lines of code y: 6 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/sqlserver-cdc/src/main/java/org/apache/inlong/sort/sqlserver/RowDataDebeziumDeserializeSchema.java x: 566 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/sqlserver-cdc/src/main/java/org/apache/inlong/sort/sqlserver/SqlServerTableSource.java x: 202 lines of code y: 3 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/KafkaSink.java x: 403 lines of code y: 5 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/PulsarSink.java x: 352 lines of code y: 8 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/TubeSink.java x: 518 lines of code y: 9 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceExactlyMetric.java x: 322 lines of code y: 3 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java x: 144 lines of code y: 22 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceService.java x: 35 lines of code y: 25 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSourceController.java x: 103 lines of code y: 27 # changes inlong-dashboard/src/ui/pages/Clusters/CreateModal.tsx x: 118 lines of code y: 5 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkExactlyMetric.java x: 392 lines of code y: 3 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java x: 74 lines of code y: 20 # changes inlong-dashboard/src/ui/pages/TenantManagement/index.tsx x: 143 lines of code y: 5 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/user/UserServiceImpl.java x: 417 lines of code y: 17 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/postgre/DebeziumSourceFunction.java x: 433 lines of code y: 3 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/http/HttpSinkContext.java x: 332 lines of code y: 2 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterNodeEntityMapper.java x: 25 lines of code y: 17 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/AbstractStandaloneSinkResourceOperator.java x: 92 lines of code y: 10 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSourceEntityMapper.java x: 62 lines of code y: 38 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml x: 623 lines of code y: 55 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsChannelWorker.java x: 90 lines of code y: 8 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarOperator.java x: 364 lines of code y: 27 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FilterFunctionUtils.java x: 204 lines of code y: 7 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/transform/filter/FilterDefinition.java x: 66 lines of code y: 4 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/FilterFunction.java x: 19 lines of code y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java x: 234 lines of code y: 31 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/tubemq/TubeMQOperator.java x: 246 lines of code y: 10 # changes inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/flink/FlinkService.java x: 206 lines of code y: 6 # changes inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/util/FlinkUtils.java x: 268 lines of code y: 8 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java x: 309 lines of code y: 19 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkService.java x: 42 lines of code y: 23 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/InlongClusterNodeEntity.java x: 28 lines of code y: 10 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterNodeRequest.java x: 56 lines of code y: 13 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterNodeResponse.java x: 56 lines of code y: 9 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ClusterType.java x: 38 lines of code y: 16 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/manager/proxy_manager.cc x: 358 lines of code y: 14 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/utils/utils.cc x: 417 lines of code y: 5 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc x: 385 lines of code y: 5 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/config/sdk_conf.cc x: 498 lines of code y: 17 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/config/sdk_conf.h x: 90 lines of code y: 6 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/manager/proxy_manager.h x: 68 lines of code y: 11 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/utils/capi_constant.h x: 86 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortServiceImpl.java x: 283 lines of code y: 27 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/row/InLongMsgDecodingFormat.java x: 188 lines of code y: 1 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvMixedFormatDeserializer.java x: 148 lines of code y: 3 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java x: 192 lines of code y: 4 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java x: 223 lines of code y: 3 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java x: 246 lines of code y: 27 # changes inlong-sdk/sdk-common/src/main/java/org/apache/inlong/sdk/commons/protocol/ProxyEvent.java x: 78 lines of code y: 7 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java x: 240 lines of code y: 7 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/SinkContext.java x: 205 lines of code y: 13 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsSinkContext.java x: 485 lines of code y: 18 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/elasticsearch-base/src/main/java/org/apache/inlong/sort/elasticsearch/ElasticsearchSinkBase.java x: 322 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/elasticsearch7/src/main/java/org/apache/inlong/sort/elasticsearch7/table/Elasticsearch7DynamicSink.java x: 255 lines of code y: 1 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java x: 104 lines of code y: 22 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/Node.java x: 111 lines of code y: 32 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/OceanBaseExtractNode.java x: 245 lines of code y: 1 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/sort/dataflow/DataFlowConfig.java x: 41 lines of code y: 6 # changes inlong-dashboard/src/ui/components/FieldList/FieldTypeConf.tsx x: 390 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksTableRowTransformer.java x: 279 lines of code y: 2 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/AuditController.java x: 55 lines of code y: 20 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java x: 285 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarTableFactory.java x: 243 lines of code y: 4 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/metrics.go x: 367 lines of code y: 2 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterService.java x: 62 lines of code y: 27 # changes inlong-dashboard/src/ui/pages/Process/Approvals/config.tsx x: 129 lines of code y: 12 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongStreamClient.java x: 168 lines of code y: 16 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/JsonUtils.java x: 140 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/QueueResourceOperator.java x: 29 lines of code y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/kafka/KafkaOperator.java x: 148 lines of code y: 9 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java x: 218 lines of code y: 37 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentMain.java x: 72 lines of code y: 13 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/node/AgentClusterNodeOperator.java x: 216 lines of code y: 5 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/ConfigLoaderImpl.java x: 185 lines of code y: 2 # changes inlong-manager/manager-web/sql/changes-1.13.0.sql x: 99 lines of code y: 8 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/TemplateServiceImpl.java x: 313 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/source/PulsarTableDeserializationSchemaFactory.java x: 160 lines of code y: 2 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java x: 232 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java x: 366 lines of code y: 33 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/StreamTaskListenerFactory.java x: 141 lines of code y: 6 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java x: 531 lines of code y: 35 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/cls/ClsSinkContext.java x: 222 lines of code y: 18 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaFederationSinkContext.java x: 192 lines of code y: 17 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarFederationSinkContext.java x: 192 lines of code y: 15 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java x: 228 lines of code y: 17 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/SortSdkSource.java x: 146 lines of code y: 25 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ErrorCodeEnum.java x: 145 lines of code y: 36 # changes inlong-manager/manager-plugins/base/src/main/java/org/apache/inlong/manager/plugin/listener/StartupSortListener.java x: 59 lines of code y: 12 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/sort/SortConfigListener.java x: 112 lines of code y: 16 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/StreamParseUtils.java x: 123 lines of code y: 8 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/GroupTaskListenerFactory.java x: 152 lines of code y: 4 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/stream/CreateStreamWorkflowDefinition.java x: 79 lines of code y: 25 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/ClientFactory.java x: 44 lines of code y: 12 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/group/InitGroupCompleteListener.java x: 76 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/queue/QueueResourceListener.java x: 147 lines of code y: 15 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupMode.java x: 20 lines of code y: 10 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/ck/ClickHouseSinkDTO.java x: 111 lines of code y: 11 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/cls/ClsSinkDTO.java x: 49 lines of code y: 4 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/greenplum/GreenplumSinkDTO.java x: 56 lines of code y: 8 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/hive/HiveSinkDTO.java x: 103 lines of code y: 9 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/mysql/MySQLSinkDTO.java x: 129 lines of code y: 16 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/entity/InLongTopic.java x: 79 lines of code y: 6 # changes inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/holder/CommonPropertiesHolder.java x: 112 lines of code y: 12 # changes inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/ManagerUrlLoader.java x: 7 lines of code y: 3 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java x: 178 lines of code y: 18 # changes inlong-dashboard/src/plugins/consumes/common/ConsumeDefaultInfo.ts x: 169 lines of code y: 4 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientConfig.java x: 394 lines of code y: 19 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaMultiTopicsFetcher.java x: 326 lines of code y: 6 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaSingleTopicFetcher.java x: 257 lines of code y: 8 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/tube/TubeSingleTopicFetcher.java x: 231 lines of code y: 8 # changes inlong-common/src/main/java/org/apache/inlong/common/heartbeat/HeartbeatMsg.java x: 43 lines of code y: 9 # changes inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml x: 115 lines of code y: 15 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcOutputFormat.java x: 267 lines of code y: 1 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamExtParam.java x: 52 lines of code y: 12 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/transform/StreamTransformService.java x: 16 lines of code y: 8 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/transform/StreamTransformServiceImpl.java x: 285 lines of code y: 24 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenInLongClusterController.java x: 232 lines of code y: 7 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenInLongGroupController.java x: 87 lines of code y: 11 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/OpenInLongStreamController.java x: 123 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java x: 318 lines of code y: 15 # changes inlong-dashboard/src/ui/components/EditableTable/index.tsx x: 370 lines of code y: 4 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceMetricData.java x: 235 lines of code y: 11 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/CommonConfigHolder.java x: 661 lines of code y: 14 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/audit/AuditUtils.java x: 113 lines of code y: 17 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/DataProxyController.java x: 69 lines of code y: 33 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/MySqlExtractNode.java x: 245 lines of code y: 13 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/kafka/KafkaSinkRequest.java x: 29 lines of code y: 6 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java x: 233 lines of code y: 23 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkOperator.java x: 30 lines of code y: 14 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/SortController.java x: 41 lines of code y: 13 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/KafkaProvider.java x: 156 lines of code y: 8 # changes inlong-dashboard/src/i18n.ts x: 63 lines of code y: 23 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentManager.java x: 115 lines of code y: 25 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/KafkaExtractNode.java x: 243 lines of code y: 18 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/FetcherConstants.java x: 29 lines of code y: 16 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/AgentController.java x: 58 lines of code y: 22 # changes inlong-dashboard/src/configs/routes/conf.ts x: 123 lines of code y: 9 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/DataNodeController.java x: 107 lines of code y: 25 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/tubemq/TubeMQSourceDTO.java x: 57 lines of code y: 9 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/tubemq/TubeMQSourceRequest.java x: 40 lines of code y: 7 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/format/Format.java x: 36 lines of code y: 8 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/IcebergProvider.java x: 146 lines of code y: 8 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java x: 94 lines of code y: 19 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java x: 87 lines of code y: 21 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSinkContext.java x: 172 lines of code y: 19 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/BaseSource.java x: 475 lines of code y: 20 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/es/ElasticsearchFieldInfo.java x: 40 lines of code y: 6 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/impl/QueryConsumeConfigImpl.java x: 163 lines of code y: 14 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hudi/src/main/java/org/apache/inlong/sort/hudi/sink/StreamWriteFunction.java x: 309 lines of code y: 1 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/DataConfig.java x: 45 lines of code y: 14 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptionsUtil.java x: 427 lines of code y: 2 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/kafka/KafkaResourceOperator.java x: 83 lines of code y: 7 # changes inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/config/loader/SortClusterConfigLoader.java x: 7 lines of code y: 6 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java x: 103 lines of code y: 15 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/elasticsearch-7/src/main/java/org/apache/inlong/sort/elasticsearch7/table/Elasticsearch7DynamicSink.java x: 289 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/redis/src/main/java/org/apache/inlong/sort/redis/table/RedisDynamicTableFactory.java x: 165 lines of code y: 2 # changes inlong-sort/sort-formats/format-row/format-json-v1.18/src/main/java/org/apache/inlong/sort/formats/json/canal/CanalJsonDecodingFormat.java x: 225 lines of code y: 1 # changes inlong-sort/sort-formats/format-row/format-json-v1.18/src/main/java/org/apache/inlong/sort/formats/json/canal/CanalJsonDeserializationSchema.java x: 297 lines of code y: 1 # changes inlong-sort/sort-formats/format-row/format-json-v1.18/src/main/java/org/apache/inlong/sort/formats/json/canal/CanalJsonEnhancedDecodingFormat.java x: 279 lines of code y: 1 # changes inlong-manager/manager-dao/src/main/resources/mappers/ClusterSetMapper.xml x: 45 lines of code y: 18 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamBriefInfo.java x: 68 lines of code y: 9 # changes inlong-distribution/src/main/assemblies/release.xml x: 140 lines of code y: 10 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeOperator.java x: 17 lines of code y: 8 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/JobConstants.java x: 12 lines of code y: 26 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/PluginUtils.java x: 101 lines of code y: 18 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/httpMsg/HttpMessageHandler.java x: 401 lines of code y: 9 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecBinMsg.java x: 298 lines of code y: 6 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/decode/KvUtils.java x: 405 lines of code y: 1 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServerMessageFactory.java x: 54 lines of code y: 14 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/SimpleTcpSource.java x: 86 lines of code y: 18 # changes inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcOutputFormat.java x: 378 lines of code y: 1 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/ConfigManager.java x: 464 lines of code y: 46 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/holder/MetaConfigHolder.java x: 331 lines of code y: 10 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/DefaultEventHandler.java x: 67 lines of code y: 7 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneSink.java x: 266 lines of code y: 16 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/config/config.go x: 526 lines of code y: 9 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldRelationUtils.java x: 247 lines of code y: 9 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/MongoExtractNode.java x: 131 lines of code y: 8 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/FlinkSqlParser.java x: 719 lines of code y: 28 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/state/AbstractStateWrapper.java x: 51 lines of code y: 7 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java x: 262 lines of code y: 51 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/StreamSinkClient.java x: 97 lines of code y: 12 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/StreamSourceClient.java x: 89 lines of code y: 10 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/StreamSourceApi.java x: 36 lines of code y: 10 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupProcessService.java x: 288 lines of code y: 19 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/WorkflowServiceImpl.java x: 218 lines of code y: 27 # changes inlong-common/src/main/java/org/apache/inlong/common/constant/Constants.java x: 8 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarDynamicTableFactory.java x: 304 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcBatchingOutputFormat.java x: 506 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java x: 767 lines of code y: 4 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/listener/consume/apply/ApproveConsumeProcessListener.java x: 136 lines of code y: 9 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/GroupStatus.java x: 114 lines of code y: 16 # changes inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsg.java x: 857 lines of code y: 6 # changes inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsgAttrBuilder.java x: 350 lines of code y: 5 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroupContext.java x: 119 lines of code y: 26 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java x: 66 lines of code y: 15 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/WorkflowClient.java x: 119 lines of code y: 12 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java x: 162 lines of code y: 12 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamSinkEntityMapper.xml x: 464 lines of code y: 33 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/HttpUtils.java x: 161 lines of code y: 9 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongTenantController.java x: 76 lines of code y: 9 # changes inlong-dashboard/src/plugins/sinks/defaults/ClickHouse.ts x: 430 lines of code y: 13 # changes inlong-dashboard/src/plugins/sinks/defaults/Cls.ts x: 160 lines of code y: 6 # changes inlong-dashboard/src/plugins/sinks/defaults/Doris.ts x: 305 lines of code y: 9 # changes inlong-dashboard/src/plugins/sinks/defaults/HBase.ts x: 193 lines of code y: 8 # changes inlong-dashboard/src/plugins/sinks/defaults/Hive.ts x: 370 lines of code y: 9 # changes inlong-dashboard/src/plugins/sinks/defaults/MySQL.ts x: 237 lines of code y: 10 # changes inlong-dashboard/src/plugins/sinks/defaults/Oracle.ts x: 244 lines of code y: 9 # changes inlong-dashboard/src/plugins/sinks/defaults/SQLServer.ts x: 297 lines of code y: 9 # changes inlong-dashboard/src/plugins/sinks/defaults/StarRocks.ts x: 211 lines of code y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/AbstractSink.java x: 55 lines of code y: 15 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/DeserializationInfo.java x: 21 lines of code y: 11 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/table/TubeMQOptions.java x: 308 lines of code y: 3 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java x: 57 lines of code y: 15 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java x: 295 lines of code y: 18 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/ck/ClickHouseSinkOperator.java x: 139 lines of code y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/starrocks/StarRocksSinkOperator.java x: 146 lines of code y: 7 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java x: 155 lines of code y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java x: 174 lines of code y: 29 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java x: 653 lines of code y: 8 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/heartbeat/HeartbeatManager.java x: 151 lines of code y: 17 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSource.java x: 715 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java x: 646 lines of code y: 3 # changes inlong-dashboard/src/plugins/sinks/defaults/Iceberg.ts x: 444 lines of code y: 10 # changes inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSink/DetailModal.tsx x: 152 lines of code y: 5 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java x: 59 lines of code y: 10 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterRequest.java x: 63 lines of code y: 14 # changes inlong-dashboard/src/plugins/sinks/defaults/Kudu.ts x: 280 lines of code y: 8 # changes inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncSources/index.tsx x: 318 lines of code y: 4 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/pojo/GroupInfo.java x: 16 lines of code y: 13 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/pojo/SinkInfo.java x: 18 lines of code y: 9 # changes inlong-dashboard/src/ui/components/FieldList/DetailModal.tsx x: 225 lines of code y: 9 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkDynamicTableFactory.java x: 271 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/DynamicSchemaHandleOperator.java x: 489 lines of code y: 11 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongConsumeController.java x: 86 lines of code y: 12 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/WorkflowController.java x: 140 lines of code y: 21 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/WorkflowEventController.java x: 95 lines of code y: 15 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/PulsarClusterOperator.java x: 124 lines of code y: 15 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/HudiLoadNode.java x: 136 lines of code y: 7 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/config/MySqlSourceOptions.java x: 235 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java x: 376 lines of code y: 5 # changes inlong-dashboard/src/ui/pages/SynchronizeDetail/SyncTransform/DetailModal.tsx x: 299 lines of code y: 3 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/AgentUtils.java x: 258 lines of code y: 21 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterEntityMapper.java x: 26 lines of code y: 22 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterEntityMapper.xml x: 245 lines of code y: 33 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterOperator.java x: 15 lines of code y: 6 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/common/AgentThreadFactory.java x: 30 lines of code y: 8 # changes inlong-dashboard/src/ui/components/GroupLogs/GroupLogs.tsx x: 199 lines of code y: 6 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/src/main/resources/hbase-default.xml x: 1734 lines of code y: 1 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/postgresql/PostgreSQLJdbcUtils.java x: 154 lines of code y: 6 # changes inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/cluster/ClusterController.java x: 288 lines of code y: 12 # changes inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/MasterServiceImpl.java x: 222 lines of code y: 11 # changes inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/TopicServiceImpl.java x: 299 lines of code y: 10 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/FlinkSink.java x: 460 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/IcebergFilesCommitter.java x: 385 lines of code y: 1 # changes inlong-dashboard/src/plugins/groups/defaults/Pulsar.ts x: 229 lines of code y: 3 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongStreamEntityMapper.xml x: 424 lines of code y: 22 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/kafka/KafkaSourceOperator.java x: 119 lines of code y: 20 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/utils/MessageUtils.java x: 225 lines of code y: 17 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/hudi/HudiCatalogClient.java x: 213 lines of code y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupOperator4Pulsar.java x: 122 lines of code y: 10 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml x: 303 lines of code y: 10 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java x: 584 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/DebeziumSourceFunction.java x: 482 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/source/fetch/PostgresScanFetchTask.java x: 328 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/table/PostgreSQLTableFactory.java x: 290 lines of code y: 2 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/kafka/KafkaHandler.java x: 184 lines of code y: 17 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/tube/TubeHandler.java x: 263 lines of code y: 20 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/consume/InlongConsumeServiceImpl.java x: 203 lines of code y: 12 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/WorkflowApproverServiceImpl.java x: 113 lines of code y: 22 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/user/TenantRoleServiceImpl.java x: 119 lines of code y: 9 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/MySqlSource.java x: 166 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java x: 417 lines of code y: 6 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/SimpleMessageProducer.java x: 383 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/MessageCommand.java x: 317 lines of code y: 1 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/TopicCommand.java x: 342 lines of code y: 1 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/DescribeCommand.java x: 259 lines of code y: 17 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/ListCommand.java x: 303 lines of code y: 21 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/DefaultInlongStreamBuilder.java x: 242 lines of code y: 32 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongStreamImpl.java x: 407 lines of code y: 40 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkCatalog.java x: 657 lines of code y: 1 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/ClientContext.java x: 127 lines of code y: 7 # changes inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java x: 689 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/FlinkSink.java x: 584 lines of code y: 7 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleStreamWriter.java x: 263 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableFactory.java x: 413 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/debezium/DebeziumSourceFunction.java x: 474 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/config/MySqlSourceConfigFactory.java x: 243 lines of code y: 5 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/UserController.java x: 73 lines of code y: 23 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/table/OracleReadableMetaData.java x: 354 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/table/PostgreSQLReadableMetaData.java x: 345 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/RecordWithSchema.java x: 141 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java x: 393 lines of code y: 4 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/common/SinkContext.java x: 186 lines of code y: 10 # changes inlong-tubemq/resources/assets/scripts/common/module.js x: 1297 lines of code y: 5 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/utils/WebParameterUtils.java x: 1305 lines of code y: 19 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java x: 528 lines of code y: 5 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java x: 730 lines of code y: 4 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/InlongClusterEntity.java x: 27 lines of code y: 13 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterTagEntityMapper.java x: 15 lines of code y: 9 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/interceptor/MultiTenantInterceptor.java x: 207 lines of code y: 5 # changes inlong-manager/manager-web/sql/changes-1.8.0.sql x: 108 lines of code y: 14 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java x: 937 lines of code y: 3 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/CreateCommand.java x: 260 lines of code y: 19 # changes inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/UpdateCommand.java x: 231 lines of code y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/TubeClusterOperator.java x: 93 lines of code y: 14 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/debezium/table/MongoDBConnectorDeserializationSchema.java x: 772 lines of code y: 3 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/format/JsonToRowDataConverters.java x: 341 lines of code y: 3 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/MessageQueueZoneProducer.java x: 236 lines of code y: 12 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/BaseMessageConsumer.java x: 1442 lines of code y: 15 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/SimpleClientBalanceConsumer.java x: 1555 lines of code y: 13 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/ProducerManager.java x: 639 lines of code y: 13 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/SimpleTcpSource.java x: 216 lines of code y: 6 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 896 lines of code y: 1 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/config/ControllerExceptionHandler.java x: 115 lines of code y: 13 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/AnnoController.java x: 42 lines of code y: 16 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/utils/RecordUtils.java x: 407 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java x: 534 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedBulkFormatBuilder.java x: 169 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedPartFileWriter.java x: 615 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/util/HiveTableUtil.java x: 443 lines of code y: 1 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/assigners/ChunkSplitter.java x: 251 lines of code y: 3 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/KafkaDynamicSink.java x: 404 lines of code y: 3 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/node/Application.java x: 310 lines of code y: 13 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongClientImpl.java x: 280 lines of code y: 36 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/dispatch/DispatchManager.java x: 146 lines of code y: 9 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/metrics/DataProxyMetricItem.java x: 173 lines of code y: 14 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongClient.java x: 45 lines of code y: 27 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java x: 123 lines of code y: 29 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/tool/excel/ExcelTool.java x: 455 lines of code y: 7 # changes inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/definition/WorkflowProcess.java x: 112 lines of code y: 10 # changes inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/event/LogableEventListener.java x: 84 lines of code y: 8 # changes inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/processor/AbstractTaskProcessor.java x: 8 lines of code y: 5 # changes inlong-manager/manager-workflow/src/main/java/org/apache/inlong/manager/workflow/processor/UserTaskProcessor.java x: 206 lines of code y: 9 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EncryptUtil.java x: 291 lines of code y: 6 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/metrics/prometheus/PrometheusMetricListener.java x: 181 lines of code y: 7 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/EsOutputChannel.java x: 163 lines of code y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/FunctionParam.java x: 90 lines of code y: 13 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/ParameterTool.java x: 313 lines of code y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/filesystem/src/main/java/org/apache/inlong/sort/filesystem/FileSystemTableSink.java x: 579 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaConsumerBase.java x: 735 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java x: 1358 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java x: 470 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/DebeziumSourceFunction.java x: 478 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/MongoDBSource.java x: 255 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/table/MongoDBTableSource.java x: 298 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/source/assigners/state/PendingSplitsStateSerializer.java x: 321 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java x: 397 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/PulsarFetcher.java x: 488 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/table/PulsarDynamicTableSink.java x: 275 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/sqlserver-cdc/src/main/java/org/apache/inlong/sort/cdc/sqlserver/table/DebeziumSourceFunction.java x: 438 lines of code y: 2 # changes inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/manager/StarRocksSinkManager.java x: 639 lines of code y: 2 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/RmtDataCache.java x: 1264 lines of code y: 12 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/factory/TubeBaseSessionFactory.java x: 176 lines of code y: 9 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/qltystats/DefaultBrokerRcvQltyStats.java x: 384 lines of code y: 6 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/cluster/Partition.java x: 162 lines of code y: 7 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/cluster/TopicInfo.java x: 151 lines of code y: 8 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/policies/FlowCtrlRuleHandler.java x: 658 lines of code y: 11 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/utils/TStringUtils.java x: 151 lines of code y: 12 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/RpcServiceFactory.java x: 470 lines of code y: 7 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/codec/PbEnDecoder.java x: 272 lines of code y: 9 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/netty/NettyClient.java x: 328 lines of code y: 9 # changes inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/netty/NettyProtocolDecoder.java x: 165 lines of code y: 8 # changes inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/controller/group/GroupController.java x: 116 lines of code y: 11 # changes inlong-tubemq/tubemq-manager/src/main/java/org/apache/inlong/tubemq/manager/service/NodeServiceImpl.java x: 333 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/metadata/TopicMetadata.java x: 411 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStore.java x: 700 lines of code y: 19 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/FileSegment.java x: 477 lines of code y: 12 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/MsgFileStore.java x: 602 lines of code y: 20 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/mem/MsgMemStore.java x: 305 lines of code y: 20 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/stats/MsgStoreStatsHolder.java x: 401 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/paramcheck/PBParameterUtils.java x: 321 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/MasterConfig.java x: 693 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/TMaster.java x: 2196 lines of code y: 29 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/balance/DefaultLoadBalancer.java x: 555 lines of code y: 15 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbBrokerConfEntity.java x: 460 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbClusterSettingEntity.java x: 351 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbGroupFilterCondEntity.java x: 227 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbGroupFlowCtrlEntity.java x: 267 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbTopicAuthControlEntity.java x: 183 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbTopicConfEntity.java x: 378 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/DefaultMetaDataService.java x: 994 lines of code y: 12 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/MetaDataService.java x: 160 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/BaseEntity.java x: 260 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/BrokerConfEntity.java x: 385 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/ClusterSettingEntity.java x: 323 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/TopicDeployEntity.java x: 276 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/TopicPropGroup.java x: 403 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/mapper/BrokerConfigMapper.java x: 24 lines of code y: 12 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/mapper/GroupResCtrlMapper.java x: 15 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/mapper/TopicDeployMapper.java x: 36 lines of code y: 13 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsBrokerConfigMapperImpl.java x: 323 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsConsumeCtrlMapperImpl.java x: 380 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsMetaConfigMapperImpl.java x: 1091 lines of code y: 15 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsTopicDeployMapperImpl.java x: 663 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/bdbimpl/BdbMetaConfigMapperImpl.java x: 461 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/BrokerAbnHolder.java x: 276 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/BrokerRunStatusInfo.java x: 321 lines of code y: 7 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/DefBrokerRunManager.java x: 481 lines of code y: 19 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumeGroupInfo.java x: 636 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumerEventManager.java x: 220 lines of code y: 13 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumerInfoHolder.java x: 300 lines of code y: 13 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/stats/MasterSrvStatsHolder.java x: 337 lines of code y: 6 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/action/screen/Master.java x: 281 lines of code y: 10 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/common/BaseResult.java x: 337 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebAdminGroupCtrlHandler.java x: 1222 lines of code y: 18 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebAdminTopicAuthHandler.java x: 246 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebBrokerConfHandler.java x: 898 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebGroupConsumeCtrlHandler.java x: 394 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebMasterInfoHandler.java x: 381 lines of code y: 14 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebOtherInfoHandler.java x: 425 lines of code y: 15 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebTopicCtrlHandler.java x: 257 lines of code y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebTopicDeployHandler.java x: 975 lines of code y: 13 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/simplemvc/RequestDispatcher.java x: 237 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/StoreRepairAdmin.java x: 394 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliConsumer.java x: 348 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliMetaDataBRU.java x: 1411 lines of code y: 8 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliProducer.java x: 289 lines of code y: 11 # changes inlong-manager/manager-dao/src/main/resources/generatorConfig.xml x: 47 lines of code y: 26 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration/Configuration.java x: 474 lines of code y: 6 # changes inlong-dashboard/src/configs/menus/index.ts x: 28 lines of code y: 18 # changes docker/kubernetes/templates/audit-statefulset.yaml x: 143 lines of code y: 17 # changes docker/kubernetes/values.yaml x: 397 lines of code y: 23 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/baseproducer.cc x: 645 lines of code y: 2 # changes docker/kubernetes/templates/zookeeper-statefulset.yaml x: 133 lines of code y: 11 # changes docker/kubernetes/templates/agent-statefulset.yaml x: 141 lines of code y: 16 # changes inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/config/TubeClientConfig.java x: 452 lines of code y: 9 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/metadata/BrokerDefMetadata.java x: 118 lines of code y: 8 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/utils.cc x: 482 lines of code y: 6 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/meta_info.cc x: 500 lines of code y: 4 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc x: 602 lines of code y: 5 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/client_service.cc x: 250 lines of code y: 4 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/flowctrl_def.cc x: 703 lines of code y: 3 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/rmt_data_cache.cc x: 556 lines of code y: 5 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_tdmsg.cc x: 866 lines of code y: 4 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/StreamSource.java x: 4 lines of code y: 10 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceFieldEntityMapper.xml x: 252 lines of code y: 6 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroup.java x: 26 lines of code y: 15 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamTransformFieldEntityMapper.xml x: 294 lines of code y: 7 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/baseconsumer.cc x: 1417 lines of code y: 7 # changes inlong-manager/manager-dao/src/main/resources/mappers/UserEntityMapper.xml x: 137 lines of code y: 10 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/multiplexing/multiplexing.go x: 361 lines of code y: 4 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/tdmsg/td_msg.go x: 353 lines of code y: 7 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/plugin/Sink.java x: 7 lines of code y: 7 # changes inlong-tubemq/tubemq-core/src/main/proto/MasterService.proto x: 458 lines of code y: 3 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/protocol/BrokerService.pb.go x: 1346 lines of code y: 1 # changes inlong-tubemq/tubemq-client-twins/tubemq-client-go/protocol/MasterService.pb.go x: 4509 lines of code y: 1 # changes inlong-tubemq/resources/assets/lib/DataTables/DataTables-1.10.11/css/dataTables.jqueryui.css x: 445 lines of code y: 2 # changes inlong-tubemq/resources/assets/lib/DataTables/DataTables-1.10.11/css/jquery.dataTables.css x: 420 lines of code y: 2 # changes inlong-tubemq/resources/assets/public/css/style.css x: 971 lines of code y: 3 # changes
140.0
# changes
  min: 1.0
  average: 4.26
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 140.0
0 4509.0
lines of code
min: 1.0 | average: 93.82 | 25th percentile: 21.0 | median: 47.0 | 75th percentile: 108.0 | max: 4509.0

Number of Contributors vs. Number of Changes: 5144 points

inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/AuditColumn.java x: 1 # contributors y: 1 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/SqlConstants.java x: 1 # contributors y: 3 # changes inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/entities/StatData.java x: 1 # contributors y: 2 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java x: 2 # contributors y: 3 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/config/AirflowConfig.java x: 3 # contributors y: 4 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go x: 3 # contributors y: 8 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/message.go x: 2 # contributors y: 2 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/channel/BufferQueueChannel.java x: 5 # contributors y: 7 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java x: 7 # contributors y: 14 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/FetchCallback.java x: 8 # contributors y: 12 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/SortFlinkConfigOperator.java x: 1 # contributors y: 5 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java x: 3 # contributors y: 3 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricOption.java x: 4 # contributors y: 4 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/RowDataDebeziumDeserializeSchema.java x: 3 # contributors y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java x: 9 # contributors y: 16 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/BaseSender.java x: 1 # contributors y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgCsv2DeserializationInfo.java x: 2 # contributors y: 5 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgKvDeserializationInfo.java x: 2 # contributors y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/KvDeserializationInfo.java x: 6 # contributors y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/AuditService.java x: 6 # contributors y: 16 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java x: 15 # contributors y: 51 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/base/TableFormatUtils.java x: 4 # contributors y: 6 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/FailureHandler.java x: 1 # contributors y: 4 # changes inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/util/StringUtils.java x: 6 # contributors y: 12 # changes inlong-sort/sort-formats/format-row/format-csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvDeserializationSchema.java x: 2 # contributors y: 4 # changes inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvMixedFormatConverter.java x: 3 # contributors y: 5 # changes inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgUtils.java x: 2 # contributors y: 7 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java x: 1 # contributors y: 15 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java x: 10 # contributors y: 22 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java x: 3 # contributors y: 7 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java x: 15 # contributors y: 35 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/TaskManager.java x: 14 # contributors y: 27 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java x: 19 # contributors y: 45 # changes inlong-agent/conf/log4j2.xml x: 8 # contributors y: 9 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java x: 13 # contributors y: 31 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java x: 2 # contributors y: 11 # changes inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/tubemq/src/main/java/org/apache/inlong/sort/tubemq/FlinkTubeMQConsumer.java x: 3 # contributors y: 9 # changes inlong-dashboard/src/ui/pages/GroupDetail/index.tsx x: 4 # contributors y: 8 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java x: 4 # contributors y: 11 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/PulsarExtractNode.java x: 9 # contributors y: 15 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/InlongGroupEntity.java x: 5 # contributors y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java x: 14 # contributors y: 66 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SourceType.java x: 9 # contributors y: 11 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigManager.java x: 10 # contributors y: 32 # changes inlong-dashboard/src/ui/pages/Clusters/NodeEditModal.tsx x: 5 # contributors y: 13 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java x: 17 # contributors y: 45 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java x: 3 # contributors y: 25 # changes inlong-dashboard/src/plugins/nodes/defaults/index.ts x: 4 # contributors y: 9 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongGroupEntityMapper.java x: 10 # contributors y: 23 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml x: 15 # contributors y: 45 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupBriefInfo.java x: 4 # contributors y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupService.java x: 10 # contributors y: 27 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java x: 14 # contributors y: 65 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongGroupController.java x: 15 # contributors y: 38 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/DataNodeType.java x: 8 # contributors y: 17 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java x: 19 # contributors y: 77 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/mysql/MySQLDataNodeOperator.java x: 3 # contributors y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java x: 11 # contributors y: 38 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java x: 6 # contributors y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java x: 7 # contributors y: 17 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/LogFileSource.java x: 3 # contributors y: 35 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/file/AbstractSource.java x: 3 # contributors y: 20 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/AbstractTask.java x: 2 # contributors y: 10 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/ProxyUtils.java x: 7 # contributors y: 20 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/InlongConstants.java x: 16 # contributors y: 41 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/HttpClientExample.java x: 7 # contributors y: 15 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/TcpClientExample.java x: 11 # contributors y: 19 # changes inlong-sdk/dirty-data-sdk/src/main/java/org/apache/inlong/sdk/dirtydata/InlongSdkDirtySender.java x: 2 # contributors y: 8 # changes inlong-common/src/main/java/org/apache/inlong/common/enums/MetaField.java x: 9 # contributors y: 10 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/ExtractNode.java x: 12 # contributors y: 22 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/connpool/connpool.go x: 1 # contributors y: 8 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java x: 10 # contributors y: 24 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration/Constants.java x: 15 # contributors y: 30 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java x: 7 # contributors y: 10 # changes inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java x: 11 # contributors y: 18 # changes inlong-dashboard/src/plugins/streams/common/StreamDefaultInfo.ts x: 5 # contributors y: 14 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/TaskProfile.java x: 1 # contributors y: 12 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java x: 6 # contributors y: 26 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java x: 6 # contributors y: 28 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/DataNodeEntityMapper.java x: 5 # contributors y: 12 # changes inlong-manager/manager-dao/src/main/resources/mappers/DataNodeEntityMapper.xml x: 4 # contributors y: 20 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java x: 8 # contributors y: 24 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java x: 18 # contributors y: 78 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java x: 11 # contributors y: 41 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigEntry.java x: 5 # contributors y: 8 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/instance/FileInstance.java x: 1 # contributors y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java x: 19 # contributors y: 71 # changes inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/EventLoopUtil.java x: 5 # contributors y: 5 # changes inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java x: 13 # contributors y: 17 # changes inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java x: 1 # contributors y: 14 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/KafkaSource.java x: 8 # contributors y: 21 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MongoDBSource.java x: 5 # contributors y: 11 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java x: 5 # contributors y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PostgreSQLSource.java x: 4 # contributors y: 10 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PulsarSource.java x: 3 # contributors y: 10 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java x: 4 # contributors y: 5 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupInfo.java x: 8 # contributors y: 18 # changes inlong-dashboard/src/plugins/sync/common/SyncDefaultInfo.ts x: 2 # contributors y: 12 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/metrics/audit/AuditUtils.java x: 6 # contributors y: 22 # changes inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/ScheduleEngineType.java x: 3 # contributors y: 2 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/FileTask.java x: 1 # contributors y: 7 # changes inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql x: 22 # contributors y: 75 # changes inlong-manager/manager-web/sql/apache_inlong_manager.sql x: 32 # contributors y: 140 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java x: 10 # contributors y: 30 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSource.java x: 8 # contributors y: 14 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceRequest.java x: 7 # contributors y: 13 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupRequest.java x: 8 # contributors y: 20 # changes inlong-dashboard/src/ui/pages/GroupDetail/Audit/config.tsx x: 4 # contributors y: 15 # changes inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java x: 5 # contributors y: 16 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongClusterController.java x: 14 # contributors y: 40 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/StatConstants.java x: 3 # contributors y: 16 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServerMessageHandler.java x: 15 # contributors y: 62 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java x: 6 # contributors y: 8 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java x: 11 # contributors y: 20 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongGroupApi.java x: 10 # contributors y: 16 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java x: 7 # contributors y: 31 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java x: 6 # contributors y: 19 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java x: 6 # contributors y: 18 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/StoreService.java x: 6 # contributors y: 11 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/web/BrokerAdminServlet.java x: 6 # contributors y: 21 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/TServerConstants.java x: 5 # contributors y: 18 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterNodeEntityMapper.xml x: 8 # contributors y: 28 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java x: 7 # contributors y: 23 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/TransformProcessor.java x: 2 # contributors y: 13 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamTransformController.java x: 9 # contributors y: 12 # changes inlong-audit/audit-common/src/main/java/org/apache/inlong/audit/file/ConfigManager.java x: 8 # contributors y: 10 # changes inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/TubeSink.java x: 7 # contributors y: 9 # changes inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java x: 9 # contributors y: 22 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceService.java x: 9 # contributors y: 25 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java x: 10 # contributors y: 20 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/user/UserServiceImpl.java x: 9 # contributors y: 17 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterNodeEntityMapper.java x: 6 # contributors y: 17 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSourceEntityMapper.java x: 9 # contributors y: 38 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml x: 10 # contributors y: 55 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/AbstractConfiguration.java x: 7 # contributors y: 11 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarOperator.java x: 9 # contributors y: 27 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FilterFunctionUtils.java x: 7 # contributors y: 7 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java x: 10 # contributors y: 31 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java x: 12 # contributors y: 19 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkService.java x: 8 # contributors y: 23 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterNodeRequest.java x: 6 # contributors y: 13 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ClusterType.java x: 8 # contributors y: 16 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/core/api_imp.cc x: 1 # contributors y: 10 # changes inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/config/sdk_conf.cc x: 1 # contributors y: 17 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/consume/ConsumeTubeMQOperator.java x: 6 # contributors y: 6 # changes inlong-sdk/sdk-common/src/main/java/org/apache/inlong/sdk/commons/protocol/ProxyEvent.java x: 6 # contributors y: 7 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/SinkContext.java x: 8 # contributors y: 13 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/elasticsearch/DefaultEvent2IndexRequestHandler.java x: 5 # contributors y: 6 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/LoadNode.java x: 16 # contributors y: 22 # changes inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/Node.java x: 17 # contributors y: 32 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/AuditController.java x: 9 # contributors y: 20 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterService.java x: 13 # contributors y: 27 # changes inlong-dashboard/src/ui/pages/Process/Approvals/config.tsx x: 4 # contributors y: 12 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/service/InlongStreamApi.java x: 8 # contributors y: 19 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/JsonUtils.java x: 11 # contributors y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/message/InlongMsgDeserializeOperator.java x: 2 # contributors y: 9 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java x: 12 # contributors y: 37 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentMain.java x: 10 # contributors y: 13 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortSourceServiceImpl.java x: 9 # contributors y: 33 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java x: 12 # contributors y: 35 # changes inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarFederationSinkContext.java x: 6 # contributors y: 15 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ErrorCodeEnum.java x: 14 # contributors y: 36 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/StreamParseUtils.java x: 8 # contributors y: 8 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/stream/CreateStreamWorkflowDefinition.java x: 8 # contributors y: 25 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java x: 9 # contributors y: 18 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientConfig.java x: 5 # contributors y: 19 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/CommonConfigHolder.java x: 2 # contributors y: 14 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/DataProxyController.java x: 12 # contributors y: 33 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/es/ElasticsearchDataNodeOperator.java x: 6 # contributors y: 10 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java x: 12 # contributors y: 23 # changes inlong-dashboard/src/i18n.ts x: 9 # contributors y: 23 # changes inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentManager.java x: 13 # contributors y: 25 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/AgentController.java x: 11 # contributors y: 22 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/DataNodeController.java x: 10 # contributors y: 25 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java x: 9 # contributors y: 19 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamRequest.java x: 9 # contributors y: 21 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/BaseSource.java x: 6 # contributors y: 20 # changes inlong-common/src/main/java/org/apache/inlong/common/pojo/agent/DataConfig.java x: 10 # contributors y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/AbstractDataNodeOperator.java x: 5 # contributors y: 15 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/JobConstants.java x: 12 # contributors y: 26 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/PluginUtils.java x: 12 # contributors y: 18 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/ConfigManager.java x: 15 # contributors y: 46 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldRelationUtils.java x: 9 # contributors y: 9 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/FlinkSqlParser.java x: 12 # contributors y: 28 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java x: 10 # contributors y: 51 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupProcessService.java x: 7 # contributors y: 19 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/InlongGroupContext.java x: 10 # contributors y: 26 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/StreamSourceEntity.java x: 8 # contributors y: 15 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/WorkflowClient.java x: 7 # contributors y: 12 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSinkEntityMapper.java x: 7 # contributors y: 18 # changes inlong-manager/manager-dao/src/main/resources/mappers/StreamSinkEntityMapper.xml x: 7 # contributors y: 33 # changes inlong-dashboard/src/plugins/sinks/defaults/ClickHouse.ts x: 3 # contributors y: 13 # changes inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/FieldType.java x: 11 # contributors y: 15 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java x: 10 # contributors y: 18 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongClusterClient.java x: 9 # contributors y: 14 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java x: 13 # contributors y: 29 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/function/EncryptFunction.java x: 4 # contributors y: 3 # changes inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/NativeFlinkSqlParser.java x: 10 # contributors y: 10 # changes inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/node/DataNodeRequest.java x: 8 # contributors y: 11 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/WorkflowController.java x: 11 # contributors y: 21 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/WorkflowEventController.java x: 10 # contributors y: 15 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/AgentUtils.java x: 12 # contributors y: 21 # changes inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterEntityMapper.java x: 7 # contributors y: 22 # changes inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/common/AgentThreadFactory.java x: 7 # contributors y: 8 # changes inlong-manager/manager-dao/src/main/resources/mappers/InlongStreamEntityMapper.xml x: 8 # contributors y: 22 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/ConfigConstants.java x: 11 # contributors y: 27 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/kafka/KafkaHandler.java x: 5 # contributors y: 17 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/pulsar/PulsarHandler.java x: 7 # contributors y: 24 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/WorkflowApproverServiceImpl.java x: 14 # contributors y: 22 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/DefaultInlongStreamBuilder.java x: 9 # contributors y: 32 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongStreamImpl.java x: 12 # contributors y: 40 # changes inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/metrics/SortSdkMetricItem.java x: 7 # contributors y: 6 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/UserController.java x: 14 # contributors y: 23 # changes inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/sink/mq/SimplePackProfile.java x: 1 # contributors y: 9 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/AbstractClusterOperator.java x: 4 # contributors y: 13 # changes inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/config/ControllerExceptionHandler.java x: 9 # contributors y: 13 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongClientImpl.java x: 15 # contributors y: 36 # changes inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/channel/MemoryChannel.java x: 12 # contributors y: 14 # changes inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/util/InlongGroupTransfer.java x: 10 # contributors y: 29 # changes inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/group/SuspendGroupWorkflowDefinition.java x: 3 # contributors y: 14 # changes inlong-sort-standalone/sort-standalone-common/src/main/java/org/apache/inlong/sort/standalone/metrics/SortMetricItemSet.java x: 5 # contributors y: 4 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/TMaster.java x: 6 # contributors y: 29 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/DefaultMetaDataService.java x: 3 # contributors y: 12 # changes inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsMetaConfigMapperImpl.java x: 3 # contributors y: 15 # changes inlong-manager/manager-dao/src/main/resources/generatorConfig.xml x: 11 # contributors y: 26 # changes inlong-dashboard/src/ui/pages/Nodes/DetailModal.tsx x: 2 # contributors y: 1 # changes docker/kubernetes/values.yaml x: 6 # contributors y: 23 # changes
140.0
# changes
  min: 1.0
  average: 4.26
  25th percentile: 1.0
  median: 3.0
  75th percentile: 5.0
  max: 140.0
0 32.0
# contributors
min: 1.0 | average: 2.72 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 32.0

Number of Contributors vs. File Size: 5144 points

inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/AuditColumn.java x: 1 # contributors y: 13 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/config/SqlConstants.java x: 1 # contributors y: 218 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/entities/StatData.java x: 1 # contributors y: 40 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/utils/AuditUtils.java x: 1 # contributors y: 89 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/auditor/Audit.java x: 1 # contributors y: 147 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/source/JdbcSource.java x: 1 # contributors y: 210 lines of code inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/AirflowScheduleEngine.java x: 2 # contributors y: 215 lines of code inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/airflow/config/AirflowConfig.java x: 3 # contributors y: 77 lines of code inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/client.go x: 3 # contributors y: 308 lines of code inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/message.go x: 2 # contributors y: 18 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/channel/BufferQueueChannel.java x: 5 # contributors y: 119 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/metrics/status/SortTaskStatusRepository.java x: 1 # contributors y: 116 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java x: 7 # contributors y: 193 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/source/sortsdk/FetchCallback.java x: 8 # contributors y: 66 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/v2/SortCluster.java x: 2 # contributors y: 103 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/SortFlinkConfigOperator.java x: 1 # contributors y: 251 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/util/AuditUtils.java x: 3 # contributors y: 40 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/CdcExactlyMetric.java x: 1 # contributors y: 71 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/MetricOption.java x: 4 # contributors y: 205 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/MysqlTableFactory.java x: 4 # contributors y: 479 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/RowDataDebeziumDeserializeSchema.java x: 3 # contributors y: 562 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/load/IcebergLoadNode.java x: 9 # contributors y: 197 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/BaseSender.java x: 1 # contributors y: 273 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/constant/Constant.java x: 2 # contributors y: 9 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/CsvDeserializationInfo.java x: 5 # contributors y: 93 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/InLongMsgCsvDeserializationInfo.java x: 2 # contributors y: 108 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/deserialization/KvDeserializationInfo.java x: 6 # contributors y: 112 lines of code inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/CdcIdEnum.java x: 2 # contributors y: 88 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/AuditService.java x: 6 # contributors y: 16 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AuditServiceImpl.java x: 15 # contributors y: 272 lines of code inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/entity/AuditType.java x: 1 # contributors y: 30 lines of code inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/base/TableFormatUtils.java x: 4 # contributors y: 510 lines of code inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/base/TextFormatBuilder.java x: 2 # contributors y: 69 lines of code inlong-sort/sort-formats/format-common/src/main/java/org/apache/inlong/sort/formats/util/StringUtils.java x: 6 # contributors y: 489 lines of code inlong-sort/sort-formats/format-row/format-csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvDeserializationSchema.java x: 2 # contributors y: 146 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/row/InLongMsgUtils.java x: 2 # contributors y: 338 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogFormatDeserializer.java x: 3 # contributors y: 146 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-binlog/src/main/java/org/apache/inlong/sort/formats/inlongmsgbinlog/InLongMsgBinlogUtils.java x: 3 # contributors y: 257 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java x: 3 # contributors y: 285 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvMixedFormatConverter.java x: 3 # contributors y: 102 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvUtils.java x: 3 # contributors y: 132 lines of code inlong-sort/sort-formats/format-row/format-inlongmsg-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvUtils.java x: 3 # contributors y: 117 lines of code inlong-sort/sort-formats/format-row/format-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvDeserializationSchema.java x: 2 # contributors y: 141 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgUtils.java x: 2 # contributors y: 327 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-csv/src/main/java/org/apache/inlong/sort/formats/inlongmsgcsv/InLongMsgCsvFormatDeserializer.java x: 2 # contributors y: 312 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-kv/src/main/java/org/apache/inlong/sort/formats/inlongmsgkv/InLongMsgKvFormatDeserializer.java x: 2 # contributors y: 258 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogcsv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogcsv/InLongMsgTlogCsvFormatDeserializer.java x: 2 # contributors y: 288 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-tlogkv/src/main/java/org/apache/inlong/sort/formats/inlongmsgtlogkv/InLongMsgTlogKvFormatDeserializer.java x: 2 # contributors y: 278 lines of code inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/AuditReporterImpl.java x: 1 # contributors y: 514 lines of code inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/MetricIdEnum.java x: 2 # contributors y: 40 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java x: 10 # contributors y: 52 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/EventReportUtils.java x: 1 # contributors y: 74 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentStatusManager.java x: 3 # contributors y: 246 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/HeartbeatManager.java x: 15 # contributors y: 177 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/TaskManager.java x: 14 # contributors y: 460 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/fetcher/ManagerFetcher.java x: 19 # contributors y: 245 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/dataproxy/Sender.java x: 1 # contributors y: 337 lines of code inlong-agent/conf/log4j2.xml x: 8 # contributors y: 196 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/AgentConstants.java x: 13 # contributors y: 93 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/task/OffsetManager.java x: 2 # contributors y: 165 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/task/logcollection/LogAbstractTask.java x: 2 # contributors y: 179 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/TcpMsgSenderConfig.java x: 1 # contributors y: 239 lines of code inlong-sort/sort-formats/format-rowdata/format-inlongmsg-rowdata-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/AbstractInLongMsgFormatDeserializer.java x: 1 # contributors y: 133 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/node/provider/PulsarProvider.java x: 4 # contributors y: 100 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/extract/PulsarExtractNode.java x: 9 # contributors y: 175 lines of code inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/entity/InlongGroupEntity.java x: 5 # contributors y: 35 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkServiceImpl.java x: 14 # contributors y: 782 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SourceType.java x: 9 # contributors y: 35 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sink/cls/ClsOperator.java x: 2 # contributors y: 207 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigManager.java x: 10 # contributors y: 907 lines of code inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/group/send_group.cc x: 2 # contributors y: 376 lines of code inlong-dashboard/src/ui/pages/Clusters/NodeEditModal.tsx x: 5 # contributors y: 342 lines of code inlong-dashboard/src/ui/pages/Clusters/NodeManage.tsx x: 3 # contributors y: 714 lines of code inlong-dashboard/src/ui/pages/Login/index.tsx x: 3 # contributors y: 61 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/ProxySink.java x: 17 # contributors y: 235 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/instance/InstanceManager.java x: 3 # contributors y: 453 lines of code inlong-dashboard/src/plugins/groups/common/GroupDefaultInfo.ts x: 4 # contributors y: 120 lines of code inlong-dashboard/src/plugins/sources/common/SourceDefaultInfo.ts x: 5 # contributors y: 200 lines of code inlong-dashboard/src/plugins/sources/defaults/index.ts x: 6 # contributors y: 88 lines of code inlong-dashboard/src/ui/pages/SynchronizeDashboard/index.tsx x: 3 # contributors y: 199 lines of code inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongGroupEntityMapper.java x: 10 # contributors y: 54 lines of code inlong-manager/manager-dao/src/main/resources/mappers/InlongGroupEntityMapper.xml x: 15 # contributors y: 578 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupBriefInfo.java x: 4 # contributors y: 48 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupServiceImpl.java x: 14 # contributors y: 827 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongGroupController.java x: 15 # contributors y: 216 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/DataNodeType.java x: 8 # contributors y: 24 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/AgentServiceImpl.java x: 19 # contributors y: 830 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/AbstractSourceOperator.java x: 11 # contributors y: 522 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceOperator.java x: 6 # contributors y: 37 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/file/FileSourceOperator.java x: 7 # contributors y: 123 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/LogFileSource.java x: 3 # contributors y: 325 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/file/AbstractSource.java x: 3 # contributors y: 355 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/metric/MetricDataHolder.java x: 1 # contributors y: 441 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/BaseMsgSenderFactory.java x: 1 # contributors y: 300 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/common/ProxyClientConfig.java x: 1 # contributors y: 451 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpClientMgr.java x: 1 # contributors y: 690 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/tcp/TcpNettyClient.java x: 1 # contributors y: 420 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/http/HttpMsgSenderConfig.java x: 1 # contributors y: 185 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/sender/tcp/InLongTcpMsgSender.java x: 1 # contributors y: 402 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/utils/ProxyUtils.java x: 7 # contributors y: 139 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/InlongConstants.java x: 16 # contributors y: 94 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongSingleTopicManager.java x: 7 # contributors y: 389 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongTopicManager.java x: 2 # contributors y: 430 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/HttpClientExample.java x: 7 # contributors y: 79 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/example/TcpClientExample.java x: 11 # contributors y: 61 lines of code inlong-common/src/main/java/org/apache/inlong/common/enums/MetaField.java x: 9 # contributors y: 41 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/ExtractNode.java x: 12 # contributors y: 86 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/network/ClientMgr.java x: 10 # contributors y: 11 lines of code inlong-common/src/main/java/org/apache/inlong/common/msg/AttributeConstants.java x: 6 # contributors y: 34 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/configuration/Constants.java x: 15 # contributors y: 205 lines of code inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/Entrance.java x: 7 # contributors y: 105 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/Constants.java x: 11 # contributors y: 324 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/source/IcebergSource.java x: 2 # contributors y: 451 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java x: 2 # contributors y: 494 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java x: 3 # contributors y: 367 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/mysql/source/MySqlSource.java x: 3 # contributors y: 167 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/PulsarTableFactory.java x: 4 # contributors y: 178 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/PulsarSourceBuilder.java x: 2 # contributors y: 233 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/source/reader/PulsarOrderedSourceReader.java x: 3 # contributors y: 194 lines of code inlong-audit/audit-service/src/main/java/org/apache/inlong/audit/service/node/ApiService.java x: 1 # contributors y: 345 lines of code inlong-dashboard/src/plugins/streams/common/StreamDefaultInfo.ts x: 5 # contributors y: 281 lines of code inlong-dashboard/src/ui/pages/GroupDetail/DataStream/index.tsx x: 3 # contributors y: 278 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/TaskConstants.java x: 6 # contributors y: 170 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/pojo/TaskProfileDto.java x: 6 # contributors y: 520 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/COSSource.java x: 1 # contributors y: 304 lines of code inlong-manager/manager-dao/src/main/resources/mappers/DataNodeEntityMapper.xml x: 4 # contributors y: 254 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/node/DataNodeServiceImpl.java x: 8 # contributors y: 244 lines of code inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/encode/SinkEncoderFactory.java x: 3 # contributors y: 27 lines of code inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/source/ServerMessageHandler.java x: 6 # contributors y: 190 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/StreamSourceServiceImpl.java x: 18 # contributors y: 492 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamServiceImpl.java x: 11 # contributors y: 829 lines of code inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-golang/dataproxy/worker.go x: 2 # contributors y: 601 lines of code inlong-sdk/dataproxy-sdk/src/main/java/org/apache/inlong/sdk/dataproxy/config/ProxyConfigEntry.java x: 5 # contributors y: 72 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterServiceImpl.java x: 19 # contributors y: 1272 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarQueueResourceOperator.java x: 5 # contributors y: 285 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/consumer_impl.go x: 3 # contributors y: 796 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/client/heartbeat.go x: 4 # contributors y: 215 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaIdConfig.java x: 5 # contributors y: 57 lines of code inlong-common/src/main/java/org/apache/inlong/common/enums/TaskTypeEnum.java x: 13 # contributors y: 44 lines of code inlong-agent/agent-installer/src/main/java/org/apache/inlong/agent/installer/ModuleManager.java x: 1 # contributors y: 575 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/DatabaseSqlSource.java x: 4 # contributors y: 56 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/KafkaSource.java x: 8 # contributors y: 147 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MongoDBSource.java x: 5 # contributors y: 147 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/MqttSource.java x: 5 # contributors y: 166 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/PostgreSQLSource.java x: 4 # contributors y: 161 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/RedisSource.java x: 5 # contributors y: 579 lines of code inlong-common/src/main/java/org/apache/inlong/common/pojo/dataproxy/DataProxyNodeResponse.java x: 4 # contributors y: 13 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/group/InlongGroupInfo.java x: 8 # contributors y: 108 lines of code inlong-dashboard/src/ui/pages/SynchronizeDetail/Info/index.tsx x: 3 # contributors y: 216 lines of code inlong-manager/manager-schedule/src/main/java/org/apache/inlong/manager/schedule/dolphinscheduler/DolphinScheduleUtils.java x: 2 # contributors y: 575 lines of code inlong-dashboard/src/ui/pages/common/DirtyModal/index.tsx x: 1 # contributors y: 565 lines of code inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/source/KafkaSource.java x: 1 # contributors y: 172 lines of code inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaConnectorOptionsUtil.java x: 1 # contributors y: 537 lines of code inlong-sort/sort-flink/sort-flink-v1.18/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSink.java x: 1 # contributors y: 357 lines of code inlong-common/src/main/java/org/apache/inlong/common/constant/SinkType.java x: 3 # contributors y: 11 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/SinkRequest.java x: 8 # contributors y: 76 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/StreamSink.java x: 6 # contributors y: 93 lines of code inlong-manager/manager-test/src/main/resources/h2/apache_inlong_manager.sql x: 22 # contributors y: 834 lines of code inlong-manager/manager-web/sql/apache_inlong_manager.sql x: 32 # contributors y: 886 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSinkController.java x: 10 # contributors y: 143 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceDTO.java x: 9 # contributors y: 77 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/source/file/FileSourceRequest.java x: 7 # contributors y: 60 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/table/sink/table/StarRocksDynamicSinkFunctionV2.java x: 4 # contributors y: 369 lines of code inlong-dashboard/src/ui/pages/GroupDetail/Audit/config.tsx x: 4 # contributors y: 342 lines of code inlong-audit/audit-sdk/src/main/java/org/apache/inlong/audit/send/SenderManager.java x: 5 # contributors y: 235 lines of code inlong-manager/manager-dao/src/main/resources/mappers/OperationLogEntityMapper.xml x: 5 # contributors y: 314 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongClusterController.java x: 14 # contributors y: 273 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/ServerMessageHandler.java x: 15 # contributors y: 550 lines of code inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/pulsar/PulsarClientService.java x: 6 # contributors y: 204 lines of code inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/InlongGroupClient.java x: 11 # contributors y: 237 lines of code docker/kubernetes/templates/tubemq-broker-ini-configmap.yaml x: 4 # contributors y: 23 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerConfig.java x: 7 # contributors y: 480 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/BrokerServiceServer.java x: 7 # contributors y: 1135 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java x: 6 # contributors y: 539 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/MessageStoreManager.java x: 6 # contributors y: 701 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/DefaultOffsetManager.java x: 7 # contributors y: 821 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/OffsetRecordService.java x: 4 # contributors y: 125 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/offset/offsetfile/FileOffsetStorage.java x: 1 # contributors y: 630 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/web/BrokerAdminServlet.java x: 6 # contributors y: 1564 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/fileconfig/AbstractFileConfig.java x: 6 # contributors y: 338 lines of code inlong-manager/manager-dao/src/main/resources/mappers/InlongClusterNodeEntityMapper.xml x: 8 # contributors y: 256 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/heartbeat/HeartbeatManager.java x: 7 # contributors y: 351 lines of code inlong-dashboard/src/plugins/sinks/defaults/Redis.ts x: 4 # contributors y: 451 lines of code inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/node/Application.java x: 4 # contributors y: 278 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/DebeziumSourceFunction.java x: 2 # contributors y: 416 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/mongodb/MongoDBConnectorDeserializationSchema.java x: 2 # contributors y: 723 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/sqlserver-cdc/src/main/java/org/apache/inlong/sort/sqlserver/RowDataDebeziumDeserializeSchema.java x: 2 # contributors y: 566 lines of code inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/KafkaSink.java x: 4 # contributors y: 403 lines of code inlong-audit/audit-proxy/src/main/java/org/apache/inlong/audit/sink/TubeSink.java x: 7 # contributors y: 518 lines of code inlong-sdk/transform-sdk/src/main/java/org/apache/inlong/sdk/transform/process/operator/OperatorTools.java x: 9 # contributors y: 144 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/StreamSourceController.java x: 10 # contributors y: 103 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkExactlyMetric.java x: 2 # contributors y: 392 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/consts/SinkType.java x: 10 # contributors y: 74 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/user/UserService.java x: 5 # contributors y: 15 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/user/UserServiceImpl.java x: 9 # contributors y: 417 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/manager/InlongMultiTopicManager.java x: 6 # contributors y: 253 lines of code inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/StreamSourceEntityMapper.java x: 9 # contributors y: 62 lines of code inlong-manager/manager-dao/src/main/resources/mappers/StreamSourceEntityMapper.xml x: 10 # contributors y: 623 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/conf/AbstractConfiguration.java x: 7 # contributors y: 166 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarOperator.java x: 9 # contributors y: 364 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FilterFunctionUtils.java x: 7 # contributors y: 204 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/transformation/function/SingleValueFilterFunction.java x: 5 # contributors y: 50 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/sort/DefaultSortConfigOperator.java x: 10 # contributors y: 234 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldInfoUtils.java x: 12 # contributors y: 309 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/StreamSinkService.java x: 8 # contributors y: 42 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/cluster/ClusterNodeRequest.java x: 6 # contributors y: 56 lines of code inlong-sdk/dataproxy-sdk-twins/dataproxy-sdk-cpp/src/client/tcp_client.cc x: 1 # contributors y: 385 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortServiceImpl.java x: 10 # contributors y: 283 lines of code inlong-dashboard/src/plugins/sinks/common/SinkDefaultInfo.ts x: 5 # contributors y: 216 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sources/reader/BinlogReader.java x: 14 # contributors y: 246 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaSeeker.java x: 4 # contributors y: 79 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/format/JsonDynamicSchemaFormat.java x: 4 # contributors y: 240 lines of code inlong-sort/sort-common/src/main/java/org/apache/inlong/sort/protocol/node/Node.java x: 17 # contributors y: 111 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/cluster/InlongClusterService.java x: 13 # contributors y: 62 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/util/JsonUtils.java x: 11 # contributors y: 140 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/kafka/KafkaOperator.java x: 6 # contributors y: 148 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/stream/InlongStreamService.java x: 7 # contributors y: 43 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/InlongStreamController.java x: 12 # contributors y: 218 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/SortClusterServiceImpl.java x: 6 # contributors y: 232 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/repository/DataProxyConfigRepository.java x: 12 # contributors y: 531 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/cls/ClsSinkContext.java x: 6 # contributors y: 222 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/pulsar/PulsarProducerCluster.java x: 7 # contributors y: 228 lines of code inlong-manager/manager-common/src/main/java/org/apache/inlong/manager/common/enums/ErrorCodeEnum.java x: 14 # contributors y: 145 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/plugin/PluginClassLoader.java x: 7 # contributors y: 150 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sink/mysql/MySQLSinkDTO.java x: 8 # contributors y: 129 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/es/ElasticsearchSinkOperator.java x: 9 # contributors y: 178 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/api/SortClientConfig.java x: 5 # contributors y: 394 lines of code inlong-sdk/sort-sdk/src/main/java/org/apache/inlong/sdk/sort/fetcher/kafka/KafkaMultiTopicsFetcher.java x: 4 # contributors y: 326 lines of code inlong-distribution/src/main/assemblies/sort-connectors-v1.15.xml x: 9 # contributors y: 115 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/transform/StreamTransformServiceImpl.java x: 8 # contributors y: 285 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/tenant/InlongTenantServiceImpl.java x: 6 # contributors y: 318 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SourceMetricData.java x: 7 # contributors y: 235 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/CommonConfigHolder.java x: 2 # contributors y: 661 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/openapi/DataProxyController.java x: 12 # contributors y: 69 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/AbstractSinkOperator.java x: 12 # contributors y: 233 lines of code inlong-agent/agent-core/src/main/java/org/apache/inlong/agent/core/AgentManager.java x: 13 # contributors y: 115 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/DataNodeController.java x: 10 # contributors y: 107 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/stream/InlongStreamInfo.java x: 9 # contributors y: 94 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/BaseSource.java x: 6 # contributors y: 475 lines of code inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/SortTask.java x: 5 # contributors y: 138 lines of code inlong-sort/sort-flink/base/src/main/java/org/apache/inlong/sort/base/metric/SinkMetricData.java x: 5 # contributors y: 249 lines of code inlong-distribution/src/main/assemblies/release.xml x: 6 # contributors y: 140 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/JobConstants.java x: 12 # contributors y: 12 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/utils/PluginUtils.java x: 12 # contributors y: 101 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/config/ConfigManager.java x: 15 # contributors y: 464 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/config/config.go x: 4 # contributors y: 526 lines of code inlong-manager/manager-pojo/src/main/java/org/apache/inlong/manager/pojo/sort/util/FieldRelationUtils.java x: 9 # contributors y: 247 lines of code inlong-sort/sort-core/src/main/java/org/apache/inlong/sort/parser/impl/FlinkSqlParser.java x: 12 # contributors y: 719 lines of code inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongGroupImpl.java x: 10 # contributors y: 262 lines of code inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/inner/client/StreamSinkClient.java x: 8 # contributors y: 97 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/group/InlongGroupProcessService.java x: 7 # contributors y: 288 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/workflow/WorkflowServiceImpl.java x: 13 # contributors y: 218 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/internal/JdbcMultiBatchingOutputFormat.java x: 4 # contributors y: 767 lines of code inlong-common/src/main/java/org/apache/inlong/common/msg/InLongMsg.java x: 6 # contributors y: 857 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/HttpManager.java x: 8 # contributors y: 162 lines of code inlong-manager/manager-dao/src/main/resources/mappers/StreamSinkEntityMapper.xml x: 7 # contributors y: 464 lines of code inlong-dashboard/src/plugins/sinks/defaults/ClickHouse.ts x: 3 # contributors y: 430 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/KafkaSink.java x: 4 # contributors y: 288 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/sinks/PulsarSink.java x: 10 # contributors y: 295 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/sink/starrocks/StarRocksSinkOperator.java x: 4 # contributors y: 146 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/source/pulsar/PulsarSourceOperator.java x: 13 # contributors y: 174 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/resource/queue/pulsar/PulsarUtils.java x: 6 # contributors y: 653 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSource.java x: 4 # contributors y: 715 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/pulsar/src/main/java/org/apache/inlong/sort/pulsar/internal/FlinkPulsarSourceWithoutAdmin.java x: 3 # contributors y: 646 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergSingleFileCommiter.java x: 5 # contributors y: 376 lines of code inlong-agent/agent-common/src/main/java/org/apache/inlong/agent/utils/AgentUtils.java x: 12 # contributors y: 258 lines of code inlong-manager/manager-dao/src/main/java/org/apache/inlong/manager/dao/mapper/InlongClusterEntityMapper.java x: 7 # contributors y: 26 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/hbase/src/main/resources/hbase-default.xml x: 1 # contributors y: 1734 lines of code inlong-manager/manager-dao/src/main/resources/mappers/WorkflowTaskEntityMapper.xml x: 5 # contributors y: 184 lines of code inlong-manager/manager-dao/src/main/resources/mappers/InlongStreamEntityMapper.xml x: 8 # contributors y: 424 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/utils/MessageUtils.java x: 8 # contributors y: 225 lines of code inlong-manager/manager-dao/src/main/resources/mappers/InlongConsumeEntityMapper.xml x: 4 # contributors y: 303 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/postgres-cdc/src/main/java/org/apache/inlong/sort/cdc/postgres/DebeziumSourceFunction.java x: 3 # contributors y: 482 lines of code inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/consts/ConfigConstants.java x: 11 # contributors y: 99 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/impl/WorkflowApproverServiceImpl.java x: 14 # contributors y: 113 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/DynamicKafkaSerializationSchema.java x: 6 # contributors y: 417 lines of code inlong-manager/manager-client-tools/src/main/java/org/apache/inlong/manager/client/cli/ListCommand.java x: 9 # contributors y: 303 lines of code inlong-manager/manager-client/src/main/java/org/apache/inlong/manager/client/api/impl/InlongStreamImpl.java x: 12 # contributors y: 407 lines of code inlong-sort/sort-flink/sort-flink-v1.15/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/FlinkCatalog.java x: 1 # contributors y: 657 lines of code inlong-sort/sort-flink/cdc-base/src/main/java/org/apache/inlong/sort/cdc/base/debezium/table/RowDataDebeziumDeserializeSchema.java x: 3 # contributors y: 689 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/FlinkSink.java x: 6 # contributors y: 584 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/iceberg/src/main/java/org/apache/inlong/sort/iceberg/sink/multiple/IcebergMultipleStreamWriter.java x: 6 # contributors y: 325 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/jdbc/src/main/java/org/apache/inlong/sort/jdbc/table/JdbcDynamicTableFactory.java x: 3 # contributors y: 413 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/debezium/DebeziumSourceFunction.java x: 3 # contributors y: 474 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/org/apache/inlong/sort/cdc/mysql/table/MySqlTableSource.java x: 4 # contributors y: 378 lines of code inlong-manager/manager-web/src/main/java/org/apache/inlong/manager/web/controller/UserController.java x: 14 # contributors y: 73 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/source/reader/fetch/OracleScanFetchTask.java x: 3 # contributors y: 393 lines of code inlong-tubemq/resources/assets/scripts/common/module.js x: 4 # contributors y: 1297 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/utils/WebParameterUtils.java x: 7 # contributors y: 1305 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicTableFactory.java x: 5 # contributors y: 528 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/oracle-cdc/src/main/java/org/apache/inlong/sort/cdc/oracle/debezium/table/RowDataDebeziumDeserializeSchema.java x: 3 # contributors y: 730 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/doris/src/main/java/org/apache/inlong/sort/doris/table/DorisDynamicSchemaOutputFormat.java x: 3 # contributors y: 937 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mongodb-cdc/src/main/java/org/apache/inlong/sort/cdc/mongodb/debezium/table/MongoDBConnectorDeserializationSchema.java x: 3 # contributors y: 772 lines of code inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/BaseMessageConsumer.java x: 6 # contributors y: 1442 lines of code inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/SimpleClientBalanceConsumer.java x: 3 # contributors y: 1555 lines of code inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/producer/ProducerManager.java x: 6 # contributors y: 639 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/mysql-cdc/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 1 # contributors y: 896 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/HiveTableSink.java x: 3 # contributors y: 534 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/hive/src/main/java/org/apache/inlong/sort/hive/filesystem/HadoopPathBasedPartFileWriter.java x: 1 # contributors y: 615 lines of code inlong-manager/manager-service/src/main/java/org/apache/inlong/manager/service/core/WorkflowApproverService.java x: 7 # contributors y: 14 lines of code inlong-agent/agent-plugins/src/main/java/org/apache/inlong/agent/plugin/channel/MemoryChannel.java x: 12 # contributors y: 129 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaConsumerBase.java x: 2 # contributors y: 735 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/FlinkKafkaProducer.java x: 2 # contributors y: 1358 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/kafka/src/main/java/org/apache/inlong/sort/kafka/table/KafkaDynamicSource.java x: 2 # contributors y: 470 lines of code inlong-sort/sort-flink/sort-flink-v1.13/sort-connectors/starrocks/src/main/java/org/apache/inlong/sort/starrocks/manager/StarRocksSinkManager.java x: 2 # contributors y: 639 lines of code inlong-tubemq/tubemq-client/src/main/java/org/apache/inlong/tubemq/client/consumer/RmtDataCache.java x: 7 # contributors y: 1264 lines of code inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corebase/policies/FlowCtrlRuleHandler.java x: 7 # contributors y: 658 lines of code inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/codec/PbEnDecoder.java x: 6 # contributors y: 272 lines of code inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/netty/NettyClient.java x: 7 # contributors y: 328 lines of code inlong-tubemq/tubemq-core/src/main/java/org/apache/inlong/tubemq/corerpc/netty/NettyRpcServer.java x: 8 # contributors y: 333 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/FileSegmentList.java x: 6 # contributors y: 290 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/disk/MsgFileStore.java x: 8 # contributors y: 602 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/msgstore/mem/MsgMemStore.java x: 7 # contributors y: 305 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/common/zookeeper/RecoverableZooKeeper.java x: 3 # contributors y: 387 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/MasterConfig.java x: 7 # contributors y: 693 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/TMaster.java x: 6 # contributors y: 2196 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/balance/DefaultLoadBalancer.java x: 7 # contributors y: 555 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbBrokerConfEntity.java x: 7 # contributors y: 460 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbGroupFlowCtrlEntity.java x: 8 # contributors y: 267 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbTopicAuthControlEntity.java x: 8 # contributors y: 183 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/bdbstore/bdbentitys/BdbTopicConfEntity.java x: 8 # contributors y: 378 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/DefaultMetaDataService.java x: 3 # contributors y: 994 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/ClusterSettingEntity.java x: 5 # contributors y: 323 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/dao/entity/TopicPropGroup.java x: 6 # contributors y: 403 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsMetaConfigMapperImpl.java x: 3 # contributors y: 1091 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/metamanage/metastore/impl/AbsTopicDeployMapperImpl.java x: 3 # contributors y: 663 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodebroker/DefBrokerRunManager.java x: 5 # contributors y: 481 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/nodemanage/nodeconsumer/ConsumeGroupInfo.java x: 3 # contributors y: 636 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebAdminGroupCtrlHandler.java x: 6 # contributors y: 1222 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebBrokerConfHandler.java x: 5 # contributors y: 898 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebMasterInfoHandler.java x: 6 # contributors y: 381 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/handler/WebTopicDeployHandler.java x: 5 # contributors y: 975 lines of code inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliMetaDataBRU.java x: 3 # contributors y: 1411 lines of code inlong-manager/manager-dao/src/main/resources/generatorConfig.xml x: 11 # contributors y: 47 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/baseproducer.cc x: 2 # contributors y: 645 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_config.cc x: 5 # contributors y: 602 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/flowctrl_def.cc x: 3 # contributors y: 703 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/rmt_data_cache.cc x: 4 # contributors y: 556 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-cpp/src/tubemq_tdmsg.cc x: 3 # contributors y: 866 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/multiplexing/multiplexing.go x: 2 # contributors y: 361 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/protocol/BrokerService.pb.go x: 2 # contributors y: 1346 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/protocol/MasterService.pb.go x: 2 # contributors y: 4509 lines of code inlong-tubemq/tubemq-client-twins/tubemq-client-go/protocol/RPC.pb.go x: 2 # contributors y: 531 lines of code inlong-tubemq/resources/assets/public/css/style.css x: 2 # contributors y: 971 lines of code
4509.0
lines of code
  min: 1.0
  average: 93.82
  25th percentile: 21.0
  median: 47.0
  75th percentile: 108.0
  max: 4509.0
0 32.0
# contributors
min: 1.0 | average: 2.72 | 25th percentile: 1.0 | median: 2.0 | 75th percentile: 4.0 | max: 32.0