apache / seatunnel
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 3,063 files with 237,969 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 7 files changed 51-100 times (5,195 lines of code)
    • 87 files changed 21-50 times (19,144 lines of code)
    • 793 files changed 6-20 times (85,945 lines of code)
    • 2,176 files changed 1-5 times (127,685 lines of code)
0% | 2% | 8% | 36% | 53%
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 3,063 files with 237,969 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 129 files changed by 11-25 contributors (29,276 lines of code)
    • 547 files changed by 6-10 contributors (59,669 lines of code)
    • 1,403 files changed by 2-5 contributors (95,566 lines of code)
    • 984 files changed by 1 contributor (53,458 lines of code)
0% | 12% | 25% | 40% | 22%
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, md, xml, txt, yaml, sql, svg, ts, json, properties, sh, tsx, cmd, js, scss, orc, py, toml, mdx, gitignore, gitattributes, html, cjs, tpl, gitmodules
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 2% | 7% | 36% | 53%
xml0% | 0% | 85% | 0% | 14%
py0% | 0% | 54% | 0% | 45%
yaml0% | 0% | 0% | 40% | 59%
tsx0% | 0% | 0% | 0% | 100%
ts0% | 0% | 0% | 0% | 100%
scss0% | 0% | 0% | 0% | 100%
tpl0% | 0% | 0% | 0% | 100%
cmd0% | 0% | 0% | 0% | 100%
js0% | 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
seatunnel-engine0% | 14% | 16% | 30% | 38%
seatunnel-connectors-v20% | 0% | 6% | 36% | 56%
seatunnel-api0% | 0% | 8% | 39% | 51%
seatunnel-core0% | 0% | 16% | 47% | 35%
seatunnel-plugin-discovery0% | 0% | 66% | 27% | 6%
seatunnel-dist0% | 0% | 85% | 0% | 14%
seatunnel-common0% | 0% | 8% | 72% | 19%
tools0% | 0% | 54% | 0% | 45%
seatunnel-formats0% | 0% | 3% | 36% | 59%
seatunnel-translation0% | 0% | 0% | 67% | 32%
seatunnel-transforms-v20% | 0% | 0% | 31% | 68%
config0% | 0% | 0% | 41% | 58%
seatunnel-examples0% | 0% | 0% | 23% | 76%
seatunnel-config0% | 0% | 0% | 0% | 100%
seatunnel-shade0% | 0% | 0% | 0% | 100%
deploy0% | 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
JobMaster.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master
 916 39 2022-08-03 2025-04-08 87 18 fanjiaeminem@qq.com wanghailin@apache.org
TaskExecutionService.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 901 35 2022-08-01 2025-03-20 68 13 83933160+ic4y@users.noreply... fanjiaeminem@qq.com
CheckpointCoordinator.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint
 913 38 2022-08-23 2025-04-27 61 16 zongwen.li.tech@gmail.com fanjiaeminem@qq.com
CoordinatorService.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 883 35 2022-09-20 2025-03-26 57 19 gaojun2048@gmail.com shenghang@apache.org
MultipleTableJobConfigParser.java
in seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse
 719 23 2023-02-21 2025-04-08 56 17 zongwen@apache.org wanghailin@apache.org
SeaTunnelServer.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 277 23 2022-07-27 2025-03-28 54 14 gaojun2048@gmail.com shenghang@apache.org
SubPlan.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical
 586 30 2022-08-09 2025-04-29 52 12 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
CheckpointManager.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint
 244 20 2022-08-23 2025-01-08 46 10 zongwen.li.tech@gmail.com fanjiaeminem@qq.com
SourceSplitEnumeratorTask.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task
 344 25 2022-08-03 2025-04-14 43 12 fanjiaeminem@qq.com fanjiaeminem@qq.com
PhysicalVertex.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical
 491 28 2022-08-09 2025-04-27 43 10 gaojun2048@gmail.com fanjiaeminem@qq.com
SeaTunnelTask.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task
 372 21 2022-08-03 2025-04-27 42 11 fanjiaeminem@qq.com wanghailin@apache.org
PhysicalPlanGenerator.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical
 528 9 2022-08-03 2025-04-27 42 15 fanjiaeminem@qq.com wanghailin@apache.org
ClientExecuteCommand.java
in seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command
 253 6 2022-09-15 2025-01-09 40 16 fanjiaeminem@qq.com fanjiaeminem@qq.com
FactoryUtil.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory
 397 17 2022-04-28 2025-02-13 39 12 wenjun@apache.org jarvis@apache.org
AbstractJdbcCatalog.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog
 621 58 2022-06-28 2025-03-24 38 15 gaojun2048@gmail.com 2795267041@qq.com
KafkaSource.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source
 94 8 2022-06-28 2025-03-28 37 22 gaojun2048@gmail.com 35264598+jesseatsz@users.no...
SinkFlowLifeCycle.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow
 295 10 2022-08-15 2025-01-15 37 14 fanjiaeminem@qq.com 77472193+cheun99@users.nore...
AbstractReadStrategy.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader
 334 14 2022-08-15 2025-04-08 37 14 tyrantlucifer@gmail.com 280154548@qq.com
PhysicalPlan.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical
 273 18 2022-08-03 2025-03-26 36 8 fanjiaeminem@qq.com shenghang@apache.org
assembly-bin.xml
in seatunnel-dist/src/main/assembly
 163 - 2022-03-08 2024-11-07 35 12 kirs@apache.org 837833280@qq.com
JdbcSink.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink
 268 10 2022-06-28 2024-12-05 34 13 gaojun2048@gmail.com fanjiaeminem@qq.com
AbstractPluginDiscovery.java
in seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery
 411 20 2022-05-15 2025-02-25 34 12 wenjun@apache.org 73771213+corgy-w@users.nore...
HiveSink.java
in seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink
 202 10 2022-06-28 2025-04-08 33 15 gaojun2048@gmail.com 280154548@qq.com
SinkAggregatedCommitterTask.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task
 277 14 2022-08-03 2025-01-08 33 9 fanjiaeminem@qq.com fanjiaeminem@qq.com
RestHttpGetCommandProcessor.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest
 285 20 2023-02-15 2024-12-25 33 13 804167098@qq.com jarvis@apache.org
AbstractWriteStrategy.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer
 337 24 2022-08-31 2025-04-08 33 11 tyrantlucifer@gmail.com 280154548@qq.com
JdbcDialect.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect
 604 36 2022-06-28 2025-03-26 33 17 gaojun2048@gmail.com 2795267041@qq.com
ServerConfigOptions.java
in seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server
 301 - 2022-10-17 2025-04-17 32 18 fanjiaeminem@qq.com nijiahui_yewu@cmss.chinamob...
SeaTunnelRow.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type
 335 24 2022-05-09 2025-01-21 32 17 wenjun@apache.org nijiahui_yewu@cmss.chinamob...
JobConfigParser.java
in seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse
 35 4 2022-09-20 2025-01-22 31 11 gaojun2048@gmail.com 804167098@qq.com
SeaTunnelClient.java
in seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client
 142 19 2022-07-27 2024-09-04 31 11 gaojun2048@gmail.com 54729175+zhangweike2000@use...
CatalogTableUtil.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog
 213 13 2023-02-20 2025-02-13 30 7 zongwen@apache.org jarvis@apache.org
ExecutionPlanGenerator.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution
 325 8 2022-08-03 2025-04-27 30 11 fanjiaeminem@qq.com wanghailin@apache.org
SourceFlowLifeCycle.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow
 342 23 2022-08-15 2025-01-08 30 12 fanjiaeminem@qq.com fanjiaeminem@qq.com
YamlSeaTunnelDomConfigProcessor.java
in seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config
 517 15 2022-08-05 2025-04-17 30 17 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
assembly-bin-ci.xml
in seatunnel-dist/src/main/assembly
 163 - 2022-07-13 2024-11-07 29 11 gaojun2048@gmail.com 837833280@qq.com
HttpSource.java
in seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source
 170 9 2022-08-08 2025-04-30 29 19 tyrantlucifer@gmail.com nijiahui_yewu@cmss.chinamob...
TextReadStrategy.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader
 218 5 2022-08-15 2025-04-08 29 13 tyrantlucifer@gmail.com 280154548@qq.com
JdbcSinkFactory.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink
 250 4 2022-11-19 2025-04-02 29 15 wenwei8268@gmail.com 73771213+corgy-w@users.nore...
BaseHdfsFileSource.java
in seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source
 117 1 2022-09-23 2025-02-13 28 11 gaojun2048@gmail.com jarvis@apache.org
Common.java
in seatunnel-common/src/main/java/org/apache/seatunnel/common/config
 131 15 2021-12-24 2024-11-30 28 16 zhongjiajie955@hotmail.com 39961809+hawk9821@users.nor...
JdbcSource.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source
 78 8 2022-06-28 2023-12-05 27 15 gaojun2048@gmail.com 83933160+ic4y@users.noreply...
MySqlIncrementalSourceFactory.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source
 119 4 2022-12-23 2025-02-13 27 10 wanghailin@apache.org jarvis@apache.org
SinkExecuteProcessor.java
in seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution
 158 4 2023-01-31 2025-02-13 26 15 tyrantlucifer@gmail.com jarvis@apache.org
S3FileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source
 86 4 2022-11-17 2025-04-08 25 15 tyrantlucifer@gmail.com 280154548@qq.com
MySqlIncrementalSource.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source
 133 9 2022-11-21 2024-11-14 25 7 zongwen@apache.org wanghailin@apache.org
TaskDataSerializerHook.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable
 137 3 2022-08-03 2024-11-05 25 11 fanjiaeminem@qq.com 73771213+corgy-w@users.nore...
KafkaSinkWriter.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink
 259 14 2022-06-28 2025-03-03 25 12 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
DefaultSeaTunnelRowSerializer.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize
 279 18 2022-06-28 2025-03-03 25 15 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
FakeDataGenerator.java
in seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source
 305 10 2022-09-30 2025-01-06 25 12 tyrantlucifer@gmail.com wanghailin@apache.org
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
KafkaSource.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source
 94 8 2022-06-28 2025-03-28 37 22 gaojun2048@gmail.com 35264598+jesseatsz@users.no...
CoordinatorService.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 883 35 2022-09-20 2025-03-26 57 19 gaojun2048@gmail.com shenghang@apache.org
HttpSource.java
in seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source
 170 9 2022-08-08 2025-04-30 29 19 tyrantlucifer@gmail.com nijiahui_yewu@cmss.chinamob...
JobMaster.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master
 916 39 2022-08-03 2025-04-08 87 18 fanjiaeminem@qq.com wanghailin@apache.org
ServerConfigOptions.java
in seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server
 301 - 2022-10-17 2025-04-17 32 18 fanjiaeminem@qq.com nijiahui_yewu@cmss.chinamob...
MultipleTableJobConfigParser.java
in seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse
 719 23 2023-02-21 2025-04-08 56 17 zongwen@apache.org wanghailin@apache.org
JdbcDialect.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect
 604 36 2022-06-28 2025-03-26 33 17 gaojun2048@gmail.com 2795267041@qq.com
SeaTunnelRow.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type
 335 24 2022-05-09 2025-01-21 32 17 wenjun@apache.org nijiahui_yewu@cmss.chinamob...
YamlSeaTunnelDomConfigProcessor.java
in seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config
 517 15 2022-08-05 2025-04-17 30 17 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
ClickhouseFileSink.java
in seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file
 48 4 2022-06-28 2025-02-20 22 17 gaojun2048@gmail.com 33561138+lyne7-sc@users.nor...
CheckpointCoordinator.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint
 913 38 2022-08-23 2025-04-27 61 16 zongwen.li.tech@gmail.com fanjiaeminem@qq.com
ClientExecuteCommand.java
in seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command
 253 6 2022-09-15 2025-01-09 40 16 fanjiaeminem@qq.com fanjiaeminem@qq.com
Common.java
in seatunnel-common/src/main/java/org/apache/seatunnel/common/config
 131 15 2021-12-24 2024-11-30 28 16 zhongjiajie955@hotmail.com 39961809+hawk9821@users.nor...
HttpSourceReader.java
in seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source
 404 15 2022-08-08 2025-04-30 24 16 tyrantlucifer@gmail.com nijiahui_yewu@cmss.chinamob...
PhysicalPlanGenerator.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical
 528 9 2022-08-03 2025-04-27 42 15 fanjiaeminem@qq.com wanghailin@apache.org
AbstractJdbcCatalog.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog
 621 58 2022-06-28 2025-03-24 38 15 gaojun2048@gmail.com 2795267041@qq.com
HiveSink.java
in seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink
 202 10 2022-06-28 2025-04-08 33 15 gaojun2048@gmail.com 280154548@qq.com
JdbcSinkFactory.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink
 250 4 2022-11-19 2025-04-02 29 15 wenwei8268@gmail.com 73771213+corgy-w@users.nore...
JdbcSource.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source
 78 8 2022-06-28 2023-12-05 27 15 gaojun2048@gmail.com 83933160+ic4y@users.noreply...
SinkExecuteProcessor.java
in seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution
 158 4 2023-01-31 2025-02-13 26 15 tyrantlucifer@gmail.com jarvis@apache.org
DefaultSeaTunnelRowSerializer.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize
 279 18 2022-06-28 2025-03-03 25 15 gaojun2048@gmail.com nijiahui_yewu@cmss.chinamob...
S3FileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source
 86 4 2022-11-17 2025-04-08 25 15 tyrantlucifer@gmail.com 280154548@qq.com
EngineConfig.java
in seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config
 116 10 2022-08-05 2025-02-19 24 15 gaojun2048@gmail.com jarvis@apache.org
FtpFileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source
 82 4 2022-11-17 2025-04-08 24 15 tyrantlucifer@gmail.com 280154548@qq.com
LocalFileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source
 79 4 2022-11-17 2025-04-08 24 15 tyrantlucifer@gmail.com 280154548@qq.com
SinkExecuteProcessor.java
in seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution
 150 3 2023-01-31 2025-02-13 24 15 tyrantlucifer@gmail.com jarvis@apache.org
JsonDeserializationSchema.java
in seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json
 162 13 2022-06-15 2024-11-30 23 15 zongwen.li.tech@gmail.com 39961809+hawk9821@users.nor...
ClickhouseSink.java
in seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client
 166 6 2022-06-28 2025-02-20 23 15 gaojun2048@gmail.com 33561138+lyne7-sc@users.nor...
StarRocksSinkFactory.java
in seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink
 78 4 2022-11-14 2025-02-13 22 15 45089228+taozex@users.norep... jarvis@apache.org
29 - 2022-12-19 2025-04-28 20 15 kirs@apache.org 146407911+mrtisttt@users.no...
KafkaSourceReader.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source
 137 6 2022-06-28 2024-09-05 20 15 gaojun2048@gmail.com 1058249259@qq.com
HttpConfig.java
in seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config
 20 2 2022-08-08 2025-03-18 19 15 tyrantlucifer@gmail.com jarvis@apache.org
SeaTunnelServer.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 277 23 2022-07-27 2025-03-28 54 14 gaojun2048@gmail.com shenghang@apache.org
SinkFlowLifeCycle.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow
 295 10 2022-08-15 2025-01-15 37 14 fanjiaeminem@qq.com 77472193+cheun99@users.nore...
AbstractReadStrategy.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader
 334 14 2022-08-15 2025-04-08 37 14 tyrantlucifer@gmail.com 280154548@qq.com
EsRestClient.java
in seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client
 902 27 2022-09-23 2025-04-16 25 14 fanjiaeminem@qq.com nijiahui_yewu@cmss.chinamob...
MysqlDialect.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql
 212 17 2022-06-28 2024-12-19 24 14 gaojun2048@gmail.com 39961809+hawk9821@users.nor...
OssFileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source
 82 4 2022-11-17 2025-04-08 24 14 tyrantlucifer@gmail.com 280154548@qq.com
S3FileSinkFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink
 109 3 2022-11-17 2025-04-08 23 14 tyrantlucifer@gmail.com 280154548@qq.com
SftpFileSourceFactory.java
in seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/source
 79 4 2022-11-17 2025-04-08 23 14 tyrantlucifer@gmail.com 280154548@qq.com
KafkaSourceSplitEnumerator.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source
 372 21 2022-06-28 2025-04-26 22 14 gaojun2048@gmail.com wanghailin@apache.org
ClickhouseFileSinkWriter.java
in seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file
 401 11 2022-06-28 2025-01-06 21 14 gaojun2048@gmail.com 77189278+caicancai@users.no...
ClickhouseSinkWriter.java
in seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client
 191 9 2022-06-28 2024-11-30 21 14 gaojun2048@gmail.com 39961809+hawk9821@users.nor...
KafkaSourceConfig.java
in seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source
 336 8 2023-10-21 2025-04-22 18 14 wenjun@apache.org 73771213+corgy-w@users.nore...
JdbcOptions.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config
 193 - 2023-02-27 2025-04-02 17 14 zongwen@apache.org 73771213+corgy-w@users.nore...
IoTDBSource.java
in seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source
 54 7 2022-08-19 2025-03-17 17 14 kirs@apache.org jarvis@apache.org
ConfigBuilder.java
in seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils
 268 16 2023-01-10 2025-02-20 16 14 tyrantlucifer@gmail.com remones11@gmail.com
FileSinkConfig.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config
 178 1 2022-12-17 2025-04-08 15 14 tyrantlucifer@gmail.com 280154548@qq.com
TaskExecutionService.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server
 901 35 2022-08-01 2025-03-20 68 13 83933160+ic4y@users.noreply... fanjiaeminem@qq.com
JdbcSink.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink
 268 10 2022-06-28 2024-12-05 34 13 gaojun2048@gmail.com fanjiaeminem@qq.com
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
Remote.java
in seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto
 4746 329 2024-10-29 2024-10-29 1 1 40288034+cosmosni@users.nor... 40288034+cosmosni@users.nor...
MembershipManager.java
in seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl
 1395 69 2024-07-08 2024-07-08 1 1 gaojun2048@gmail.com gaojun2048@gmail.com
MySqlStreamingChangeEventSource.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/io/debezium/connector/mysql
 1193 43 2025-02-07 2025-02-07 1 1 1633138551@qq.com 1633138551@qq.com
ClusterServiceImpl.java
in seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl
 1034 89 2024-07-08 2024-07-08 1 1 gaojun2048@gmail.com gaojun2048@gmail.com
GoGoProtos.java
in seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto
 743 4 2024-10-29 2024-10-29 1 1 40288034+cosmosni@users.nor... 40288034+cosmosni@users.nor...
PostgresReplicationConnection.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-opengauss/src/main/java/io/debezium/connector/postgresql/connection
 734 33 2024-08-27 2024-08-27 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
Tokenizer.java
in seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl
 614 39 2025-03-15 2025-04-25 2 1 fanjiaeminem@qq.com fanjiaeminem@qq.com
SqlServerConnection.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver
 609 34 2024-09-29 2024-11-19 2 1 fanjiaeminem@qq.com fanjiaeminem@qq.com
PostgresConnection.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-opengauss/src/main/java/io/debezium/connector/postgresql/connection
 582 28 2024-08-27 2024-08-27 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
StarRocksTypeConverter.java
in seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/datatypes
 577 13 2024-12-04 2024-12-04 1 1 1633138551@qq.com 1633138551@qq.com
LiteNodeDropOutTcpIpJoiner.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/joiner
 480 21 2024-12-13 2024-12-13 1 1 jarvis@apache.org jarvis@apache.org
SapHanaTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/saphana
 440 5 2024-07-09 2024-10-30 4 1 fanjiaeminem@qq.com fanjiaeminem@qq.com
OceanBaseMysqlType.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase
 436 5 2024-08-09 2024-08-09 1 1 93303124+xxsc0529@users.nor... 93303124+xxsc0529@users.nor...
SqlServerUtils.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/utils
 435 22 2024-09-23 2024-09-23 1 1 73771213+corgy-w@users.nore... 73771213+corgy-w@users.nore...
IrisTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/iris
 390 3 2024-05-08 2024-05-08 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
DB2TypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2
 382 3 2024-04-07 2024-04-07 1 1 wanghailin@apache.org wanghailin@apache.org
ConfigImpl.java
in seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl
 377 39 2024-10-25 2024-10-25 1 1 wanghailin@apache.org wanghailin@apache.org
RedshiftTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/redshift
 366 3 2024-04-07 2024-04-07 1 1 wanghailin@apache.org wanghailin@apache.org
LogMinerAdapter.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer
 363 18 2024-05-23 2024-05-23 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
NodeMetricExports.java
in seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/telemetry/metrics/exports
 351 4 2024-09-09 2024-09-09 1 1 73771213+corgy-w@users.nore... 73771213+corgy-w@users.nore...
SchemaChangeManager.java
in seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/schema
 348 19 2024-12-19 2024-12-19 1 1 jeffer_deng@foxmail.com jeffer_deng@foxmail.com
XuguTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/xugu
 346 3 2024-04-02 2024-04-02 1 1 42635285+l-gryps@users.nore... 42635285+l-gryps@users.nore...
PhoenixTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix
 335 3 2024-04-07 2024-04-07 1 1 wanghailin@apache.org wanghailin@apache.org
index.tsx
in seatunnel-engine/seatunnel-engine-ui/src/components/directed-acyclic-graph
 329 4 2024-10-25 2024-10-25 1 1 chenqjun0520@163.com chenqjun0520@163.com
SnowflakeTypeConverter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/snowflake
 310 3 2024-04-07 2024-04-07 1 1 wanghailin@apache.org wanghailin@apache.org
FileBaseSinkOptions.java
in seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config
 282 - 2025-03-20 2025-04-08 2 1 280154548@qq.com 280154548@qq.com
SlsSourceSplitEnumerator.java
in seatunnel-connectors-v2/connector-sls/src/main/java/org/apache/seatunnel/connectors/seatunnel/sls/source
 276 18 2024-08-13 2024-08-13 1 1 743344516@qq.com 743344516@qq.com
DefaultDataConverter.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/converter
 276 15 2024-09-11 2024-09-11 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
CustomColumnDefinitionParserListener.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/parser
 259 15 2024-07-05 2024-07-05 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
FakeSourceOptions.java
in seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config
 250 1 2025-03-11 2025-03-11 1 1 jarvis@apache.org jarvis@apache.org
EventProcessorFactory.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/l...
 235 10 2024-05-23 2024-05-23 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
RowDataToAvroConverters.java
in seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/sink/convert
 234 4 2024-09-19 2024-10-18 2 1 137260654+happyboy1024@user... 137260654+happyboy1024@user...
CsvSerializationSchema.java
in seatunnel-formats/seatunnel-format-csv/src/main/java/org/apache/seatunnel/format/csv
 225 15 2025-01-22 2025-02-06 2 1 73771213+corgy-w@users.nore... 73771213+corgy-w@users.nore...
SqlServerSnapshotSplitReadTask.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/reader/f...
 225 9 2024-09-23 2024-09-23 1 1 73771213+corgy-w@users.nore... 73771213+corgy-w@users.nore...
CustomColumnDefinitionParserListener.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/parser
 221 10 2024-11-07 2024-11-07 1 1 837833280@qq.com 837833280@qq.com
AerospikeSinkWriter.java
in seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink
 217 8 2025-03-25 2025-03-25 1 1 53292491+zax1314157@users.n... 53292491+zax1314157@users.n...
RocketMqBaseConfiguration.java
in seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/common
 202 19 2023-04-14 2023-04-14 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MDCStream.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing
 201 40 2024-12-05 2025-01-07 2 1 wanghailin@apache.org wanghailin@apache.org
HudiRecordWriter.java
in seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/sink/writer
 198 10 2024-09-19 2024-10-18 2 1 137260654+happyboy1024@user... 137260654+happyboy1024@user...
ChangeEventQueue.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/io/debezium/connector/base
 198 19 2024-05-23 2024-05-23 1 1 dailai@chinatelecom.cn dailai@chinatelecom.cn
TiDBSourceReader.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader
 193 13 2024-09-11 2024-09-11 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
MemberMap.java
in seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl
 192 22 2024-07-08 2024-07-08 1 1 gaojun2048@gmail.com gaojun2048@gmail.com
ConnectTableChangeSerializer.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium
 187 7 2024-11-14 2024-11-14 1 1 wanghailin@apache.org wanghailin@apache.org
TablePlaceholderProcessor.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/sink
 168 7 2024-09-10 2024-09-10 1 1 admin@hadoop.wiki admin@hadoop.wiki
PrometheusWriter.java
in seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink
 168 7 2024-10-29 2024-10-29 1 1 40288034+cosmosni@users.nor... 40288034+cosmosni@users.nor...
CopyManagerBatchStatementExecutor.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor
 167 7 2024-03-11 2024-03-11 1 1 jmhjmhok@163.com jmhjmhok@163.com
AlterTableEventHandler.java
in seatunnel-api/src/main/java/org/apache/seatunnel/api/table/schema/handler
 165 9 2024-11-14 2024-11-14 1 1 wanghailin@apache.org wanghailin@apache.org
MultiTableManager.java
in seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/execution
 164 8 2024-08-14 2024-12-23 2 1 1058249259@qq.com 1058249259@qq.com
CollationBasedSplitter.java
in seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source
 162 8 2025-03-26 2025-03-26 1 1 2795267041@qq.com 2795267041@qq.com
TiDBSourceSplitEnumerator.java
in seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/enumerator
 160 16 2024-09-11 2024-09-11 1 1 sunxiaojian926@163.com sunxiaojian926@163.com
Correlations

File Size vs. Number of Changes: 3074 points

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java x: 141 lines of code y: 8 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseUtil.java x: 58 lines of code y: 11 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/config/GraphQLSinkParameter.java x: 49 lines of code y: 2 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/config/GraphQLSourceParameter.java x: 64 lines of code y: 2 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/sink/GraphQLSinkWriter.java x: 74 lines of code y: 2 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/reader/GraphQLWebSocket.java x: 111 lines of code y: 2 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java x: 319 lines of code y: 12 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java x: 56 lines of code y: 14 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpSourceOptions.java x: 114 lines of code y: 3 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/PageInfo.java x: 19 lines of code y: 3 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java x: 170 lines of code y: 29 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java x: 404 lines of code y: 24 # changes seatunnel-connectors-v2/connector-http/connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source/MyHoursSource.java x: 78 lines of code y: 11 # changes seatunnel-connectors-v2/connector-http/connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source/config/MyHoursSourceParameter.java x: 36 lines of code y: 8 # changes seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/split/SamplingSplitStrategy.java x: 202 lines of code y: 5 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java x: 295 lines of code y: 15 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksSinkManager.java x: 122 lines of code y: 12 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jBaseOptions.java x: 49 lines of code y: 1 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jQueryInfo.java x: 97 lines of code y: 5 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSinkOptions.java x: 24 lines of code y: 1 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSinkQueryInfo.java x: 67 lines of code y: 3 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSourceOptions.java x: 2 lines of code y: 1 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSink.java x: 30 lines of code y: 11 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkFactory.java x: 39 lines of code y: 4 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkWriter.java x: 121 lines of code y: 9 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSource.java x: 41 lines of code y: 13 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSourceFactory.java x: 53 lines of code y: 9 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/ResourceUtils.java x: 74 lines of code y: 6 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java x: 586 lines of code y: 52 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/config/QdrantBaseOptions.java x: 26 lines of code y: 1 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/config/QdrantParameters.java x: 24 lines of code y: 2 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/sink/QdrantSink.java x: 32 lines of code y: 3 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/source/QdrantSource.java x: 38 lines of code y: 2 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/source/QdrantSourceFactory.java x: 38 lines of code y: 3 # changes config/seatunnel.yaml x: 29 lines of code y: 20 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergRecordWriter.java x: 153 lines of code y: 7 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java x: 913 lines of code y: 61 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java x: 491 lines of code y: 43 # changes seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSinkFactory.java x: 34 lines of code y: 6 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java x: 325 lines of code y: 30 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java x: 182 lines of code y: 12 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java x: 528 lines of code y: 42 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java x: 372 lines of code y: 42 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/table/TableFilterConfig.java x: 101 lines of code y: 1 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/table/TableFilterMultiCatalogTransform.java x: 66 lines of code y: 1 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java x: 372 lines of code y: 22 # changes seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/config/OpenMldbParameters.java x: 46 lines of code y: 4 # changes seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSource.java x: 120 lines of code y: 6 # changes seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSourceFactory.java x: 50 lines of code y: 6 # changes seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/Tokenizer.java x: 614 lines of code y: 2 # changes seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/config/TDengineSinkOptions.java x: 14 lines of code y: 1 # changes seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkFactory.java x: 36 lines of code y: 1 # changes seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java x: 124 lines of code y: 10 # changes seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSink.java x: 45 lines of code y: 7 # changes seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubWriter.java x: 98 lines of code y: 4 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceConfig.java x: 336 lines of code y: 18 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonSerializationSchema.java x: 49 lines of code y: 13 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Column.java x: 111 lines of code y: 17 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/PhysicalColumn.java x: 323 lines of code y: 11 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/DorisCatalogUtil.java x: 227 lines of code y: 17 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergTypeMapper.java x: 153 lines of code y: 11 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/utils/SchemaUtils.java x: 287 lines of code y: 11 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCreateTableSqlBuilder.java x: 174 lines of code y: 2 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/iris/IrisCreateTableSqlBuilder.java x: 139 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java x: 224 lines of code y: 19 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseMysqlCreateTableSqlBuilder.java x: 231 lines of code y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCreateTableSqlBuilder.java x: 109 lines of code y: 9 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/psql/PostgresCreateTableSqlBuilder.java x: 169 lines of code y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/redshift/RedshiftCreateTableSqlBuilder.java x: 105 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java x: 216 lines of code y: 12 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/sink/MilvusSinkConverter.java x: 262 lines of code y: 4 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/SchemaUtil.java x: 80 lines of code y: 8 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java x: 83 lines of code y: 20 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/exception/TransformCommonError.java x: 43 lines of code y: 3 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/exception/TransformCommonErrorCode.java x: 33 lines of code y: 4 # changes seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-hdfs/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/HdfsStorage.java x: 322 lines of code y: 18 # changes seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-hdfs/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/common/FileConfiguration.java x: 20 lines of code y: 6 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java x: 846 lines of code y: 14 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLType.java x: 499 lines of code y: 17 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/SystemFunction.java x: 180 lines of code y: 8 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/config/IcebergSourceConfig.java x: 55 lines of code y: 2 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanContext.java x: 80 lines of code y: 7 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/utils/ExpressionUtils.java x: 267 lines of code y: 2 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ParquetReadStrategy.java x: 390 lines of code y: 19 # changes seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceState.java x: 15 lines of code y: 2 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKAggCommitInfo.java x: 5 lines of code y: 5 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKFileAggCommitInfo.java x: 13 lines of code y: 4 # changes seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplit.java x: 16 lines of code y: 3 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/state/EasysearchAggregatedCommitInfo.java x: 5 lines of code y: 2 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchAggregatedCommitInfo.java x: 5 lines of code y: 6 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileAggregatedCommitInfo.java x: 13 lines of code y: 6 # changes seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/source/HbaseSourceSplit.java x: 31 lines of code y: 2 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/sink/state/HudiAggregatedCommitInfo.java x: 5 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceSplit.java x: 24 lines of code y: 5 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/state/JdbcSourceState.java x: 15 lines of code y: 5 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplit.java x: 73 lines of code y: 9 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/state/KuduSourceState.java x: 15 lines of code y: 7 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSourceSplit.java x: 26 lines of code y: 5 # changes seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/split/PulsarPartitionSplit.java x: 57 lines of code y: 5 # changes seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/split/RabbitmqSplitEnumeratorState.java x: 5 lines of code y: 4 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/YamlSeaTunnelDomConfigProcessor.java x: 517 lines of code y: 30 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/HttpConfig.java x: 38 lines of code y: 5 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java x: 301 lines of code y: 32 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/JettyService.java x: 213 lines of code y: 8 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/filter/BasicAuthFilter.java x: 59 lines of code y: 1 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkAggregatedCommitter.java x: 16 lines of code y: 13 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSinkAggregatedCommitter.java x: 156 lines of code y: 2 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkAggCommitter.java x: 109 lines of code y: 8 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileSinkAggregatedCommitter.java x: 100 lines of code y: 12 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkAggregatedCommitter.java x: 88 lines of code y: 11 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java x: 902 lines of code y: 25 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/ElasticsearchSourceOptions.java x: 79 lines of code y: 3 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/ElasticsearchConnectorErrorCode.java x: 39 lines of code y: 12 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSource.java x: 221 lines of code y: 18 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceFactory.java x: 69 lines of code y: 13 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceReader.java x: 187 lines of code y: 10 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java x: 144 lines of code y: 13 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/reader/GraphQLSourceHttpReader.java x: 108 lines of code y: 1 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java x: 141 lines of code y: 1 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeCatalog.java x: 291 lines of code y: 8 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeDataTypeConvertor.java x: 152 lines of code y: 6 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/datatype/MaxComputeTypeConverter.java x: 492 lines of code y: 2 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/sink/MaxcomputeSink.java x: 77 lines of code y: 11 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/sink/MaxcomputeWriter.java x: 74 lines of code y: 10 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSource.java x: 161 lines of code y: 10 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSourceFactory.java x: 45 lines of code y: 8 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSourceSplitEnumerator.java x: 129 lines of code y: 6 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/util/MaxcomputeUtil.java x: 94 lines of code y: 7 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/CsvWriteStrategy.java x: 150 lines of code y: 3 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/CsvReadStrategy.java x: 252 lines of code y: 6 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/catalog/KuduCatalog.java x: 192 lines of code y: 3 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSinkConfig.java x: 49 lines of code y: 9 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSourceConfig.java x: 18 lines of code y: 9 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/sink/KuduSinkFactory.java x: 68 lines of code y: 9 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceFactory.java x: 53 lines of code y: 10 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalogFactory.java x: 43 lines of code y: 5 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/config/PaimonConfig.java x: 69 lines of code y: 7 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/source/PaimonSource.java x: 119 lines of code y: 6 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/RowConverter.java x: 471 lines of code y: 12 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/RowTypeConverter.java x: 483 lines of code y: 10 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/catalog/MilvusCatalog.java x: 341 lines of code y: 6 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/config/MilvusSinkOptions.java x: 72 lines of code y: 1 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusBufferBatchWriter.java x: 296 lines of code y: 3 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSink.java x: 88 lines of code y: 5 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java x: 261 lines of code y: 7 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceSplitEnumerator.java x: 210 lines of code y: 2 # changes seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/MilvusConvertUtils.java x: 226 lines of code y: 3 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java x: 344 lines of code y: 43 # changes seatunnel-engine/seatunnel-engine-ui/src/views/jobs/detail.tsx x: 246 lines of code y: 2 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresIncrementalSource.java x: 120 lines of code y: 5 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/DefaultSaveModeHandler.java x: 214 lines of code y: 9 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java x: 719 lines of code y: 56 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java x: 916 lines of code y: 87 # changes seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/BaseHdfsFileSink.java x: 48 lines of code y: 12 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java x: 103 lines of code y: 15 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSourceConfig.java x: 117 lines of code y: 9 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileBaseOptions.java x: 131 lines of code y: 2 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileBaseSinkOptions.java x: 282 lines of code y: 2 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSink.java x: 98 lines of code y: 17 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSinkWriter.java x: 150 lines of code y: 20 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseMultipleTableFileSink.java x: 114 lines of code y: 8 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java x: 178 lines of code y: 15 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java x: 337 lines of code y: 33 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java x: 334 lines of code y: 37 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/BinaryReadStrategy.java x: 64 lines of code y: 5 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java x: 237 lines of code y: 18 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/JsonReadStrategy.java x: 120 lines of code y: 17 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java x: 780 lines of code y: 20 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategyFactory.java x: 31 lines of code y: 10 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java x: 218 lines of code y: 29 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/XmlReadStrategy.java x: 254 lines of code y: 7 # changes seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/source/CosFileSource.java x: 106 lines of code y: 12 # changes seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/source/CosFileSourceFactory.java x: 77 lines of code y: 14 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/config/FtpConf.java x: 40 lines of code y: 11 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSinkFactory.java x: 110 lines of code y: 20 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSourceFactory.java x: 82 lines of code y: 24 # changes seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSinkFactory.java x: 92 lines of code y: 17 # changes seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSourceFactory.java x: 74 lines of code y: 22 # changes seatunnel-connectors-v2/connector-file/connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo/sink/OssFileSinkFactory.java x: 91 lines of code y: 8 # changes seatunnel-connectors-v2/connector-file/connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo/source/OssFileSource.java x: 107 lines of code y: 6 # changes seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/sink/LocalFileSinkFactory.java x: 104 lines of code y: 23 # changes seatunnel-connectors-v2/connector-file/connector-file-obs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/obs/sink/ObsFileSinkFactory.java x: 74 lines of code y: 5 # changes seatunnel-connectors-v2/connector-file/connector-file-obs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/obs/source/ObsFileSource.java x: 105 lines of code y: 5 # changes seatunnel-connectors-v2/connector-file/connector-file-obs/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/obs/source/ObsFileSourceFactory.java x: 61 lines of code y: 6 # changes seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/sink/OssFileSinkFactory.java x: 103 lines of code y: 22 # changes seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/config/S3HadoopConf.java x: 70 lines of code y: 4 # changes seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSourceFactory.java x: 86 lines of code y: 25 # changes seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/source/SftpFileSourceFactory.java x: 79 lines of code y: 23 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java x: 202 lines of code y: 33 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSourceFactory.java x: 45 lines of code y: 10 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java x: 269 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java x: 320 lines of code y: 16 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DateUtils.java x: 174 lines of code y: 9 # changes seatunnel-engine/seatunnel-engine-ui/src/views/jobs/finished-jobs.tsx x: 84 lines of code y: 2 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/serialize/StarRocksBaseSerializer.java x: 55 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseMySqlCatalog.java x: 215 lines of code y: 10 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMySqlTypeConverter.java x: 492 lines of code y: 5 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java x: 201 lines of code y: 10 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java x: 193 lines of code y: 17 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java x: 108 lines of code y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2DialectFactory.java x: 20 lines of code y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/hive/HiveJdbcConnectionProvider.java x: 72 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlDialectFactory.java x: 29 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java x: 250 lines of code y: 29 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java x: 302 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java x: 364 lines of code y: 17 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java x: 145 lines of code y: 24 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFilter.java x: 368 lines of code y: 7 # changes seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml x: 30 lines of code y: 12 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java x: 277 lines of code y: 54 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java x: 94 lines of code y: 37 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/MultipleTableFileSourceSplitEnumerator.java x: 122 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java x: 48 lines of code y: 14 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceConfig.java x: 59 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java x: 81 lines of code y: 5 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java x: 604 lines of code y: 33 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/db2/DB2Dialect.java x: 67 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java x: 432 lines of code y: 22 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/vertica/VerticaDialect.java x: 94 lines of code y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/CollationBasedSplitter.java x: 162 lines of code y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java x: 640 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/FixedChunkSplitter.java x: 369 lines of code y: 6 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java x: 883 lines of code y: 57 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java x: 273 lines of code y: 36 # changes seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/config/AerospikeSinkOptions.java x: 78 lines of code y: 1 # changes seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSinkWriter.java x: 217 lines of code y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java x: 621 lines of code y: 38 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/utils/CatalogUtils.java x: 297 lines of code y: 11 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/catalog/PaimonCatalog.java x: 301 lines of code y: 11 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/schema/handler/AlterPaimonTableSchemaEventHandler.java x: 148 lines of code y: 2 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/JdbcCatalogOptions.java x: 61 lines of code y: 11 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/iris/IrisCatalog.java x: 233 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MySqlCatalog.java x: 181 lines of code y: 20 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MySqlCatalogFactory.java x: 37 lines of code y: 6 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseCatalogFactory.java x: 59 lines of code y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java x: 194 lines of code y: 18 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/psql/PostgresCatalog.java x: 196 lines of code y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/saphana/SapHanaCatalog.java x: 296 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java x: 139 lines of code y: 15 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/xugu/XuguCatalog.java x: 214 lines of code y: 5 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java x: 901 lines of code y: 68 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/util/MaxcomputeTypeMapper.java x: 276 lines of code y: 11 # changes seatunnel-formats/seatunnel-format-csv/src/main/java/org/apache/seatunnel/format/csv/CsvDeserializationSchema.java x: 328 lines of code y: 2 # changes seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/config/InfluxDBConfig.java x: 30 lines of code y: 8 # changes seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSource.java x: 100 lines of code y: 15 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpConfig.java x: 20 lines of code y: 19 # changes seatunnel-connectors-v2/connector-http/connector-http-gitlab/src/main/java/org/apache/seatunnel/connectors/seatunnel/gitlab/source/GitlabSource.java x: 41 lines of code y: 7 # changes seatunnel-connectors-v2/connector-http/connector-http-wechat/src/main/java/org/apache/seatunnel/connectors/seatunnel/wechat/sink/WeChatSink.java x: 29 lines of code y: 9 # changes seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/PrometheusSink.java x: 54 lines of code y: 3 # changes seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/source/PrometheusSourceReader.java x: 190 lines of code y: 4 # changes seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSource.java x: 54 lines of code y: 17 # changes seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceReader.java x: 138 lines of code y: 9 # changes seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceSplitEnumerator.java x: 197 lines of code y: 10 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlServerDialect.java x: 459 lines of code y: 16 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java x: 138 lines of code y: 5 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergTableLoader.java x: 73 lines of code y: 8 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/RowConverter.java x: 425 lines of code y: 4 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSinkWriter.java x: 137 lines of code y: 9 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergWriterFactory.java x: 159 lines of code y: 6 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java x: 128 lines of code y: 18 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergSourceReader.java x: 146 lines of code y: 10 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/source/converter/SqlToPaimonPredicateConverter.java x: 292 lines of code y: 5 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java x: 532 lines of code y: 9 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/catalog/EasysearchCatalog.java x: 180 lines of code y: 5 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/client/EasysearchClient.java x: 484 lines of code y: 2 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/sink/EasysearchSinkWriter.java x: 99 lines of code y: 2 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceFactory.java x: 129 lines of code y: 3 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceReader.java x: 94 lines of code y: 2 # changes seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceSplitEnumerator.java x: 161 lines of code y: 3 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchTypeConverter.java x: 345 lines of code y: 6 # changes seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSource.java x: 268 lines of code y: 5 # changes seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceReader.java x: 222 lines of code y: 7 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbStreamFetchTask.java x: 333 lines of code y: 3 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/utils/MongodbRecordUtils.java x: 172 lines of code y: 4 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/utils/MongodbUtils.java x: 361 lines of code y: 3 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/catalog/HudiCatalog.java x: 289 lines of code y: 4 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/config/HudiSinkOptions.java x: 120 lines of code y: 1 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/config/HudiTableConfig.java x: 172 lines of code y: 3 # changes seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/config/RedisParameters.java x: 160 lines of code y: 18 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/TimeUtils.java x: 65 lines of code y: 7 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java x: 392 lines of code y: 16 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeSourceOptions.java x: 250 lines of code y: 1 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java x: 96 lines of code y: 16 # changes seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/config/HbaseParameters.java x: 86 lines of code y: 9 # changes seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/sink/HbaseSink.java x: 86 lines of code y: 10 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/scan/MySqlSnapshotFetchTask.java x: 155 lines of code y: 13 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java x: 736 lines of code y: 4 # changes seatunnel-connectors-v2/connector-google-sheets/src/main/java/org/apache/seatunnel/connectors/seatunnel/google/sheets/source/SheetsSource.java x: 43 lines of code y: 11 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSource.java x: 40 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskLocation.java x: 103 lines of code y: 11 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/MySqlSourceFetchTaskContext.java x: 364 lines of code y: 16 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java x: 235 lines of code y: 5 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/reader/PostgresSourceFetchTaskContext.java x: 305 lines of code y: 6 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/reader/fetch/SqlServerSourceFetchTaskContext.java x: 250 lines of code y: 2 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/exception/CommonError.java x: 259 lines of code y: 15 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/StarRocksBeReadClient.java x: 168 lines of code y: 6 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/source/model/QueryPartition.java x: 95 lines of code y: 3 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSink.java x: 82 lines of code y: 21 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java x: 109 lines of code y: 14 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StarRocksSourceReader.java x: 115 lines of code y: 4 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/source/StartRocksSourceSplitEnumerator.java x: 153 lines of code y: 4 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/config/MessageFormat.java x: 14 lines of code y: 8 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize/DefaultSeaTunnelRowSerializer.java x: 279 lines of code y: 25 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkWriter.java x: 259 lines of code y: 25 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDag.java x: 117 lines of code y: 11 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/dag/logical/LogicalDagGenerator.java x: 79 lines of code y: 10 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/DAGUtils.java x: 197 lines of code y: 11 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestJobExecutionEnvironment.java x: 96 lines of code y: 7 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/service/BaseService.java x: 501 lines of code y: 5 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/catalog/DorisCatalog.java x: 456 lines of code y: 10 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/config/DorisSinkOptions.java x: 110 lines of code y: 4 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/AbstractDorisTypeConverter.java x: 395 lines of code y: 3 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/DorisTypeConverterV2.java x: 232 lines of code y: 3 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/DorisSinkFactory.java x: 103 lines of code y: 10 # changes seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java x: 411 lines of code y: 34 # changes seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceSplitEnumerator.java x: 129 lines of code y: 4 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceSplitEnumerator.java x: 156 lines of code y: 11 # changes seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/source/TypesenseSourceSplitEnumerator.java x: 138 lines of code y: 2 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/nlpmodel/embedding/EmbeddingTransform.java x: 192 lines of code y: 2 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/nlpmodel/embedding/remote/custom/CustomModel.java x: 115 lines of code y: 2 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSinkOptions.java x: 125 lines of code y: 16 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java x: 166 lines of code y: 23 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkFactory.java x: 58 lines of code y: 6 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSink.java x: 48 lines of code y: 22 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java x: 354 lines of code y: 6 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/config/TypesafeConfigUtils.java x: 63 lines of code y: 16 # changes seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigBuilder.java x: 268 lines of code y: 16 # changes seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigShadeUtils.java x: 188 lines of code y: 6 # changes seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/source/RabbitmqSourceFactory.java x: 63 lines of code y: 10 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java x: 116 lines of code y: 24 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/CheckpointConfig.java x: 36 lines of code y: 9 # changes seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/arrow/reader/ArrowToSeatunnelRowReader.java x: 263 lines of code y: 2 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/nlpmodel/llm/remote/custom/CustomModel.java x: 125 lines of code y: 4 # changes seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSink.java x: 46 lines of code y: 15 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/fieldmapper/FieldMapperTransform.java x: 152 lines of code y: 9 # changes seatunnel-connectors-v2/connector-slack/src/main/java/org/apache/seatunnel/connectors/seatunnel/slack/client/SlackClient.java x: 65 lines of code y: 4 # changes seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqSink.java x: 136 lines of code y: 5 # changes seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java x: 306 lines of code y: 20 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/schema/handler/AlterTableSchemaEventHandler.java x: 167 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbDialect.java x: 315 lines of code y: 14 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSink.java x: 170 lines of code y: 8 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Catalog.java x: 144 lines of code y: 16 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java x: 213 lines of code y: 30 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/schema/ReadonlyConfigParser.java x: 215 lines of code y: 8 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java x: 397 lines of code y: 39 # changes seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/config/AmazonDynamoDBSourceOptions.java x: 15 lines of code y: 11 # changes seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/rule/AssertCatalogTableRuleParser.java x: 149 lines of code y: 5 # changes seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/sink/AssertSink.java x: 113 lines of code y: 21 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java x: 171 lines of code y: 20 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSourceFactory.java x: 119 lines of code y: 27 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSourceFactory.java x: 119 lines of code y: 10 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/PostgresIncrementalSourceFactory.java x: 78 lines of code y: 4 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/source/SqlServerIncrementalSourceFactory.java x: 94 lines of code y: 3 # changes seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/BaseHdfsFileSource.java x: 117 lines of code y: 28 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkFactory.java x: 78 lines of code y: 22 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SinkExecuteProcessor.java x: 158 lines of code y: 26 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/FlinkExecution.java x: 194 lines of code y: 9 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SinkExecuteProcessor.java x: 164 lines of code y: 22 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SourceExecuteProcessor.java x: 108 lines of code y: 16 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/TransformExecuteProcessor.java x: 162 lines of code y: 16 # changes seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java x: 244 lines of code y: 10 # changes seatunnel-core/seatunnel-spark-starter/seatunnel-spark-2-starter/src/main/java/org/apache/seatunnel/core/starter/spark/execution/SinkExecuteProcessor.java x: 150 lines of code y: 24 # changes seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/SparkStarter.java x: 244 lines of code y: 7 # changes seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/execution/TransformExecuteProcessor.java x: 187 lines of code y: 15 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/ConfigParserUtil.java x: 240 lines of code y: 8 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/SQLTransform.java x: 146 lines of code y: 13 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-2.4/src/main/java/org/apache/seatunnel/translation/spark/source/SeaTunnelSourceSupport.java x: 113 lines of code y: 15 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-3.3/src/main/java/org/apache/seatunnel/translation/spark/source/partition/micro/SeaTunnelMicroBatch.java x: 115 lines of code y: 7 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/SinkConfig.java x: 74 lines of code y: 16 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/dto/IndexInfo.java x: 19 lines of code y: 10 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java x: 82 lines of code y: 19 # changes seatunnel-connectors-v2/connector-activemq/src/main/java/org/apache/seatunnel/connectors/seatunnel/activemq/config/ActivemqSinkOptions.java x: 93 lines of code y: 1 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/SeaTunnelDataTypeConvertorUtil.java x: 201 lines of code y: 8 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java x: 244 lines of code y: 9 # changes seatunnel-connectors-v2/connector-cassandra/src/main/java/org/apache/seatunnel/connectors/seatunnel/cassandra/sink/CassandraSink.java x: 82 lines of code y: 9 # changes seatunnel-connectors-v2/connector-cassandra/src/main/java/org/apache/seatunnel/connectors/seatunnel/cassandra/source/CassandraSource.java x: 98 lines of code y: 8 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 1193 lines of code y: 1 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSink.java x: 60 lines of code y: 17 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkFactory.java x: 33 lines of code y: 13 # changes seatunnel-formats/seatunnel-format-csv/src/main/java/org/apache/seatunnel/format/csv/CsvSerializationSchema.java x: 225 lines of code y: 2 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/AbstractResourceManager.java x: 264 lines of code y: 24 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/ResourceManager.java x: 29 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/ResourceRequestHandler.java x: 238 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/slot/DefaultSlotService.java x: 294 lines of code y: 18 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/utils/SystemLoadCalculate.java x: 148 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java x: 35 lines of code y: 31 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileFormat.java x: 124 lines of code y: 14 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/TextWriteStrategy.java x: 149 lines of code y: 23 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java x: 501 lines of code y: 8 # changes seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java x: 545 lines of code y: 8 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/ArrayType.java x: 66 lines of code y: 13 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java x: 335 lines of code y: 32 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java x: 245 lines of code y: 17 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java x: 413 lines of code y: 6 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/JsonWriteStrategy.java x: 118 lines of code y: 18 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/OrcWriteStrategy.java x: 356 lines of code y: 19 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java x: 394 lines of code y: 22 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/FileUtils.java x: 168 lines of code y: 16 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java x: 444 lines of code y: 18 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java x: 295 lines of code y: 37 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/split/FileSourceSplitEnumerator.java x: 105 lines of code y: 7 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/debezium/DebeziumJsonDeserializationSchema.java x: 133 lines of code y: 7 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestConstant.java x: 50 lines of code y: 18 # changes seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java x: 253 lines of code y: 40 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeConverter.java x: 435 lines of code y: 4 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/utils/concurrent/CompletableFuture.java x: 131 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServerStarter.java x: 86 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointManager.java x: 244 lines of code y: 46 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/PendingCheckpoint.java x: 147 lines of code y: 18 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/AbstractTask.java x: 93 lines of code y: 16 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java x: 277 lines of code y: 33 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSeaTunnelTask.java x: 113 lines of code y: 17 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/AbstractFlowLifeCycle.java x: 21 lines of code y: 8 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SourceFlowLifeCycle.java x: 342 lines of code y: 30 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/TransformFlowLifeCycle.java x: 162 lines of code y: 15 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ShardRouter.java x: 100 lines of code y: 11 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCStream.java x: 201 lines of code y: 2 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/converter/BasicDataConverter.java x: 1166 lines of code y: 3 # changes seatunnel-connectors-v2/connector-assert/src/main/java/org/apache/seatunnel/connectors/seatunnel/assertion/excecutor/AssertExecutor.java x: 317 lines of code y: 14 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeDataGenerator.java x: 305 lines of code y: 25 # changes seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/serialization/RowConverter.java x: 129 lines of code y: 12 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/utils/TypeConverterUtils.java x: 195 lines of code y: 5 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java x: 401 lines of code y: 21 # changes seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/typemapper/TDengineTypeMapper.java x: 120 lines of code y: 7 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/StringFunction.java x: 628 lines of code y: 4 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DateTimeUtils.java x: 266 lines of code y: 10 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLEngine.java x: 240 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java x: 285 lines of code y: 33 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpPostCommandProcessor.java x: 105 lines of code y: 19 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSink.java x: 127 lines of code y: 11 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java x: 250 lines of code y: 18 # changes seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/execution/MultiTableManager.java x: 164 lines of code y: 2 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlTypeUtils.java x: 112 lines of code y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MysqlDialect.java x: 212 lines of code y: 24 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMysqlDialect.java x: 215 lines of code y: 5 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/schema/SchemaChangeManager.java x: 348 lines of code y: 1 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java x: 232 lines of code y: 16 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java x: 423 lines of code y: 12 # changes seatunnel-connectors-v2/connector-typesense/src/main/java/org/apache/seatunnel/connectors/seatunnel/typesense/serialize/source/DefaultSeaTunnelRowDeserializer.java x: 217 lines of code y: 2 # changes tools/update_modules_check/update_modules_check.py x: 180 lines of code y: 23 # changes seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkWriter.java x: 201 lines of code y: 11 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/OracleIncrementalSource.java x: 129 lines of code y: 11 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/shard/Shard.java x: 80 lines of code y: 6 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeConverter.java x: 449 lines of code y: 2 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/joiner/LiteNodeDropOutTcpIpJoiner.java x: 480 lines of code y: 1 # changes seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java x: 246 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java x: 567 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/utils/JdbcColumnConverter.java x: 187 lines of code y: 4 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaInternalProducer.java x: 159 lines of code y: 7 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaTransactionSender.java x: 100 lines of code y: 9 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/rename/FieldRenameTransform.java x: 292 lines of code y: 1 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/rename/TableRenameTransform.java x: 226 lines of code y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java x: 281 lines of code y: 18 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/inceptor/InceptorJdbcRowConverter.java x: 122 lines of code y: 2 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/kingbase/KingbaseJdbcRowConverter.java x: 172 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresJdbcRowConverter.java x: 244 lines of code y: 15 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/InsertOrUpdateBatchStatementExecutor.java x: 129 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/SimpleBatchStatementExecutor.java x: 38 lines of code y: 10 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSink.java x: 268 lines of code y: 34 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/datatypes/StarRocksTypeConverter.java x: 577 lines of code y: 1 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java x: 131 lines of code y: 28 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/IncrementalSource.java x: 274 lines of code y: 23 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/IncrementalSourceReader.java x: 221 lines of code y: 15 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializeSchema.java x: 330 lines of code y: 19 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/parser/CustomMySqlAntlrDdlParser.java x: 270 lines of code y: 3 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSinkWriter.java x: 191 lines of code y: 21 # changes seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/reader/SourceReaderBase.java x: 183 lines of code y: 11 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/committer/DorisCommitter.java x: 144 lines of code y: 6 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisStreamLoad.java x: 277 lines of code y: 10 # changes seatunnel-connectors-v2/connector-druid/src/main/java/org/apache/seatunnel/connectors/druid/sink/DruidWriter.java x: 201 lines of code y: 3 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchCatalog.java x: 214 lines of code y: 15 # changes seatunnel-connectors-v2/connector-hbase/src/main/java/org/apache/seatunnel/connectors/seatunnel/hbase/source/HbaseSourceReader.java x: 142 lines of code y: 4 # changes seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/serialize/DefaultSeaTunnelRowSerializer.java x: 179 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/snowflake/SnowflakeDataTypeConvertor.java x: 163 lines of code y: 5 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/tidb/TiDBDataTypeConvertor.java x: 90 lines of code y: 6 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeConverter.java x: 494 lines of code y: 6 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaFacadeImplAutoLoad.java x: 407 lines of code y: 8 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/source/enumerator/AbstractSplitEnumerator.java x: 180 lines of code y: 3 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonDeserializationSchema.java x: 162 lines of code y: 23 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSinkWriter.java x: 324 lines of code y: 8 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/transform/SeaTunnelTransform.java x: 22 lines of code y: 15 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/Constants.java x: 27 lines of code y: 16 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/common/AbstractSeaTunnelTransform.java x: 71 lines of code y: 12 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java x: 151 lines of code y: 22 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/AbstractJdbcSourceChunkSplitter.java x: 426 lines of code y: 8 # changes seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/BsonToRowDataConverters.java x: 399 lines of code y: 6 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkWriter.java x: 32 lines of code y: 23 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/source/Collector.java x: 13 lines of code y: 9 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/TableSchema.java x: 96 lines of code y: 14 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/schema/handler/AlterTableEventHandler.java x: 165 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/IncrementalSplitAssigner.java x: 224 lines of code y: 10 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/ConnectTableChangeSerializer.java x: 187 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSource.java x: 133 lines of code y: 25 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/parser/CustomAlterTableParserListener.java x: 182 lines of code y: 2 # changes seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSinkWriter.java x: 113 lines of code y: 20 # changes seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/JobClient.java x: 138 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-core/src/main/resources/client-protocol-definition/SeaTunnelEngine.yaml x: 284 lines of code y: 16 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/ClientToServerOperationDataSerializerHook.java x: 83 lines of code y: 12 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelSourceCollector.java x: 159 lines of code y: 21 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/utils/SourceRecordUtils.java x: 167 lines of code y: 10 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/copy/CopyFieldTransform.java x: 162 lines of code y: 5 # changes seatunnel-dist/src/main/assembly/assembly-bin.xml x: 163 lines of code y: 35 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hadoop/HadoopFileSystemProxy.java x: 290 lines of code y: 9 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/saphana/SapHanaTypeConverter.java x: 440 lines of code y: 4 # changes seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto/GoGoProtos.java x: 743 lines of code y: 1 # changes seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto/Remote.java x: 4746 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-ui/src/components/directed-acyclic-graph/index.tsx x: 329 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-ui/src/layouts/main/sidebar/index.tsx x: 116 lines of code y: 1 # changes seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigImpl.java x: 377 lines of code y: 1 # changes seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/SimpleConfigObject.java x: 549 lines of code y: 4 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/sink/convert/RowDataToAvroConverters.java x: 234 lines of code y: 2 # changes seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/util/HudiUtil.java x: 180 lines of code y: 7 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategy.java x: 60 lines of code y: 14 # changes seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/source/SftpFileSource.java x: 14 lines of code y: 20 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceReader.java x: 100 lines of code y: 20 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SeaTunnelSink.java x: 50 lines of code y: 16 # changes seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSink.java x: 23 lines of code y: 7 # changes seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/sink/OssFileSink.java x: 22 lines of code y: 11 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/OptionRule.java x: 231 lines of code y: 12 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSource.java x: 14 lines of code y: 22 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/operation/CheckpointFinishedOperation.java x: 82 lines of code y: 14 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/sink/SinkPrepareCommitOperation.java x: 67 lines of code y: 12 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/AssignSplitOperation.java x: 85 lines of code y: 17 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/RequestSplitOperation.java x: 72 lines of code y: 18 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/RestoredSplitOperation.java x: 87 lines of code y: 15 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceNoMoreElementOperation.java x: 69 lines of code y: 17 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java x: 92 lines of code y: 21 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/sqlserver/utils/SqlServerUtils.java x: 435 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-api/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/api/AbstractCheckpointStorage.java x: 145 lines of code y: 12 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/converter/DefaultDataConverter.java x: 276 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/reader/TiDBSourceReader.java x: 193 lines of code y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java x: 346 lines of code y: 5 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelHealthMonitor.java x: 354 lines of code y: 5 # changes seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/args/ClientCommandArgs.java x: 122 lines of code y: 23 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaPartitionSplitReader.java x: 360 lines of code y: 2 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java x: 137 lines of code y: 20 # changes seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java x: 142 lines of code y: 31 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/Task.java x: 35 lines of code y: 15 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/Constant.java x: 25 lines of code y: 23 # changes seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/client/RabbitmqClient.java x: 167 lines of code y: 4 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceSplitEnumerator.java x: 116 lines of code y: 12 # changes seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/CoordinatedSource.java x: 273 lines of code y: 15 # changes seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelSource.java x: 177 lines of code y: 19 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-opengauss/src/main/java/io/debezium/connector/postgresql/connection/PostgresReplicationConnection.java x: 734 lines of code y: 1 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/ElasticsearchRowSerializer.java x: 164 lines of code y: 14 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlDialect.java x: 102 lines of code y: 13 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java x: 472 lines of code y: 5 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/RowToJsonConverters.java x: 259 lines of code y: 9 # changes seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextSerializationSchema.java x: 182 lines of code y: 13 # changes seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java x: 121 lines of code y: 19 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlServerTypeConverter.java x: 458 lines of code y: 4 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java x: 394 lines of code y: 18 # changes seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java x: 1034 lines of code y: 1 # changes seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java x: 1395 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/parser/CustomColumnDefinitionParserListener.java x: 259 lines of code y: 1 # changes seatunnel-engine/seatunnel-engine-common/src/main/resources/hazelcast.yaml x: 24 lines of code y: 14 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/utils/MySqlUtils.java x: 412 lines of code y: 16 # changes seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/RowDataToBsonConverters.java x: 275 lines of code y: 3 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java x: 520 lines of code y: 4 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/io/debezium/connector/base/ChangeEventQueue.java x: 198 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/binlog/MySqlBinlogFetchTask.java x: 166 lines of code y: 9 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/scan/MySqlSnapshotSplitReadTask.java x: 288 lines of code y: 14 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java x: 363 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/logminer/EventProcessorFactory.java x: 235 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/PostgresOffsetContext.java x: 296 lines of code y: 2 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java x: 349 lines of code y: 2 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/utils/PostgresUtils.java x: 458 lines of code y: 5 # changes seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/PulsarSource.java x: 339 lines of code y: 22 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/canal/CanalJsonDeserializationSchema.java x: 202 lines of code y: 9 # changes seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSource.java x: 14 lines of code y: 18 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/IncrementalSourceEnumerator.java x: 139 lines of code y: 10 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSourceReader.java x: 128 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/iris/IrisTypeConverter.java x: 390 lines of code y: 1 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/commit/HiveSinkAggregatedCommitter.java x: 79 lines of code y: 13 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSource.java x: 55 lines of code y: 21 # changes seatunnel-engine/seatunnel-engine-storage/imap-storage-plugins/imap-storage-file/src/main/java/org/apache/seatunnel/engine/imap/storage/file/IMapFileStorage.java x: 274 lines of code y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/phoenix/PhoenixTypeConverter.java x: 335 lines of code y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/snowflake/SnowflakeTypeConverter.java x: 310 lines of code y: 1 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/SnapshotSplitAssigner.java x: 237 lines of code y: 9 # changes seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelReaderContext.java x: 54 lines of code y: 13 # changes seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java x: 305 lines of code y: 5 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/ConfigUtil.java x: 186 lines of code y: 16 # changes seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSourceReader.java x: 211 lines of code y: 14 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/util/ConfigValidator.java x: 194 lines of code y: 8 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java x: 78 lines of code y: 27 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/source/KuduSourceSplitEnumerator.java x: 165 lines of code y: 7 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSource.java x: 68 lines of code y: 22 # changes seatunnel-connectors-v2/connector-cassandra/src/main/java/org/apache/seatunnel/connectors/seatunnel/cassandra/util/TypeConvertUtil.java x: 361 lines of code y: 5 # changes seatunnel-connectors-v2/connector-pulsar/src/main/java/org/apache/seatunnel/connectors/seatunnel/pulsar/source/enumerator/PulsarSplitEnumerator.java x: 233 lines of code y: 11 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/JdbcBatchStatementExecutorBuilder.java x: 215 lines of code y: 6 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/source/SeaTunnelSource.java x: 36 lines of code y: 18 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/TableSourceFactory.java x: 13 lines of code y: 16 # changes seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java x: 485 lines of code y: 5 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/TaskExecutionContext.java x: 51 lines of code y: 17 # changes seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/source/RabbitmqSourceReader.java x: 179 lines of code y: 5 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/connector/TableSource.java x: 7 lines of code y: 9 # changes seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-local-file/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/localfile/LocalFileStorage.java x: 340 lines of code y: 11 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkCommitter.java x: 8 lines of code y: 13 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/CatalogFactory.java x: 6 lines of code y: 7 # changes seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPConnectionPool.java x: 222 lines of code y: 3 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaGroupOpsImpl.java x: 135 lines of code y: 10 # changes seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/CompressionUtils.java x: 116 lines of code y: 5 # changes
87.0
# changes
  min: 1.0
  average: 5.06
  25th percentile: 1.0
  median: 3.0
  75th percentile: 6.0
  max: 87.0
0 4746.0
lines of code
min: 1.0 | average: 77.58 | 25th percentile: 17.0 | median: 38.0 | 75th percentile: 87.0 | max: 4746.0

Number of Contributors vs. Number of Changes: 3074 points

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java x: 6 # contributors y: 8 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseUtil.java x: 11 # contributors y: 11 # changes seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/config/GraphQLSinkParameter.java x: 2 # contributors y: 2 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java x: 11 # contributors y: 12 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java x: 11 # contributors y: 14 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpSourceOptions.java x: 3 # contributors y: 3 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java x: 19 # contributors y: 29 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java x: 16 # contributors y: 24 # changes seatunnel-connectors-v2/connector-http/connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source/MyHoursSource.java x: 9 # contributors y: 11 # changes seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/split/SamplingSplitStrategy.java x: 5 # contributors y: 5 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java x: 10 # contributors y: 15 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksSinkManager.java x: 10 # contributors y: 12 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jBaseOptions.java x: 1 # contributors y: 1 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkFactory.java x: 4 # contributors y: 4 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkWriter.java x: 8 # contributors y: 9 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSource.java x: 9 # contributors y: 13 # changes seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSourceFactory.java x: 5 # contributors y: 9 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/ResourceUtils.java x: 5 # contributors y: 6 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java x: 12 # contributors y: 52 # changes seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/sink/QdrantSinkFactory.java x: 2 # contributors y: 3 # changes config/seatunnel.yaml x: 15 # contributors y: 20 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergRecordWriter.java x: 5 # contributors y: 7 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java x: 16 # contributors y: 61 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java x: 10 # contributors y: 43 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/ExecutionPlanGenerator.java x: 11 # contributors y: 30 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java x: 7 # contributors y: 12 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java x: 15 # contributors y: 42 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java x: 11 # contributors y: 42 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java x: 14 # contributors y: 22 # changes seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSource.java x: 6 # contributors y: 6 # changes seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/Tokenizer.java x: 1 # contributors y: 2 # changes seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java x: 7 # contributors y: 10 # changes seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSink.java x: 7 # contributors y: 7 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceConfig.java x: 14 # contributors y: 18 # changes seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonSerializationSchema.java x: 12 # contributors y: 13 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Column.java x: 11 # contributors y: 17 # changes seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/DorisCatalogUtil.java x: 10 # contributors y: 17 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergTypeMapper.java x: 8 # contributors y: 11 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/utils/SchemaUtils.java x: 7 # contributors y: 11 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java x: 10 # contributors y: 19 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseMysqlCreateTableSqlBuilder.java x: 3 # contributors y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/psql/PostgresCreateTableSqlBuilder.java x: 8 # contributors y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java x: 8 # contributors y: 12 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java x: 8 # contributors y: 20 # changes seatunnel-engine/seatunnel-engine-storage/checkpoint-storage-plugins/checkpoint-storage-hdfs/src/main/java/org/apache/seatunnel/engine/checkpoint/storage/hdfs/HdfsStorage.java x: 11 # contributors y: 18 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java x: 10 # contributors y: 14 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/SystemFunction.java x: 7 # contributors y: 8 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java x: 6 # contributors y: 11 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/scan/IcebergScanContext.java x: 6 # contributors y: 7 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/state/ElasticsearchSinkState.java x: 4 # contributors y: 5 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/state/FileSinkState.java x: 4 # contributors y: 6 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/YamlSeaTunnelDomConfigProcessor.java x: 17 # contributors y: 30 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java x: 18 # contributors y: 32 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/JettyService.java x: 8 # contributors y: 8 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkAggregatedCommitter.java x: 7 # contributors y: 13 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkAggCommitter.java x: 5 # contributors y: 8 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java x: 14 # contributors y: 25 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/exception/ElasticsearchConnectorErrorCode.java x: 9 # contributors y: 12 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSource.java x: 12 # contributors y: 18 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceFactory.java x: 10 # contributors y: 13 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceReader.java x: 8 # contributors y: 10 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeCatalog.java x: 4 # contributors y: 8 # changes seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeDataTypeConvertor.java x: 3 # contributors y: 6 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSinkConfig.java x: 7 # contributors y: 9 # changes seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/config/KuduSourceTableConfig.java x: 3 # contributors y: 5 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/RowTypeConverter.java x: 9 # contributors y: 10 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java x: 12 # contributors y: 43 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/DefaultSaveModeHandler.java x: 6 # contributors y: 9 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java x: 17 # contributors y: 56 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java x: 18 # contributors y: 87 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java x: 12 # contributors y: 15 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/BaseFileSink.java x: 8 # contributors y: 17 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java x: 14 # contributors y: 15 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java x: 11 # contributors y: 33 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/AbstractReadStrategy.java x: 14 # contributors y: 37 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java x: 13 # contributors y: 18 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java x: 9 # contributors y: 20 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java x: 13 # contributors y: 29 # changes seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/source/CosFileSourceFactory.java x: 12 # contributors y: 14 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSinkFactory.java x: 13 # contributors y: 20 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSourceFactory.java x: 15 # contributors y: 24 # changes seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSourceFactory.java x: 13 # contributors y: 22 # changes seatunnel-connectors-v2/connector-file/connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo/sink/OssFileSinkFactory.java x: 3 # contributors y: 8 # changes seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/sink/LocalFileSinkFactory.java x: 12 # contributors y: 23 # changes seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/sink/OssFileSinkFactory.java x: 11 # contributors y: 22 # changes seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source/OssFileSourceFactory.java x: 14 # contributors y: 24 # changes seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSinkFactory.java x: 14 # contributors y: 23 # changes seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/source/S3FileSourceFactory.java x: 15 # contributors y: 25 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java x: 15 # contributors y: 33 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java x: 11 # contributors y: 20 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java x: 8 # contributors y: 16 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java x: 14 # contributors y: 17 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialectLoader.java x: 9 # contributors y: 9 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java x: 15 # contributors y: 29 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSourceFactory.java x: 12 # contributors y: 17 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java x: 13 # contributors y: 24 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java x: 14 # contributors y: 54 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java x: 22 # contributors y: 37 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceFactory.java x: 13 # contributors y: 14 # changes seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/client/RedisSingleClient.java x: 2 # contributors y: 4 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlTypeMapper.java x: 9 # contributors y: 14 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java x: 17 # contributors y: 33 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java x: 12 # contributors y: 22 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java x: 19 # contributors y: 57 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java x: 8 # contributors y: 36 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java x: 15 # contributors y: 38 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCatalog.java x: 5 # contributors y: 13 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/iris/IrisCatalog.java x: 4 # contributors y: 7 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oracle/OracleCatalog.java x: 8 # contributors y: 18 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCatalog.java x: 8 # contributors y: 15 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java x: 13 # contributors y: 68 # changes seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSource.java x: 11 # contributors y: 15 # changes seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpConfig.java x: 15 # contributors y: 19 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlServerDialect.java x: 9 # contributors y: 16 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/IcebergSink.java x: 5 # contributors y: 10 # changes seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/IcebergSource.java x: 10 # contributors y: 18 # changes seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/source/FakeSourceFactory.java x: 10 # contributors y: 16 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/config/OracleSourceConfigFactory.java x: 6 # contributors y: 10 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/MySqlSourceFetchTaskContext.java x: 7 # contributors y: 16 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/exception/CommonError.java x: 6 # contributors y: 15 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSink.java x: 11 # contributors y: 21 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkWriter.java x: 8 # contributors y: 14 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkWriter.java x: 12 # contributors y: 25 # changes seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkFactory.java x: 10 # contributors y: 11 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/DebeziumJsonDeserializeSchema.java x: 1 # contributors y: 3 # changes seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java x: 12 # contributors y: 34 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/nlpmodel/llm/LLMTransform.java x: 4 # contributors y: 10 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSinkOptions.java x: 12 # contributors y: 16 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java x: 15 # contributors y: 23 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSink.java x: 17 # contributors y: 22 # changes seatunnel-core/seatunnel-core-starter/src/main/java/org/apache/seatunnel/core/starter/utils/ConfigBuilder.java x: 14 # contributors y: 16 # changes seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/sink/RabbitmqSinkFactory.java x: 6 # contributors y: 5 # changes seatunnel-connectors-v2/connector-console/src/main/java/org/apache/seatunnel/connectors/seatunnel/console/sink/ConsoleSink.java x: 9 # contributors y: 15 # changes seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java x: 12 # contributors y: 20 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/CatalogTableUtil.java x: 7 # contributors y: 30 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/factory/FactoryUtil.java x: 12 # contributors y: 39 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java x: 10 # contributors y: 20 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSourceFactory.java x: 10 # contributors y: 27 # changes seatunnel-connectors-v2/connector-file/connector-file-base-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/BaseHdfsFileSource.java x: 11 # contributors y: 28 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSinkFactory.java x: 15 # contributors y: 22 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-13-starter/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SinkExecuteProcessor.java x: 15 # contributors y: 26 # changes seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/TransformExecuteProcessor.java x: 11 # contributors y: 16 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/reader/IncrementalSourceRecordEmitter.java x: 5 # contributors y: 15 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSink.java x: 12 # contributors y: 19 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/AbstractResourceManager.java x: 8 # contributors y: 24 # changes seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java x: 11 # contributors y: 31 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileFormat.java x: 7 # contributors y: 14 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java x: 17 # contributors y: 32 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/OrcWriteStrategy.java x: 7 # contributors y: 19 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java x: 8 # contributors y: 22 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/FileUtils.java x: 6 # contributors y: 16 # changes seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java x: 9 # contributors y: 18 # changes seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java x: 16 # contributors y: 40 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointManager.java x: 10 # contributors y: 46 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java x: 9 # contributors y: 33 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SourceFlowLifeCycle.java x: 12 # contributors y: 30 # changes seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java x: 14 # contributors y: 21 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java x: 13 # contributors y: 33 # changes seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/sink/PaimonSinkWriter.java x: 6 # contributors y: 18 # changes tools/update_modules_check/update_modules_check.py x: 11 # contributors y: 23 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/option/SourceOptions.java x: 6 # contributors y: 14 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/rename/FieldRenameTransform.java x: 2 # contributors y: 1 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSink.java x: 13 # contributors y: 34 # changes seatunnel-api/src/main/java/org/apache/seatunnel/api/common/SeaTunnelAPIErrorCode.java x: 7 # contributors y: 6 # changes seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java x: 16 # contributors y: 28 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/IncrementalSource.java x: 10 # contributors y: 23 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializeSchema.java x: 9 # contributors y: 19 # changes seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/reader/SourceReaderBase.java x: 5 # contributors y: 11 # changes seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchDataTypeConvertor.java x: 4 # contributors y: 9 # changes seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/split/SplitTransform.java x: 3 # contributors y: 7 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java x: 10 # contributors y: 22 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/IncrementalSplitAssigner.java x: 3 # contributors y: 10 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/split/SnapshotSplit.java x: 2 # contributors y: 5 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlIncrementalSource.java x: 7 # contributors y: 25 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelSourceCollector.java x: 13 # contributors y: 21 # changes seatunnel-dist/src/main/assembly/assembly-bin-ci.xml x: 11 # contributors y: 29 # changes seatunnel-dist/src/main/assembly/assembly-bin.xml x: 12 # contributors y: 35 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/TaskDataSerializerHook.java x: 11 # contributors y: 25 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/saphana/SapHanaTypeConverter.java x: 1 # contributors y: 4 # changes seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategy.java x: 5 # contributors y: 14 # changes seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSource.java x: 9 # contributors y: 22 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/AssignSplitOperation.java x: 7 # contributors y: 17 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/RequestSplitOperation.java x: 7 # contributors y: 18 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/operation/source/SourceRegisterOperation.java x: 8 # contributors y: 21 # changes seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/ConsumerMetadata.java x: 10 # contributors y: 10 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/execution/Task.java x: 7 # contributors y: 15 # changes seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/Constant.java x: 9 # contributors y: 23 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/MySqlDialect.java x: 6 # contributors y: 13 # changes seatunnel-engine/seatunnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/job/ClientJobProxy.java x: 8 # contributors y: 19 # changes seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/source/reader/fetch/scan/OracleSnapshotSplitReadTask.java x: 3 # contributors y: 2 # changes seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/HiveSource.java x: 10 # contributors y: 21 # changes seatunnel-connectors-v2/connector-file/connector-file-local/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/local/source/LocalFileSource.java x: 7 # contributors y: 22 # changes seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/JdbcSource.java x: 15 # contributors y: 27 # changes seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointPlan.java x: 6 # contributors y: 12 # changes
87.0
# changes
  min: 1.0
  average: 5.06
  25th percentile: 1.0
  median: 3.0
  75th percentile: 6.0
  max: 87.0
0 22.0
# contributors
min: 1.0 | average: 3.63 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 22.0

Number of Contributors vs. File Size: 3074 points

seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkFactory.java x: 6 # contributors y: 141 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseUtil.java x: 11 # contributors y: 58 lines of code seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/config/GraphQLSinkParameter.java x: 2 # contributors y: 49 lines of code seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/config/GraphQLSourceParameter.java x: 2 # contributors y: 64 lines of code seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/source/reader/GraphQLWebSocket.java x: 2 # contributors y: 111 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/client/HttpClientProvider.java x: 11 # contributors y: 319 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpParameter.java x: 11 # contributors y: 56 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/HttpSourceOptions.java x: 3 # contributors y: 114 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/config/PageInfo.java x: 3 # contributors y: 19 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSource.java x: 19 # contributors y: 170 lines of code seatunnel-connectors-v2/connector-http/connector-http-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/http/source/HttpSourceReader.java x: 16 # contributors y: 404 lines of code seatunnel-connectors-v2/connector-http/connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source/MyHoursSource.java x: 9 # contributors y: 78 lines of code seatunnel-connectors-v2/connector-http/connector-http-myhours/src/main/java/org/apache/seatunnel/connectors/seatunnel/myhours/source/config/MyHoursSourceParameter.java x: 6 # contributors y: 36 lines of code seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/source/split/SamplingSplitStrategy.java x: 5 # contributors y: 202 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksStreamLoadVisitor.java x: 10 # contributors y: 295 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/client/StarRocksSinkManager.java x: 10 # contributors y: 122 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jBaseOptions.java x: 1 # contributors y: 49 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jQueryInfo.java x: 5 # contributors y: 97 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSinkOptions.java x: 1 # contributors y: 24 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSinkQueryInfo.java x: 3 # contributors y: 67 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/config/Neo4jSourceOptions.java x: 1 # contributors y: 2 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSink.java x: 9 # contributors y: 30 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkFactory.java x: 4 # contributors y: 39 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/sink/Neo4jSinkWriter.java x: 8 # contributors y: 121 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSource.java x: 9 # contributors y: 41 lines of code seatunnel-connectors-v2/connector-neo4j/src/main/java/org/apache/seatunnel/connectors/seatunnel/neo4j/source/Neo4jSourceFactory.java x: 5 # contributors y: 53 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/ResourceUtils.java x: 5 # contributors y: 74 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/SubPlan.java x: 12 # contributors y: 586 lines of code seatunnel-connectors-v2/connector-qdrant/src/main/java/org/apache/seatunnel/connectors/seatunnel/qdrant/config/QdrantParameters.java x: 2 # contributors y: 24 lines of code config/seatunnel.yaml x: 15 # contributors y: 29 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergRecordWriter.java x: 5 # contributors y: 153 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointCoordinator.java x: 16 # contributors y: 913 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalVertex.java x: 10 # contributors y: 491 lines of code seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSinkFactory.java x: 5 # contributors y: 34 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/execution/PipelineGenerator.java x: 7 # contributors y: 182 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlanGenerator.java x: 15 # contributors y: 528 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SeaTunnelTask.java x: 11 # contributors y: 372 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/table/TableFilterConfig.java x: 1 # contributors y: 101 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/table/TableFilterMultiCatalogTransform.java x: 1 # contributors y: 66 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplitEnumerator.java x: 14 # contributors y: 372 lines of code seatunnel-connectors-v2/connector-openmldb/src/main/java/org/apache/seatunnel/connectors/seatunnel/openmldb/source/OpenMldbSource.java x: 6 # contributors y: 120 lines of code seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/Tokenizer.java x: 1 # contributors y: 614 lines of code seatunnel-connectors-v2/connector-tdengine/src/main/java/org/apache/seatunnel/connectors/seatunnel/tdengine/sink/TDengineSinkWriter.java x: 7 # contributors y: 124 lines of code seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubSink.java x: 7 # contributors y: 45 lines of code seatunnel-connectors-v2/connector-datahub/src/main/java/org/apache/seatunnel/connectors/seatunnel/datahub/sink/DataHubWriter.java x: 4 # contributors y: 98 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceConfig.java x: 14 # contributors y: 336 lines of code seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonSerializationSchema.java x: 12 # contributors y: 49 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Column.java x: 11 # contributors y: 111 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/PhysicalColumn.java x: 9 # contributors y: 323 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseCatalogUtil.java x: 3 # contributors y: 41 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/util/DorisCatalogUtil.java x: 10 # contributors y: 227 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/IcebergTypeMapper.java x: 8 # contributors y: 153 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/utils/SchemaUtils.java x: 7 # contributors y: 287 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/dm/DamengCreateTableSqlBuilder.java x: 2 # contributors y: 174 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/iris/IrisCreateTableSqlBuilder.java x: 2 # contributors y: 139 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MysqlCreateTableSqlBuilder.java x: 10 # contributors y: 224 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseMysqlCreateTableSqlBuilder.java x: 3 # contributors y: 231 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/psql/PostgresCreateTableSqlBuilder.java x: 8 # contributors y: 169 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/sqlserver/SqlServerCreateTableSqlBuilder.java x: 8 # contributors y: 216 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/xugu/XuguCreateTableSqlBuilder.java x: 3 # contributors y: 109 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeCatalogUtil.java x: 3 # contributors y: 139 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/utils/sink/MilvusSinkConverter.java x: 4 # contributors y: 262 lines of code seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/SchemaUtil.java x: 6 # contributors y: 80 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSaveModeUtil.java x: 8 # contributors y: 83 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/exception/TransformCommonErrorCode.java x: 4 # contributors y: 33 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFunction.java x: 10 # contributors y: 846 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/catalog/IcebergCatalog.java x: 6 # contributors y: 320 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/utils/ExpressionUtils.java x: 2 # contributors y: 267 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ParquetReadStrategy.java x: 10 # contributors y: 390 lines of code seatunnel-connectors-v2/connector-amazondynamodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/amazondynamodb/source/AmazonDynamoDBSourceSplit.java x: 2 # contributors y: 18 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKAggCommitInfo.java x: 5 # contributors y: 5 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/state/CKFileAggCommitInfo.java x: 4 # contributors y: 13 lines of code seatunnel-connectors-v2/connector-common/src/main/java/org/apache/seatunnel/connectors/seatunnel/common/source/SingleSplit.java x: 3 # contributors y: 16 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileAggregatedCommitInfo.java x: 6 # contributors y: 13 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceSplit.java x: 8 # contributors y: 73 lines of code seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/YamlSeaTunnelDomConfigProcessor.java x: 17 # contributors y: 517 lines of code seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/server/ServerConfigOptions.java x: 18 # contributors y: 301 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/SinkAggregatedCommitter.java x: 7 # contributors y: 16 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSinkAggregatedCommitter.java x: 1 # contributors y: 156 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/commit/FileSinkAggregatedCommitter.java x: 8 # contributors y: 100 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/client/EsRestClient.java x: 14 # contributors y: 902 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/config/ElasticsearchSourceOptions.java x: 2 # contributors y: 79 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSource.java x: 12 # contributors y: 221 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceFactory.java x: 10 # contributors y: 69 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/source/ElasticsearchSourceReader.java x: 8 # contributors y: 187 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/configuration/Options.java x: 8 # contributors y: 144 lines of code seatunnel-connectors-v2/connector-graphql/src/main/java/org/apache/seatunnel/connectors/seatunnel/graphql/util/GraphQLUtil.java x: 1 # contributors y: 141 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeCatalog.java x: 4 # contributors y: 291 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/catalog/MaxComputeDataTypeConvertor.java x: 3 # contributors y: 152 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/datatype/MaxComputeTypeConverter.java x: 2 # contributors y: 492 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/sink/MaxcomputeSinkFactory.java x: 6 # contributors y: 49 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/sink/MaxcomputeWriter.java x: 7 # contributors y: 74 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSource.java x: 7 # contributors y: 161 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/source/MaxcomputeSourceSplitEnumerator.java x: 5 # contributors y: 129 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/CsvWriteStrategy.java x: 2 # contributors y: 150 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/CsvReadStrategy.java x: 4 # contributors y: 252 lines of code seatunnel-connectors-v2/connector-kudu/src/main/java/org/apache/seatunnel/connectors/seatunnel/kudu/catalog/KuduCatalog.java x: 3 # contributors y: 192 lines of code seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/config/PaimonConfig.java x: 6 # contributors y: 69 lines of code seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/source/PaimonSource.java x: 4 # contributors y: 119 lines of code seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/RowConverter.java x: 7 # contributors y: 471 lines of code seatunnel-connectors-v2/connector-paimon/src/main/java/org/apache/seatunnel/connectors/seatunnel/paimon/utils/RowTypeConverter.java x: 9 # contributors y: 483 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/catalog/MilvusCatalog.java x: 6 # contributors y: 341 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusBufferBatchWriter.java x: 3 # contributors y: 296 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/sink/MilvusSink.java x: 5 # contributors y: 88 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceReader.java x: 6 # contributors y: 261 lines of code seatunnel-connectors-v2/connector-milvus/src/main/java/org/apache/seatunnel/connectors/seatunnel/milvus/source/MilvusSourceSplitEnumerator.java x: 2 # contributors y: 210 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SourceSplitEnumeratorTask.java x: 12 # contributors y: 344 lines of code seatunnel-engine/seatunnel-engine-ui/src/views/jobs/detail.tsx x: 2 # contributors y: 246 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/DefaultSaveModeHandler.java x: 6 # contributors y: 214 lines of code seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/MultipleTableJobConfigParser.java x: 17 # contributors y: 719 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/master/JobMaster.java x: 18 # contributors y: 916 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/BaseFileSinkConfig.java x: 12 # contributors y: 103 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/config/FileBaseSinkOptions.java x: 1 # contributors y: 282 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/config/FileSinkConfig.java x: 14 # contributors y: 178 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/AbstractWriteStrategy.java x: 11 # contributors y: 337 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ExcelReadStrategy.java x: 13 # contributors y: 237 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/JsonReadStrategy.java x: 11 # contributors y: 120 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/OrcReadStrategy.java x: 9 # contributors y: 780 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/ReadStrategyFactory.java x: 8 # contributors y: 31 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/TextReadStrategy.java x: 13 # contributors y: 218 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/source/reader/XmlReadStrategy.java x: 7 # contributors y: 254 lines of code seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/sink/CosFileSinkFactory.java x: 7 # contributors y: 91 lines of code seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/source/CosFileSource.java x: 9 # contributors y: 106 lines of code seatunnel-connectors-v2/connector-file/connector-file-cos/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/cos/source/CosFileSourceFactory.java x: 12 # contributors y: 77 lines of code seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/sink/FtpFileSinkFactory.java x: 13 # contributors y: 110 lines of code seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSourceFactory.java x: 15 # contributors y: 82 lines of code seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/sink/HdfsFileSinkFactory.java x: 10 # contributors y: 92 lines of code seatunnel-connectors-v2/connector-file/connector-file-hadoop/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/hdfs/source/HdfsFileSourceFactory.java x: 13 # contributors y: 74 lines of code seatunnel-connectors-v2/connector-file/connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo/sink/OssFileSinkFactory.java x: 3 # contributors y: 91 lines of code seatunnel-connectors-v2/connector-file/connector-file-jindo-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/jindo/source/OssFileSourceFactory.java x: 4 # contributors y: 72 lines of code seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source/OssFileSourceFactory.java x: 14 # contributors y: 82 lines of code seatunnel-connectors-v2/connector-file/connector-file-s3/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/s3/sink/S3FileSinkFactory.java x: 14 # contributors y: 109 lines of code seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/sink/HiveSink.java x: 15 # contributors y: 202 lines of code seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/source/config/HiveSourceConfig.java x: 5 # contributors y: 269 lines of code seatunnel-connectors-v2/connector-s3-redshift/src/main/java/org/apache/seatunnel/connectors/seatunnel/redshift/sink/S3RedshiftSink.java x: 8 # contributors y: 53 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/sink/ElasticsearchSinkWriter.java x: 11 # contributors y: 154 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcOutputFormatBuilder.java x: 8 # contributors y: 320 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/oceanbase/OceanBaseMySqlCatalog.java x: 7 # contributors y: 215 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oceanbase/OceanBaseMySqlTypeConverter.java x: 4 # contributors y: 492 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcConnectionConfig.java x: 9 # contributors y: 201 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcOptions.java x: 14 # contributors y: 193 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/JdbcInputFormat.java x: 10 # contributors y: 108 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MySqlDialectFactory.java x: 7 # contributors y: 29 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkFactory.java x: 15 # contributors y: 250 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/ChunkSplitter.java x: 6 # contributors y: 302 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java x: 8 # contributors y: 364 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSinkWriter.java x: 13 # contributors y: 145 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLFilter.java x: 5 # contributors y: 368 lines of code seatunnel-engine/seatunnel-engine-common/src/main/resources/seatunnel.yaml x: 10 # contributors y: 30 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/SeaTunnelServer.java x: 14 # contributors y: 277 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSource.java x: 22 # contributors y: 94 lines of code seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/client/RedisSingleClient.java x: 2 # contributors y: 225 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/config/JdbcSourceTableConfig.java x: 4 # contributors y: 81 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/JdbcDialect.java x: 17 # contributors y: 604 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleDialect.java x: 12 # contributors y: 432 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/source/DynamicChunkSplitter.java x: 5 # contributors y: 640 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/CoordinatorService.java x: 19 # contributors y: 883 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/physical/PhysicalPlan.java x: 8 # contributors y: 273 lines of code seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/config/AerospikeSinkOptions.java x: 1 # contributors y: 78 lines of code seatunnel-connectors-v2/connector-aerospike/src/main/java/org/apache/seatunnel/connectors/seatunnel/aerospike/sink/AerospikeSinkWriter.java x: 1 # contributors y: 217 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/AbstractJdbcCatalog.java x: 15 # contributors y: 621 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/iris/IrisCatalog.java x: 4 # contributors y: 233 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/mysql/MySqlCatalog.java x: 11 # contributors y: 181 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/saphana/SapHanaCatalog.java x: 5 # contributors y: 296 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/catalog/xugu/XuguCatalog.java x: 4 # contributors y: 214 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java x: 13 # contributors y: 901 lines of code seatunnel-connectors-v2/connector-maxcompute/src/main/java/org/apache/seatunnel/connectors/seatunnel/maxcompute/util/MaxcomputeTypeMapper.java x: 6 # contributors y: 276 lines of code seatunnel-formats/seatunnel-format-csv/src/main/java/org/apache/seatunnel/format/csv/CsvDeserializationSchema.java x: 2 # contributors y: 328 lines of code seatunnel-connectors-v2/connector-influxdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/influxdb/source/InfluxDBSourceSplitEnumerator.java x: 7 # contributors y: 187 lines of code seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/source/PrometheusSourceReader.java x: 4 # contributors y: 190 lines of code seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSource.java x: 14 # contributors y: 54 lines of code seatunnel-connectors-v2/connector-iotdb/src/main/java/org/apache/seatunnel/connectors/seatunnel/iotdb/source/IoTDBSourceReader.java x: 9 # contributors y: 138 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/sqlserver/SqlServerDialect.java x: 9 # contributors y: 459 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/IcebergCatalogLoader.java x: 4 # contributors y: 138 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/data/RowConverter.java x: 4 # contributors y: 425 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/sink/writer/IcebergWriterFactory.java x: 4 # contributors y: 159 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/enumerator/IcebergStreamSplitEnumerator.java x: 6 # contributors y: 109 lines of code seatunnel-connectors-v2/connector-iceberg/src/main/java/org/apache/seatunnel/connectors/seatunnel/iceberg/source/reader/IcebergSourceReader.java x: 7 # contributors y: 146 lines of code seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/system/SeaTunnelFTPFileSystem.java x: 7 # contributors y: 532 lines of code seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/catalog/EasysearchCatalog.java x: 5 # contributors y: 180 lines of code seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/client/EasysearchClient.java x: 2 # contributors y: 484 lines of code seatunnel-connectors-v2/connector-easysearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/easysearch/source/EasysearchSourceFactory.java x: 2 # contributors y: 129 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchTypeConverter.java x: 4 # contributors y: 345 lines of code seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceReader.java x: 5 # contributors y: 222 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/config/MongodbSourceOptions.java x: 3 # contributors y: 212 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/source/fetch/MongodbStreamFetchTask.java x: 3 # contributors y: 333 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/utils/MongodbRecordUtils.java x: 3 # contributors y: 172 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/utils/MongodbUtils.java x: 3 # contributors y: 361 lines of code seatunnel-connectors-v2/connector-hudi/src/main/java/org/apache/seatunnel/connectors/seatunnel/hudi/config/HudiSinkOptions.java x: 1 # contributors y: 120 lines of code seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/config/RedisParameters.java x: 12 # contributors y: 160 lines of code seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeConfig.java x: 9 # contributors y: 392 lines of code seatunnel-connectors-v2/connector-fake/src/main/java/org/apache/seatunnel/connectors/seatunnel/fake/config/FakeSourceOptions.java x: 1 # contributors y: 250 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerStreamingChangeEventSource.java x: 3 # contributors y: 736 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/config/OracleSourceConfigFactory.java x: 6 # contributors y: 156 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/source/ClickhouseSource.java x: 13 # contributors y: 40 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/reader/fetch/MySqlSourceFetchTaskContext.java x: 7 # contributors y: 364 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/source/reader/PostgresSourceFetchTaskContext.java x: 3 # contributors y: 305 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/exception/CommonErrorCode.java x: 13 # contributors y: 77 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/sink/StarRocksSink.java x: 11 # contributors y: 82 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/serialize/DefaultSeaTunnelRowSerializer.java x: 15 # contributors y: 279 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/sink/KafkaSinkWriter.java x: 12 # contributors y: 259 lines of code seatunnel-connectors-v2/connector-redis/src/main/java/org/apache/seatunnel/connectors/seatunnel/redis/sink/RedisSinkFactory.java x: 10 # contributors y: 50 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/dag/DAGUtils.java x: 6 # contributors y: 197 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/catalog/DorisCatalog.java x: 7 # contributors y: 456 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/datatype/AbstractDorisTypeConverter.java x: 3 # contributors y: 395 lines of code seatunnel-plugin-discovery/src/main/java/org/apache/seatunnel/plugin/discovery/AbstractPluginDiscovery.java x: 12 # contributors y: 411 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/nlpmodel/embedding/EmbeddingTransform.java x: 2 # contributors y: 192 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/config/StarRocksSinkOptions.java x: 12 # contributors y: 125 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/ClickhouseSink.java x: 15 # contributors y: 166 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSink.java x: 17 # contributors y: 48 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/util/ClickhouseProxy.java x: 5 # contributors y: 354 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/config/TypesafeConfigUtils.java x: 12 # contributors y: 63 lines of code seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/config/RabbitmqConfig.java x: 7 # contributors y: 104 lines of code seatunnel-engine/seatunnel-engine-common/src/main/java/org/apache/seatunnel/engine/common/config/EngineConfig.java x: 15 # contributors y: 116 lines of code seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/sink/RocketMqSink.java x: 5 # contributors y: 136 lines of code seatunnel-formats/seatunnel-format-text/src/main/java/org/apache/seatunnel/format/text/TextDeserializationSchema.java x: 12 # contributors y: 306 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbDialect.java x: 11 # contributors y: 315 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/table/catalog/Catalog.java x: 10 # contributors y: 144 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/config/JdbcSourceConfigFactory.java x: 10 # contributors y: 171 lines of code seatunnel-core/seatunnel-flink-starter/seatunnel-flink-starter-common/src/main/java/org/apache/seatunnel/core/starter/flink/execution/SinkExecuteProcessor.java x: 13 # contributors y: 164 lines of code seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/execution/SourceExecuteProcessor.java x: 9 # contributors y: 118 lines of code seatunnel-core/seatunnel-spark-starter/seatunnel-spark-starter-common/src/main/java/org/apache/seatunnel/core/starter/spark/execution/TransformExecuteProcessor.java x: 11 # contributors y: 187 lines of code seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/ConfigParserUtil.java x: 5 # contributors y: 240 lines of code seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/serialization/SeaTunnelRowConverter.java x: 5 # contributors y: 244 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/io/debezium/connector/mysql/MySqlStreamingChangeEventSource.java x: 1 # contributors y: 1193 lines of code seatunnel-formats/seatunnel-format-csv/src/main/java/org/apache/seatunnel/format/csv/CsvSerializationSchema.java x: 1 # contributors y: 225 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/resourcemanager/ResourceRequestHandler.java x: 8 # contributors y: 238 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/service/slot/DefaultSlotService.java x: 8 # contributors y: 294 lines of code seatunnel-engine/seatunnel-engine-core/src/main/java/org/apache/seatunnel/engine/core/parse/JobConfigParser.java x: 11 # contributors y: 35 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/TextWriteStrategy.java x: 12 # contributors y: 149 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/debezium/row/SeaTunnelRowDebeziumDeserializationConverters.java x: 7 # contributors y: 501 lines of code seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/system/SFTPFileSystem.java x: 6 # contributors y: 545 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/table/type/SeaTunnelRow.java x: 17 # contributors y: 335 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/JsonUtils.java x: 10 # contributors y: 190 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/serialize/source/DefaultSeaTunnelRowDeserializer.java x: 11 # contributors y: 245 lines of code seatunnel-translation/seatunnel-translation-spark/seatunnel-translation-spark-common/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java x: 6 # contributors y: 413 lines of code seatunnel-connectors-v2/connector-file/connector-file-base/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sink/writer/ParquetWriteStrategy.java x: 8 # contributors y: 394 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/catalog/StarRocksCatalog.java x: 9 # contributors y: 444 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/SinkFlowLifeCycle.java x: 14 # contributors y: 295 lines of code seatunnel-core/seatunnel-starter/src/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java x: 16 # contributors y: 253 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresTypeConverter.java x: 3 # contributors y: 435 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/CheckpointManager.java x: 10 # contributors y: 244 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/SinkAggregatedCommitterTask.java x: 9 # contributors y: 277 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/task/flow/TransformFlowLifeCycle.java x: 9 # contributors y: 162 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/tracing/MDCStream.java x: 1 # contributors y: 201 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/table/converter/BasicDataConverter.java x: 2 # contributors y: 1166 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/file/ClickhouseFileSinkWriter.java x: 14 # contributors y: 401 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/StringFunction.java x: 4 # contributors y: 628 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/utils/DateTimeUtils.java x: 7 # contributors y: 266 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/ZetaSQLEngine.java x: 7 # contributors y: 240 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java x: 13 # contributors y: 285 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/mysql/MysqlDialect.java x: 14 # contributors y: 212 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/psql/PostgresDialect.java x: 11 # contributors y: 391 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/schema/SchemaChangeManager.java x: 1 # contributors y: 348 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkWriter.java x: 9 # contributors y: 232 lines of code seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/rest/RestService.java x: 10 # contributors y: 423 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/dm/DmdbTypeConverter.java x: 2 # contributors y: 449 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/joiner/LiteNodeDropOutTcpIpJoiner.java x: 1 # contributors y: 480 lines of code seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/cluster/impl/MemberImpl.java x: 3 # contributors y: 246 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/executor/FieldNamedPreparedStatement.java x: 8 # contributors y: 567 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/rename/FieldRenameTransform.java x: 2 # contributors y: 292 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/converter/AbstractJdbcRowConverter.java x: 11 # contributors y: 281 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/kingbase/KingbaseJdbcRowConverter.java x: 6 # contributors y: 172 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/sink/JdbcSink.java x: 13 # contributors y: 268 lines of code seatunnel-connectors-v2/connector-starrocks/src/main/java/org/apache/seatunnel/connectors/seatunnel/starrocks/datatypes/StarRocksTypeConverter.java x: 1 # contributors y: 577 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/config/Common.java x: 16 # contributors y: 131 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/IncrementalSource.java x: 10 # contributors y: 274 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mysql/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/source/parser/CustomMySqlAntlrDdlParser.java x: 3 # contributors y: 270 lines of code seatunnel-connectors-v2/connector-elasticsearch/src/main/java/org/apache/seatunnel/connectors/seatunnel/elasticsearch/catalog/ElasticSearchCatalog.java x: 9 # contributors y: 214 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/xa/XaFacadeImplAutoLoad.java x: 7 # contributors y: 407 lines of code seatunnel-api/src/main/java/org/apache/seatunnel/api/sink/multitablesink/MultiTableSinkWriter.java x: 4 # contributors y: 324 lines of code seatunnel-common/src/main/java/org/apache/seatunnel/common/Constants.java x: 12 # contributors y: 27 lines of code seatunnel-connectors-v2/connector-hive/src/main/java/org/apache/seatunnel/connectors/seatunnel/hive/utils/HiveMetaStoreProxy.java x: 10 # contributors y: 151 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-base/src/main/java/org/apache/seatunnel/connectors/cdc/base/source/enumerator/splitter/AbstractJdbcSourceChunkSplitter.java x: 5 # contributors y: 426 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/mongodb/sender/MongoDBConnectorDeserializationSchema.java x: 5 # contributors y: 573 lines of code seatunnel-connectors-v2/connector-mongodb/src/main/java/org/apache/seatunnel/connectors/seatunnel/mongodb/serde/BsonToRowDataConverters.java x: 5 # contributors y: 399 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/serializable/TaskDataSerializerHook.java x: 11 # contributors y: 137 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/saphana/SapHanaTypeConverter.java x: 1 # contributors y: 440 lines of code seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto/GoGoProtos.java x: 1 # contributors y: 743 lines of code seatunnel-connectors-v2/connector-prometheus/src/main/java/org/apache/seatunnel/connectors/seatunnel/prometheus/sink/proto/Remote.java x: 1 # contributors y: 4746 lines of code seatunnel-engine/seatunnel-engine-ui/src/components/directed-acyclic-graph/index.tsx x: 1 # contributors y: 329 lines of code seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigImpl.java x: 1 # contributors y: 377 lines of code seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/SimpleConfigObject.java x: 3 # contributors y: 549 lines of code seatunnel-connectors-v2/connector-file/connector-file-sftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/sftp/source/SftpFileSource.java x: 10 # contributors y: 14 lines of code seatunnel-connectors-v2/connector-file/connector-file-ftp/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/ftp/source/FtpFileSource.java x: 9 # contributors y: 14 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-tidb/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/tidb/source/converter/DefaultDataConverter.java x: 1 # contributors y: 276 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/oracle/OracleTypeConverter.java x: 3 # contributors y: 346 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaPartitionSplitReader.java x: 2 # contributors y: 360 lines of code seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/NodeExtension.java x: 9 # contributors y: 65 lines of code seatunnel-connectors-v2/connector-kafka/src/main/java/org/apache/seatunnel/connectors/seatunnel/kafka/source/KafkaSourceReader.java x: 15 # contributors y: 137 lines of code seatunnel-translation/seatunnel-translation-base/src/main/java/org/apache/seatunnel/translation/source/ParallelSource.java x: 12 # contributors y: 177 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-opengauss/src/main/java/io/debezium/connector/postgresql/connection/PostgresConnection.java x: 1 # contributors y: 582 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/oracle/utils/OracleUtils.java x: 4 # contributors y: 472 lines of code seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/RowToJsonConverters.java x: 8 # contributors y: 259 lines of code seatunnel-formats/seatunnel-format-json/src/main/java/org/apache/seatunnel/format/json/JsonToRowConverters.java x: 11 # contributors y: 394 lines of code seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl/ClusterServiceImpl.java x: 1 # contributors y: 1034 lines of code seatunnel-shade/seatunnel-hazelcast/seatunnel-hazelcast-shade/src/main/java/com/hazelcast/internal/cluster/impl/MembershipManager.java x: 1 # contributors y: 1395 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/DateTimeFunction.java x: 4 # contributors y: 520 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-oracle/src/main/java/io/debezium/connector/oracle/logminer/LogMinerAdapter.java x: 1 # contributors y: 363 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/io/debezium/connector/postgresql/TypeRegistry.java x: 2 # contributors y: 349 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-postgres/src/main/java/org/apache/seatunnel/connectors/seatunnel/cdc/postgres/utils/PostgresUtils.java x: 4 # contributors y: 458 lines of code seatunnel-connectors-v2/connector-cdc/connector-cdc-sqlserver/src/main/java/io/debezium/connector/sqlserver/SqlServerStreamingChangeEventSource.java x: 5 # contributors y: 504 lines of code seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/internal/dialect/snowflake/SnowflakeTypeConverter.java x: 1 # contributors y: 310 lines of code seatunnel-connectors-v2/connector-rocketmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rocketmq/source/RocketMqSourceSplitEnumerator.java x: 5 # contributors y: 305 lines of code seatunnel-connectors-v2/connector-file/connector-file-oss/src/main/java/org/apache/seatunnel/connectors/seatunnel/file/oss/source/OssFileSource.java x: 8 # contributors y: 14 lines of code seatunnel-transforms-v2/src/main/java/org/apache/seatunnel/transform/sql/zeta/functions/NumericFunction.java x: 2 # contributors y: 397 lines of code seatunnel-connectors-v2/connector-clickhouse/src/main/java/org/apache/seatunnel/connectors/seatunnel/clickhouse/sink/client/executor/FieldNamedPreparedStatement.java x: 4 # contributors y: 552 lines of code seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java x: 5 # contributors y: 485 lines of code seatunnel-connectors-v2/connector-rabbitmq/src/main/java/org/apache/seatunnel/connectors/seatunnel/rabbitmq/source/RabbitmqSourceReader.java x: 4 # contributors y: 179 lines of code
4746.0
lines of code
  min: 1.0
  average: 77.58
  25th percentile: 17.0
  median: 38.0
  75th percentile: 87.0
  max: 4746.0
0 22.0
# contributors
min: 1.0 | average: 3.63 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 22.0