Hudi
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 2,460 files with 251,281 lines of code.
    • 5 files changed more than 100 times (5,297 lines of code)
    • 22 files changed 51-100 times (13,379 lines of code)
    • 132 files changed 21-50 times (36,736 lines of code)
    • 604 files changed 6-20 times (81,967 lines of code)
    • 1,697 files changed 1-5 times (113,902 lines of code)
2% | 5% | 14% | 32% | 45%
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 2,460 files with 251,281 lines of code.
    • 33 files changed by more than 25 contributors (19,894 lines of code)
    • 220 files changed by 11-25 contributors (51,809 lines of code)
    • 358 files changed by 6-10 contributors (45,249 lines of code)
    • 1,056 files changed by 2-5 contributors (92,467 lines of code)
    • 793 files changed by 1 contributor (41,862 lines of code)
7% | 20% | 18% | 36% | 16%
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, scala, xml, avsc, sh, json, properties, yaml, md, sql, txt, yml, g4, mustache, proto, py, js, gitignore, thrift, rdf
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java1% | 6% | 16% | 34% | 39%
scala3% | 1% | 10% | 25% | 59%
rdf0% | 0% | 100% | 0% | 0%
xml0% | 0% | 0% | 83% | 16%
avsc0% | 0% | 0% | 38% | 61%
yml0% | 0% | 0% | 62% | 37%
g40% | 0% | 0% | 2% | 97%
py0% | 0% | 0% | 0% | 100%
sql0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
mustache0% | 0% | 0% | 0% | 100%
thrift0% | 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
hudi-client7% | 5% | 16% | 39% | 31%
hudi-spark-datasource2% | <1% | 9% | 21% | 65%
hudi-utilities<1% | 4% | 23% | 35% | 35%
hudi-common0% | 13% | 16% | 35% | 34%
hudi-flink-datasource0% | 2% | 11% | 32% | 53%
hudi-cli0% | 10% | 28% | 42% | 19%
hudi-hadoop-mr0% | 0% | 23% | 46% | 30%
hudi-timeline-service0% | 0% | 47% | 31% | 21%
hudi-aws0% | 0% | 44% | 25% | 30%
hudi-sync0% | 0% | 14% | 46% | 39%
hudi-integ-test0% | 0% | 9% | 41% | 48%
ROOT0% | 0% | 30% | 69% | 0%
hudi-kafka-connect0% | 0% | 0% | 56% | 43%
hudi-gcp0% | 0% | 0% | 76% | 23%
docker0% | 0% | 0% | 46% | 53%
style0% | 0% | 0% | 94% | 5%
hudi-io0% | 0% | 0% | 0% | 100%
hudi-hadoop-common0% | 0% | 0% | 0% | 100%
hudi-platform-service0% | 0% | 0% | 0% | 100%
scripts0% | 0% | 0% | 0% | 100%
packaging0% | 0% | 0% | 0% | 100%
hudi-examples0% | 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
HoodieWriteConfig.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config
 2526 448 2020-10-01 2024-04-08 212 64 wxhjsxz@126.com wombatukun@gmail.com
DeltaSync.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer
 28 2 2019-08-12 2024-02-26 143 58 varadarb@uber.com vinishreddygunner17@gmail.com
DataSourceOptions.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 758 7 2020-12-10 2024-03-01 116 43 wenningding95@gmail.com geserdugarov@gmail.com
HoodieBackedTableMetadataWriter.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata
 1115 55 2020-12-31 2024-04-01 116 38 ryanpife@amazon.com yuzhao.cyz@gmail.com
HoodieSparkSqlWriter.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 870 27 2022-01-14 2024-04-03 107 43 490081539@qq.com jbvexler@gmail.com
HoodieTable.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table
 562 63 2020-10-01 2024-03-23 100 47 wxhjsxz@126.com wombatukun@gmail.com
HoodieFlinkWriteClient.java
in hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client
 367 36 2020-11-08 2023-10-25 96 30 satishkotha@uber.com beyond1920@gmail.com
HoodieTableMetaClient.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 976 110 2019-08-12 2024-03-04 96 45 varadarb@uber.com stayrascal@users.noreply.gi...
HoodieDeltaStreamer.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer
 36 4 2019-08-12 2023-07-12 89 48 varadarb@uber.com ethan.guoyihua@gmail.com
BaseHoodieWriteClient.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client
 840 94 2022-01-28 2024-04-08 86 33 2701446+xushiyan@users.nore... wombatukun@gmail.com
HoodieTableConfig.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 613 56 2019-08-12 2024-04-08 82 36 varadarb@uber.com wombatukun@gmail.com
UtilHelpers.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities
 514 37 2019-08-12 2024-03-07 79 45 varadarb@uber.com harshal.j.patil@gmail.com
SparkRDDWriteClient.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client
 262 26 2020-10-01 2024-02-28 77 34 wxhjsxz@126.com stream2000@apache.org
HoodieTableMetadataUtil.java
in hudi-common/src/main/java/org/apache/hudi/metadata
 1273 66 2020-12-31 2024-03-04 76 28 ryanpife@amazon.com 152183592+bhat-vinay@users....
FSUtils.java
in hudi-common/src/main/java/org/apache/hudi/common/fs
 557 62 2020-03-29 2024-04-05 73 38 vinothchandar@users.noreply... wombatukun@gmail.com
HoodieAvroUtils.java
in hudi-common/src/main/java/org/apache/hudi/avro
 982 70 2020-03-27 2024-04-06 72 35 pwason@uber.com tim@onehouse.ai
HoodieActiveTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 583 70 2019-08-12 2024-01-31 68 33 varadarb@uber.com ethan.guoyihua@gmail.com
AbstractTableFileSystemView.java
in hudi-common/src/main/java/org/apache/hudi/common/table/view
 1039 82 2019-08-12 2024-03-28 68 39 varadarb@uber.com tim@onehouse.ai
SparkMain.java
in hudi-cli/src/main/java/org/apache/hudi/cli/commands
 589 27 2019-08-12 2024-01-29 67 39 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieBackedTableMetadata.java
in hudi-common/src/main/java/org/apache/hudi/metadata
 597 20 2020-12-31 2024-02-07 66 29 ryanpife@amazon.com 152183592+bhat-vinay@users....
HoodieMergeHandle.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io
 370 27 2020-10-01 2024-03-23 64 33 wxhjsxz@126.com wombatukun@gmail.com
HoodieDefaultTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 447 75 2019-08-12 2024-03-26 58 30 varadarb@uber.com ethan.guoyihua@gmail.com
MergeIntoHoodieTableCommand.scala
in hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command
 474 19 2021-06-08 2023-11-10 58 27 pengzhiwei2015@icloud.com jbvexler@gmail.com
HoodieAppendHandle.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io
 519 32 2020-10-01 2024-03-23 56 25 wxhjsxz@126.com wombatukun@gmail.com
FlinkOptions.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration
 900 6 2022-03-21 2024-04-08 55 27 yuzhao.cyz@gmail.com 34104400+zhuanshenbsj1@user...
HoodieMetadataConfig.java
in hudi-common/src/main/java/org/apache/hudi/common/config
 547 70 2020-12-31 2023-11-03 54 19 udit.mehrotra90@gmail.com sagarsumit09@gmail.com
KafkaOffsetGen.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers
 332 16 2019-08-12 2024-03-15 52 29 varadarb@uber.com vinishreddygunner17@gmail.com
DefaultSource.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 301 11 2022-01-14 2024-03-27 50 23 490081539@qq.com jbvexler@gmail.com
HoodieAnalysis.scala
in hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis
 383 21 2021-06-08 2023-12-12 50 19 pengzhiwei2015@icloud.com jbvexler@gmail.com
HiveSyncTool.java
in hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive
 358 18 2020-08-06 2024-03-16 49 33 lw309637554@gmail.com vitaliy.makarevich.work@gma...
HoodieBaseRelation.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 532 21 2022-02-11 2024-02-17 49 17 biyan900116@gmail.com jbvexler@gmail.com
BaseSparkCommitActionExecutor.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit
 303 14 2020-10-01 2024-03-23 48 31 wxhjsxz@126.com wombatukun@gmail.com
StreamerUtil.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util
 371 35 2022-03-21 2024-03-26 48 25 yuzhao.cyz@gmail.com ethan.guoyihua@gmail.com
HoodieFlinkCopyOnWriteTable.java
in hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table
 280 14 2020-11-08 2024-03-23 46 25 satishkotha@uber.com wombatukun@gmail.com
HoodieLogFileReader.java
in hudi-common/src/main/java/org/apache/hudi/common/table/log
 376 23 2019-08-12 2024-02-01 46 30 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieFileIndex.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 373 13 2022-01-14 2024-03-11 45 21 490081539@qq.com 137779852+studystill@users....
HoodieMetadataPayload.java
in hudi-common/src/main/java/org/apache/hudi/metadata
 551 38 2020-12-31 2024-03-27 45 16 pwason@uber.com ethan.guoyihua@gmail.com
CleanPlanner.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean
 408 23 2020-10-01 2024-04-01 44 23 wxhjsxz@126.com sagarsumit09@gmail.com
HoodieClusteringConfig.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config
 515 40 2020-11-08 2023-11-04 44 27 satishkotha@uber.com 135721692+ksmou@users.norep...
HoodieSparkUtils.scala
in hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi
 247 11 2021-07-20 2024-04-06 42 15 sivabala@uber.com tim@onehouse.ai
RemoteHoodieTableFileSystemView.java
in hudi-common/src/main/java/org/apache/hudi/common/table/view
 547 39 2019-08-12 2024-03-28 42 25 varadarb@uber.com tim@onehouse.ai
HiveSyncConfig.java
in hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive
 161 8 2020-08-06 2024-02-08 41 29 lw309637554@gmail.com nicolas.paris@adevinta.com
HoodieTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 299 53 2020-03-29 2024-03-26 41 22 vinothchandar@users.noreply... ethan.guoyihua@gmail.com
HoodieInputFormatUtils.java
in hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils
 349 17 2020-06-09 2024-02-27 41 23 yanjia.gary.li@gmail.com stayrascal@users.noreply.gi...
MultipleSparkJobExecutionStrategy.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy
 358 5 2021-08-07 2024-01-29 41 22 sagarsumit09@gmail.com ethan.guoyihua@gmail.com
TableSchemaResolver.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 392 35 2020-03-27 2024-03-05 41 25 pwason@uber.com jbvexler@gmail.com
RealtimeCompactedRecordReader.java
in hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime
 172 12 2019-08-12 2024-01-29 40 22 varadarb@uber.com ethan.guoyihua@gmail.com
DataSourceUtils.java
in hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi
 231 15 2020-12-10 2023-08-14 40 26 wenningding95@gmail.com n.siva.b@gmail.com
SparkAdapter.scala
in hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi
 78 6 2021-07-20 2023-12-12 39 16 sivabala@uber.com 141371752+linliu-code@users...
HoodieSparkCopyOnWriteTable.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table
 241 15 2020-10-01 2024-03-23 39 22 wxhjsxz@126.com wombatukun@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
HoodieWriteConfig.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config
 2526 448 2020-10-01 2024-04-08 212 64 wxhjsxz@126.com wombatukun@gmail.com
DeltaSync.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer
 28 2 2019-08-12 2024-02-26 143 58 varadarb@uber.com vinishreddygunner17@gmail.com
HoodieDeltaStreamer.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer
 36 4 2019-08-12 2023-07-12 89 48 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieTable.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table
 562 63 2020-10-01 2024-03-23 100 47 wxhjsxz@126.com wombatukun@gmail.com
HoodieTableMetaClient.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 976 110 2019-08-12 2024-03-04 96 45 varadarb@uber.com stayrascal@users.noreply.gi...
UtilHelpers.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities
 514 37 2019-08-12 2024-03-07 79 45 varadarb@uber.com harshal.j.patil@gmail.com
DataSourceOptions.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 758 7 2020-12-10 2024-03-01 116 43 wenningding95@gmail.com geserdugarov@gmail.com
HoodieSparkSqlWriter.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 870 27 2022-01-14 2024-04-03 107 43 490081539@qq.com jbvexler@gmail.com
AbstractTableFileSystemView.java
in hudi-common/src/main/java/org/apache/hudi/common/table/view
 1039 82 2019-08-12 2024-03-28 68 39 varadarb@uber.com tim@onehouse.ai
SparkMain.java
in hudi-cli/src/main/java/org/apache/hudi/cli/commands
 589 27 2019-08-12 2024-01-29 67 39 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieBackedTableMetadataWriter.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata
 1115 55 2020-12-31 2024-04-01 116 38 ryanpife@amazon.com yuzhao.cyz@gmail.com
FSUtils.java
in hudi-common/src/main/java/org/apache/hudi/common/fs
 557 62 2020-03-29 2024-04-05 73 38 vinothchandar@users.noreply... wombatukun@gmail.com
HoodieTableConfig.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 613 56 2019-08-12 2024-04-08 82 36 varadarb@uber.com wombatukun@gmail.com
HoodieAvroUtils.java
in hudi-common/src/main/java/org/apache/hudi/avro
 982 70 2020-03-27 2024-04-06 72 35 pwason@uber.com tim@onehouse.ai
SparkRDDWriteClient.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client
 262 26 2020-10-01 2024-02-28 77 34 wxhjsxz@126.com stream2000@apache.org
BaseHoodieWriteClient.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client
 840 94 2022-01-28 2024-04-08 86 33 2701446+xushiyan@users.nore... wombatukun@gmail.com
HoodieActiveTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 583 70 2019-08-12 2024-01-31 68 33 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieMergeHandle.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io
 370 27 2020-10-01 2024-03-23 64 33 wxhjsxz@126.com wombatukun@gmail.com
HiveSyncTool.java
in hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive
 358 18 2020-08-06 2024-03-16 49 33 lw309637554@gmail.com vitaliy.makarevich.work@gma...
BaseSparkCommitActionExecutor.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit
 303 14 2020-10-01 2024-03-23 48 31 wxhjsxz@126.com wombatukun@gmail.com
HoodieFlinkWriteClient.java
in hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client
 367 36 2020-11-08 2023-10-25 96 30 satishkotha@uber.com beyond1920@gmail.com
HoodieDefaultTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 447 75 2019-08-12 2024-03-26 58 30 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieLogFileReader.java
in hudi-common/src/main/java/org/apache/hudi/common/table/log
 376 23 2019-08-12 2024-02-01 46 30 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieBackedTableMetadata.java
in hudi-common/src/main/java/org/apache/hudi/metadata
 597 20 2020-12-31 2024-02-07 66 29 ryanpife@amazon.com 152183592+bhat-vinay@users....
KafkaOffsetGen.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers
 332 16 2019-08-12 2024-03-15 52 29 varadarb@uber.com vinishreddygunner17@gmail.com
HiveSyncConfig.java
in hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive
 161 8 2020-08-06 2024-02-08 41 29 lw309637554@gmail.com nicolas.paris@adevinta.com
HoodieTableMetadataUtil.java
in hudi-common/src/main/java/org/apache/hudi/metadata
 1273 66 2020-12-31 2024-03-04 76 28 ryanpife@amazon.com 152183592+bhat-vinay@users....
MergeIntoHoodieTableCommand.scala
in hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command
 474 19 2021-06-08 2023-11-10 58 27 pengzhiwei2015@icloud.com jbvexler@gmail.com
FlinkOptions.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration
 900 6 2022-03-21 2024-04-08 55 27 yuzhao.cyz@gmail.com 34104400+zhuanshenbsj1@user...
HoodieClusteringConfig.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config
 515 40 2020-11-08 2023-11-04 44 27 satishkotha@uber.com 135721692+ksmou@users.norep...
HoodieMergedLogRecordScanner.java
in hudi-common/src/main/java/org/apache/hudi/common/table/log
 327 36 2019-08-12 2024-01-24 39 27 varadarb@uber.com 22875197+kbuci@users.norepl...
DataSourceUtils.java
in hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi
 231 15 2020-12-10 2023-08-14 40 26 wenningding95@gmail.com n.siva.b@gmail.com
HoodieMultiTableDeltaStreamer.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer
 13 1 2020-04-08 2023-07-12 29 26 pratyaksh13@gmail.com ethan.guoyihua@gmail.com
HoodieAppendHandle.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io
 519 32 2020-10-01 2024-03-23 56 25 wxhjsxz@126.com wombatukun@gmail.com
StreamerUtil.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util
 371 35 2022-03-21 2024-03-26 48 25 yuzhao.cyz@gmail.com ethan.guoyihua@gmail.com
HoodieFlinkCopyOnWriteTable.java
in hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table
 280 14 2020-11-08 2024-03-23 46 25 satishkotha@uber.com wombatukun@gmail.com
RemoteHoodieTableFileSystemView.java
in hudi-common/src/main/java/org/apache/hudi/common/table/view
 547 39 2019-08-12 2024-03-28 42 25 varadarb@uber.com tim@onehouse.ai
TableSchemaResolver.java
in hudi-common/src/main/java/org/apache/hudi/common/table
 392 35 2020-03-27 2024-03-05 41 25 pwason@uber.com jbvexler@gmail.com
HoodieLogFileCommand.java
in hudi-cli/src/main/java/org/apache/hudi/cli/commands
 252 2 2019-08-12 2024-01-29 36 25 varadarb@uber.com ethan.guoyihua@gmail.com
AbstractRealtimeRecordReader.java
in hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime
 165 15 2019-08-12 2023-10-13 37 24 varadarb@uber.com 135721692+ksmou@users.norep...
RepairsCommand.java
in hudi-cli/src/main/java/org/apache/hudi/cli/commands
 273 8 2019-08-12 2023-09-28 34 24 varadarb@uber.com 141371752+linliu-code@users...
DefaultSource.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi
 301 11 2022-01-14 2024-03-27 50 23 490081539@qq.com jbvexler@gmail.com
CleanPlanner.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean
 408 23 2020-10-01 2024-04-01 44 23 wxhjsxz@126.com sagarsumit09@gmail.com
HoodieInputFormatUtils.java
in hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils
 349 17 2020-06-09 2024-02-27 41 23 yanjia.gary.li@gmail.com stayrascal@users.noreply.gi...
ProvidesHoodieConfig.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi
 396 12 2022-02-23 2024-04-08 39 23 490081539@qq.com wombatukun@gmail.com
HoodieCompactor.java
in hudi-utilities/src/main/java/org/apache/hudi/utilities
 245 13 2019-08-12 2024-01-29 36 23 varadarb@uber.com ethan.guoyihua@gmail.com
HoodieCompactionConfig.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config
 309 25 2020-10-01 2023-09-21 34 23 wxhjsxz@126.com ethan.guoyihua@gmail.com
HoodieWriteHandle.java
in hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io
 191 26 2020-10-01 2024-03-23 34 23 wxhjsxz@126.com wombatukun@gmail.com
HoodieTimeline.java
in hudi-common/src/main/java/org/apache/hudi/common/table/timeline
 299 53 2020-03-29 2024-03-26 41 22 vinothchandar@users.noreply... ethan.guoyihua@gmail.com
MultipleSparkJobExecutionStrategy.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy
 358 5 2021-08-07 2024-01-29 41 22 sagarsumit09@gmail.com ethan.guoyihua@gmail.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
HoodieSpark3_5ExtendedSqlAstBuilder.scala
in hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser
 2354 181 2023-11-16 2023-11-16 1 1 42792772+ctty@users.noreply... 42792772+ctty@users.noreply...
SqlBase.g4
in hudi-spark-datasource/hudi-spark3.5.x/src/main/antlr4/imports
 1760 - 2023-11-16 2023-11-16 1 1 42792772+ctty@users.noreply... 42792772+ctty@users.noreply...
SqlBase.g4
in hudi-spark-datasource/hudi-spark2/src/main/antlr4/imports
 971 - 2021-06-08 2021-06-08 1 1 pengzhiwei2015@icloud.com pengzhiwei2015@icloud.com
HoodieWrapperFileSystem.java
in hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs
 865 124 2024-01-29 2024-01-31 2 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
HoodieNativeAvroHFileReader.java
in hudi-common/src/main/java/org/apache/hudi/io/storage
 459 24 2024-01-29 2024-02-16 3 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
CDCFileGroupIterator.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc
 415 16 2023-11-07 2023-12-06 2 1 141371752+linliu-code@users... 141371752+linliu-code@users...
AvroDeserializer.scala
in hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro
 375 10 2023-11-16 2023-11-16 1 1 42792772+ctty@users.noreply... 42792772+ctty@users.noreply...
AvroDeserializer.scala
in hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro
 375 10 2023-06-10 2023-08-03 2 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
ArrayColumnReader.java
in hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 366 9 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
ArrayColumnReader.java
in hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 366 9 2023-04-27 2023-04-27 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
ArrayColumnReader.java
in hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 366 9 2023-01-05 2023-01-05 1 1 stayrascal@users.noreply.gi... stayrascal@users.noreply.gi...
ArrayColumnReader.java
in hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 366 9 2023-11-09 2023-11-09 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
ArrayColumnReader.java
in hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 366 9 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
Spark31LegacyHoodieParquetFileFormat.scala
in hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet
 325 4 2023-08-07 2023-08-07 1 1 jbvexler@gmail.com jbvexler@gmail.com
AvroSerializer.scala
in hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro
 325 11 2023-06-10 2023-06-10 1 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
AvroSerializer.scala
in hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro
 324 11 2023-11-16 2023-11-16 1 1 42792772+ctty@users.noreply... 42792772+ctty@users.noreply...
Spark30LegacyHoodieParquetFileFormat.scala
in hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet
 319 4 2023-08-07 2023-08-07 1 1 jbvexler@gmail.com jbvexler@gmail.com
Predicates.java
in hudi-common/src/main/java/org/apache/hudi/expression
 311 59 2023-07-24 2023-07-24 1 1 bonean131@gmail.com bonean131@gmail.com
TypeConverters.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format
 304 8 2023-07-20 2023-07-20 1 1 voonhousu@gmail.com voonhousu@gmail.com
AvroSerializer.scala
in hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro
 297 11 2023-05-20 2023-05-20 1 1 69956021+zhangyue19921010@u... 69956021+zhangyue19921010@u...
ComparableVersion.java
in hudi-io/src/main/java/org/apache/hudi/common/util
 252 24 2024-01-31 2024-01-31 1 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
Spark30ResolveHudiAlterTableCommand.scala
in hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi
 236 6 2023-05-20 2023-05-20 1 1 69956021+zhangyue19921010@u... 69956021+zhangyue19921010@u...
HFileReaderImpl.java
in hudi-io/src/main/java/org/apache/hudi/io/hfile
 233 15 2024-01-18 2024-02-16 3 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
HoodieHadoopFSUtils.scala
in hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark
 233 4 2022-03-19 2022-03-19 1 1 alexey@infinilake.com alexey@infinilake.com
JsonEncoder.java
in hudi-common/src/main/java/org/apache/hudi/avro
 230 28 2023-09-15 2023-09-15 1 1 sagarsumit09@gmail.com sagarsumit09@gmail.com
Spark31ResolveHudiAlterTableCommand.scala
in hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/hudi
 224 5 2022-09-14 2022-09-14 1 1 alexey@infinilake.com alexey@infinilake.com
StoragePath.java
in hudi-io/src/main/java/org/apache/hudi/storage
 222 16 2024-02-17 2024-02-17 1 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
BaseVectorizedColumnReader.java
in hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 221 12 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
BaseVectorizedColumnReader.java
in hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 221 12 2023-04-27 2023-04-27 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
BaseVectorizedColumnReader.java
in hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 221 12 2023-01-05 2023-01-05 1 1 stayrascal@users.noreply.gi... stayrascal@users.noreply.gi...
BaseVectorizedColumnReader.java
in hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 221 12 2023-11-09 2023-11-09 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
BaseVectorizedColumnReader.java
in hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 221 12 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
ParquetDataColumnReaderFactory.java
in hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 219 34 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
ParquetDataColumnReaderFactory.java
in hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 219 34 2023-04-27 2023-04-27 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
ParquetDataColumnReaderFactory.java
in hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 219 34 2023-01-05 2023-01-05 1 1 stayrascal@users.noreply.gi... stayrascal@users.noreply.gi...
ParquetDataColumnReaderFactory.java
in hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 219 34 2023-11-09 2023-11-09 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
ParquetDataColumnReaderFactory.java
in hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 219 34 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
HoodieRetryWrapperFileSystem.java
in hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs
 216 34 2024-01-29 2024-01-29 1 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
RunLengthDecoder.java
in hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 216 9 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
RunLengthDecoder.java
in hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 216 9 2023-04-27 2023-04-27 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
RunLengthDecoder.java
in hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 216 9 2023-01-05 2023-01-05 1 1 stayrascal@users.noreply.gi... stayrascal@users.noreply.gi...
RunLengthDecoder.java
in hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 216 9 2023-11-09 2023-11-09 1 1 prabhujose.gates@gmail.com prabhujose.gates@gmail.com
RunLengthDecoder.java
in hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader
 216 9 2022-07-06 2022-07-06 1 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
HoodieSparkFunctionalIndex.java
in hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/functional
 190 6 2023-11-03 2023-11-03 1 1 sagarsumit09@gmail.com sagarsumit09@gmail.com
Spark24LegacyHoodieParquetFileFormat.scala
in hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/parquet
 186 1 2023-08-07 2023-08-07 1 1 jbvexler@gmail.com jbvexler@gmail.com
BucketAssigner.java
in hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner
 185 16 2022-03-21 2023-04-01 3 1 yuzhao.cyz@gmail.com yuzhao.cyz@gmail.com
IOUtils.java
in hudi-io/src/main/java/org/apache/hudi/io/util
 175 16 2024-01-18 2024-01-30 3 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
FileIOUtils.java
in hudi-io/src/main/java/org/apache/hudi/common/util
 175 16 2024-01-18 2024-01-31 3 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
Spark30NestedSchemaPruning.scala
in hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources
 166 11 2023-05-20 2023-05-20 1 1 69956021+zhangyue19921010@u... 69956021+zhangyue19921010@u...
StringUtils.java
in hudi-io/src/main/java/org/apache/hudi/common/util
 149 20 2024-01-29 2024-01-31 3 1 ethan.guoyihua@gmail.com ethan.guoyihua@gmail.com
Correlations

File Size vs. Number of Changes: 2461 points

hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java x: 266 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java x: 211 lines of code y: 27 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java x: 900 lines of code y: 55 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java x: 391 lines of code y: 28 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java x: 189 lines of code y: 14 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodiePayloadConfig.java x: 77 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java x: 2526 lines of code y: 212 # changes hudi-common/src/main/java/org/apache/hudi/common/model/DefaultHoodieRecordPayload.java x: 126 lines of code y: 16 # changes hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java x: 50 lines of code y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/model/RecordPayloadType.java x: 67 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableConfig.java x: 613 lines of code y: 82 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala x: 396 lines of code y: 39 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java x: 197 lines of code y: 14 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java x: 800 lines of code y: 32 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java x: 840 lines of code y: 86 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/HoodieJavaWriteClient.java x: 187 lines of code y: 30 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala x: 247 lines of code y: 42 # changes hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java x: 982 lines of code y: 72 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ErrorEvent.java x: 40 lines of code y: 3 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java x: 137 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java x: 557 lines of code y: 73 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java x: 1158 lines of code y: 34 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfigHolder.java x: 126 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala x: 153 lines of code y: 20 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala x: 15 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaUtils.java x: 322 lines of code y: 16 # changes hudi-common/src/main/java/org/apache/hudi/exception/HoodieAvroSchemaException.java x: 6 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala x: 870 lines of code y: 107 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java x: 105 lines of code y: 5 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java x: 34 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java x: 212 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/RecordLevelIndexSupport.scala x: 123 lines of code y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java x: 408 lines of code y: 44 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineDiffHelper.java x: 111 lines of code y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java x: 1115 lines of code y: 116 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/metadata/FlinkHoodieBackedTableMetadataWriter.java x: 131 lines of code y: 37 # changes hudi-cli/src/main/java/org/apache/hudi/cli/HoodieCLI.java x: 78 lines of code y: 15 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java x: 332 lines of code y: 18 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsConfig.java x: 154 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanActionExecutor.java x: 143 lines of code y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java x: 1039 lines of code y: 68 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java x: 264 lines of code y: 25 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/RemoteHoodieTableFileSystemView.java x: 547 lines of code y: 42 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java x: 54 lines of code y: 17 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java x: 536 lines of code y: 27 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java x: 124 lines of code y: 18 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DefaultSource.scala x: 301 lines of code y: 50 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java x: 969 lines of code y: 26 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java x: 551 lines of code y: 45 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/PreferWriterConflictResolutionStrategy.java x: 65 lines of code y: 3 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java x: 248 lines of code y: 29 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java x: 62 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java x: 447 lines of code y: 58 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java x: 299 lines of code y: 41 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java x: 371 lines of code y: 48 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java x: 541 lines of code y: 31 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadAppendPartitioner.java x: 12 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/model/FirstValueAvroPayload.java x: 45 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java x: 519 lines of code y: 56 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java x: 370 lines of code y: 64 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java x: 191 lines of code y: 34 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java x: 562 lines of code y: 100 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkCopyOnWriteTable.java x: 280 lines of code y: 46 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java x: 142 lines of code y: 27 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaCopyOnWriteTable.java x: 263 lines of code y: 34 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/BaseJavaCommitActionExecutor.java x: 238 lines of code y: 27 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java x: 241 lines of code y: 39 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java x: 107 lines of code y: 27 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BaseBootstrapMetadataHandler.java x: 56 lines of code y: 5 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java x: 303 lines of code y: 48 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java x: 212 lines of code y: 37 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadBucketIndexPartitioner.java x: 13 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/LSMTimelineWriter.java x: 230 lines of code y: 6 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java x: 318 lines of code y: 21 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java x: 516 lines of code y: 15 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java x: 809 lines of code y: 31 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieDeltaWriteStat.java x: 78 lines of code y: 7 # changes hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java x: 785 lines of code y: 27 # changes hudi-aws/src/main/java/org/apache/hudi/config/GlueCatalogSyncClientConfig.java x: 61 lines of code y: 4 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java x: 358 lines of code y: 49 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncClient.java x: 378 lines of code y: 15 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieMetaSyncOperations.java x: 86 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java x: 332 lines of code y: 52 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/KeyGenUtils.java x: 186 lines of code y: 23 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/factory/HoodieAvroKeyGeneratorFactory.java x: 70 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/factory/HoodieSparkKeyGeneratorFactory.java x: 125 lines of code y: 12 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala x: 190 lines of code y: 17 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala x: 140 lines of code y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/ClusteringPlanStrategy.java x: 105 lines of code y: 13 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkSizeBasedClusteringPlanStrategyRecently.java x: 89 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java x: 249 lines of code y: 32 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIndexUtils.java x: 190 lines of code y: 7 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystPlansUtils.scala x: 30 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalBloomFilter.java x: 128 lines of code y: 3 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperator.java x: 90 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileIndex.scala x: 373 lines of code y: 45 # changes scripts/pr_compliance.py x: 333 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/ScheduleCompactionActionExecutor.java x: 178 lines of code y: 17 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkUtil.java x: 103 lines of code y: 1 # changes hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkTestWriter.scala x: 71 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCreateHandle.java x: 177 lines of code y: 27 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGeneratorBase.java x: 82 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGenerators.java x: 26 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataWriteUtils.java x: 177 lines of code y: 12 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineUtils.java x: 338 lines of code y: 22 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/catalog/HoodieCatalogTable.scala x: 236 lines of code y: 29 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncClient.java x: 160 lines of code y: 11 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieArchivedTimeline.java x: 217 lines of code y: 38 # changes hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java x: 257 lines of code y: 10 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanActionExecutor.java x: 228 lines of code y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java x: 514 lines of code y: 79 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileReaderFactory.java x: 35 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderFactory.java x: 51 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileReaderFactory.java x: 104 lines of code y: 10 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSchemaUtils.scala x: 131 lines of code y: 6 # changes azure-pipelines-20230430.yml x: 329 lines of code y: 16 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/config/CloudSourceConfig.java x: 109 lines of code y: 10 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsHoodieIncrSource.java x: 111 lines of code y: 15 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java x: 130 lines of code y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelectorCommon.java x: 227 lines of code y: 11 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/gcs/GcsObjectMetadataFetcher.java x: 36 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaCompatibility.java x: 603 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/TableSchemaResolver.java x: 392 lines of code y: 41 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/convert/AvroInternalSchemaConverter.java x: 326 lines of code y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsM3Config.java x: 82 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporterFactory.java x: 72 lines of code y: 7 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporterType.java x: 4 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/HoodieSparkFunctionalIndexClient.java x: 105 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/util/collection/ExternalSpillableMap.java x: 242 lines of code y: 19 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/MetadataCommand.java x: 303 lines of code y: 17 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/RunIndexActionExecutor.java x: 250 lines of code y: 20 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ThreeToFourUpgradeHandler.java x: 28 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java x: 1273 lines of code y: 76 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieIndexer.java x: 267 lines of code y: 12 # changes hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java x: 976 lines of code y: 96 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewManager.java x: 172 lines of code y: 32 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java x: 365 lines of code y: 36 # changes hudi-common/src/main/java/org/apache/hudi/common/engine/HoodieReaderContext.java x: 65 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupRecordBuffer.java x: 32 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieKeyBasedFileGroupRecordBuffer.java x: 122 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodiePositionBasedFileGroupRecordBuffer.java x: 154 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieUnmergedFileGroupRecordBuffer.java x: 105 lines of code y: 1 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java x: 56 lines of code y: 2 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java x: 378 lines of code y: 16 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputFormat.java x: 707 lines of code y: 20 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/RowDataToAvroConverters.java x: 284 lines of code y: 5 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java x: 432 lines of code y: 35 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java x: 544 lines of code y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java x: 89 lines of code y: 15 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/KafkaOffsetPostProcessor.java x: 58 lines of code y: 7 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonKafkaSource.java x: 93 lines of code y: 30 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java x: 140 lines of code y: 23 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/AvroSchemaEvolutionUtils.java x: 98 lines of code y: 14 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala x: 758 lines of code y: 116 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieWriterUtils.scala x: 202 lines of code y: 31 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileWriterFactory.java x: 76 lines of code y: 3 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieInternalRowFileWriterFactory.java x: 58 lines of code y: 6 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowParquetWriteSupport.java x: 62 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieStorageConfig.java x: 330 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableCommand.scala x: 180 lines of code y: 15 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HadoopFSUtils.java x: 100 lines of code y: 3 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/storage/hadoop/HoodieHadoopStorage.java x: 144 lines of code y: 4 # changes hudi-io/src/main/java/org/apache/hudi/storage/StoragePathInfo.java x: 81 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/HoodiePartitionTTLStrategyFactory.java x: 51 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByCreationTimeStrategy.java x: 27 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByTimeStrategy.java x: 65 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java x: 35 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/TTLStrategy.java x: 3 lines of code y: 1 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDWriteClient.java x: 262 lines of code y: 77 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstantTimeGenerator.java x: 114 lines of code y: 18 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HoodieProcedures.scala x: 75 lines of code y: 33 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunTTLProcedure.scala x: 62 lines of code y: 1 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java x: 281 lines of code y: 22 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadTableInputFormat.java x: 305 lines of code y: 14 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieInputFormatUtils.java x: 349 lines of code y: 41 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelation.scala x: 201 lines of code y: 33 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HiveAvroSerializer.java x: 324 lines of code y: 8 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeRecordReaderUtils.java x: 245 lines of code y: 20 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieMultiTableStreamer.java x: 383 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java x: 28 lines of code y: 143 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroKafkaSource.java x: 104 lines of code y: 30 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/KafkaSource.java x: 71 lines of code y: 11 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ProtoKafkaSource.java x: 84 lines of code y: 11 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java x: 55 lines of code y: 17 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/DefaultStreamContext.java x: 19 lines of code y: 2 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java x: 742 lines of code y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/Key.java x: 72 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/util/queue/BaseHoodieQueueBasedExecutor.java x: 126 lines of code y: 7 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudDataFetcher.java x: 34 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieOptionConfig.scala x: 194 lines of code y: 17 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncConfig.java x: 242 lines of code y: 22 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTableFileSystemView.java x: 295 lines of code y: 23 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HiveQueryDDLExecutor.java x: 121 lines of code y: 12 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBaseRelation.scala x: 532 lines of code y: 49 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieHadoopFsRelationFactory.scala x: 297 lines of code y: 10 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/ExportCommand.java x: 186 lines of code y: 16 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HeartbeatUtils.java x: 49 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HoodieHeartbeatClient.java x: 195 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/FileSystemBasedLockProvider.java x: 173 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/functional/BaseHoodieFunctionalIndexClient.java x: 26 lines of code y: 4 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkMetadataWriterUtils.java x: 201 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/conflict/detection/DirectMarkerBasedDetectionStrategy.java x: 68 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/metadata/AbstractHoodieTableMetadata.java x: 64 lines of code y: 4 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java x: 156 lines of code y: 19 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java x: 244 lines of code y: 12 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java x: 192 lines of code y: 10 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FilePathUtils.java x: 314 lines of code y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClientIds.java x: 174 lines of code y: 7 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ViewStorageProperties.java x: 54 lines of code y: 9 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFSUtils.java x: 47 lines of code y: 2 # changes hudi-io/src/main/java/org/apache/hudi/storage/HoodieStorage.java x: 143 lines of code y: 3 # changes hudi-io/src/main/java/org/apache/hudi/storage/StoragePath.java x: 222 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ExportInstantsProcedure.scala x: 177 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieSpark32PlusAnalysis.scala x: 256 lines of code y: 11 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerBasedEarlyConflictDetectionRunnable.java x: 87 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SparkSampleWritesUtils.java x: 130 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java x: 584 lines of code y: 15 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieNativeAvroHFileReader.java x: 459 lines of code y: 3 # changes hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileReaderImpl.java x: 233 lines of code y: 3 # changes hudi-common/src/main/avro/HoodieCleanerPlan.avsc x: 119 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/versioning/clean/CleanPlanV1MigrationHandler.java x: 39 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CleanerUtils.java x: 148 lines of code y: 19 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java x: 194 lines of code y: 30 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieParquetDataBlock.java x: 143 lines of code y: 16 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFileSystem.java x: 86 lines of code y: 1 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFsDataInputStream.java x: 92 lines of code y: 1 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/HoodieCompactor.java x: 186 lines of code y: 19 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieWriteStat.java x: 251 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java x: 184 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/CompletionTimeQueryView.java x: 183 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataLogRecordReader.java x: 166 lines of code y: 9 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClusteringUtil.java x: 64 lines of code y: 9 # changes hudi-io/src/main/java/org/apache/hudi/common/util/Option.java x: 115 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCRelation.scala x: 147 lines of code y: 7 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java x: 245 lines of code y: 28 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalFilter.java x: 72 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java x: 150 lines of code y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java x: 280 lines of code y: 7 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java x: 302 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java x: 143 lines of code y: 34 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java x: 326 lines of code y: 5 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java x: 161 lines of code y: 41 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/SparkMetadataTableRecordIndex.java x: 120 lines of code y: 3 # changes hudi-common/src/main/avro/HoodieMetadata.avsc x: 436 lines of code y: 10 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroHFileWriter.java x: 152 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHBaseAvroHFileReader.java x: 517 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java x: 314 lines of code y: 32 # changes hudi-common/src/main/java/org/apache/hudi/metadata/FileSystemBackedTableMetadata.java x: 221 lines of code y: 29 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java x: 597 lines of code y: 66 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/FunctionalIndexSupport.scala x: 140 lines of code y: 2 # changes hudi-aws/src/main/java/org/apache/hudi/config/HoodieAWSConfig.java x: 139 lines of code y: 7 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/PartitionFilterGenerator.java x: 166 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecord.java x: 269 lines of code y: 28 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFileReader.java x: 376 lines of code y: 46 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java x: 257 lines of code y: 28 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCDCDataBlock.java x: 31 lines of code y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCommandBlock.java x: 33 lines of code y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCorruptBlock.java x: 24 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDataBlock.java x: 288 lines of code y: 19 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDeleteBlock.java x: 158 lines of code y: 14 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieLogBlock.java x: 203 lines of code y: 24 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HadoopSeekableDataInputStream.java x: 19 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordReader.java x: 249 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieBaseFileGroupRecordBuffer.java x: 214 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupReader.java x: 264 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/common/util/HoodieRecordSizeEstimator.java x: 18 lines of code y: 12 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala x: 343 lines of code y: 14 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/CompactionCommand.java x: 592 lines of code y: 37 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieFunctionalIndexConfig.java x: 220 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePartitionMetadata.java x: 172 lines of code y: 17 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java x: 583 lines of code y: 68 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ConfigUtils.java x: 356 lines of code y: 11 # changes hudi-common/src/main/java/org/apache/hudi/common/util/InternalSchemaCache.java x: 150 lines of code y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/util/MarkerUtils.java x: 187 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/io/FileBasedInternalSchemaStorageManager.java x: 155 lines of code y: 9 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieWrapperFileSystem.java x: 865 lines of code y: 2 # changes hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java x: 175 lines of code y: 3 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/ManifestFileWriter.java x: 98 lines of code y: 8 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerDirState.java x: 251 lines of code y: 10 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactionAdminTool.java x: 124 lines of code y: 14 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/perf/TimelineServerPerf.java x: 269 lines of code y: 27 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/FilebasedSchemaProvider.java x: 68 lines of code y: 17 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JdbcSource.java x: 198 lines of code y: 6 # changes hudi-io/src/main/java/org/apache/hudi/common/util/ComparableVersion.java x: 252 lines of code y: 1 # changes hudi-io/src/main/java/org/apache/hudi/common/util/StringUtils.java x: 149 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java x: 422 lines of code y: 32 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieReplaceCommitMetadata.java x: 96 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/model/debezium/PostgresDebeziumAvroPayload.java x: 74 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/util/Base64CodecUtil.java x: 16 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/util/hash/HashID.java x: 76 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroHFileReaderImplBase.java x: 97 lines of code y: 2 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/InputSplitUtils.java x: 24 lines of code y: 5 # changes hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileUtils.java x: 57 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/HDFSParquetImporterUtils.java x: 251 lines of code y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieReadHandle.java x: 48 lines of code y: 7 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieMergeHelper.java x: 165 lines of code y: 20 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaExecutionStrategy.java x: 162 lines of code y: 14 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java x: 358 lines of code y: 41 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SingleSparkJobExecutionStrategy.java x: 117 lines of code y: 12 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/ParquetBootstrapMetadataHandler.java x: 99 lines of code y: 10 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/HoodieDynamicBoundedBloomFilter.java x: 69 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/SimpleBloomFilter.java x: 93 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieReaderConfig.java x: 46 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileWriterFactory.java x: 88 lines of code y: 5 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java x: 303 lines of code y: 26 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHFileRecordReader.java x: 79 lines of code y: 4 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSHoodieDatasetInputReader.java x: 295 lines of code y: 27 # changes hudi-common/src/main/java/org/apache/hudi/common/util/BaseFileUtils.java x: 93 lines of code y: 11 # changes hudi-common/src/main/java/org/apache/hudi/common/util/OrcUtils.java x: 219 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ParquetUtils.java x: 365 lines of code y: 30 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/ArchivedCommitsCommand.java x: 208 lines of code y: 20 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java x: 252 lines of code y: 36 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkMain.java x: 589 lines of code y: 67 # changes hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkUtil.java x: 77 lines of code y: 22 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineService.java x: 228 lines of code y: 24 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/Metrics.java x: 134 lines of code y: 13 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/ListingBasedRollbackStrategy.java x: 223 lines of code y: 15 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/DirectWriteMarkers.java x: 148 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/SimpleDirectMarkerBasedDetectionStrategy.java x: 52 lines of code y: 3 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java x: 84 lines of code y: 6 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkPartitionUtils.java x: 30 lines of code y: 2 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowCreateHandle.java x: 197 lines of code y: 16 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java x: 250 lines of code y: 31 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/BaseSparkInternalRowReaderContext.java x: 104 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/BaseHoodieTableFileIndex.java x: 356 lines of code y: 27 # changes hudi-common/src/main/java/org/apache/hudi/common/fs/OptimisticConsistencyGuard.java x: 41 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/model/BaseFile.java x: 80 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieBaseFile.java x: 116 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieLogFile.java x: 195 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java x: 699 lines of code y: 37 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/BaseHoodieLogRecordReader.java x: 592 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/dto/FilePathDTO.java x: 30 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTablePreCommitFileSystemView.java x: 41 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroOrcWriter.java x: 125 lines of code y: 3 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/schema/FilebasedSchemaProvider.java x: 70 lines of code y: 4 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java x: 238 lines of code y: 15 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputFormat.java x: 607 lines of code y: 11 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cow/CopyOnWriteInputFormat.java x: 285 lines of code y: 11 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/ConsistencyGuard.java x: 29 lines of code y: 1 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieRetryWrapperFileSystem.java x: 216 lines of code y: 1 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieSerializableFileStatus.java x: 97 lines of code y: 1 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/SerializablePath.java x: 39 lines of code y: 1 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/TimedFSDataInputStream.java x: 47 lines of code y: 1 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadSnapshotReader.java x: 168 lines of code y: 4 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java x: 172 lines of code y: 40 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeSplit.java x: 76 lines of code y: 10 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java x: 104 lines of code y: 25 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteJob.java x: 262 lines of code y: 26 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/ValidateAsyncOperations.java x: 83 lines of code y: 9 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/DeltaGenerator.java x: 276 lines of code y: 20 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSDeltaInputReader.java x: 61 lines of code y: 3 # changes hudi-io/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java x: 124 lines of code y: 1 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java x: 127 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/FileSystemRelation.scala x: 88 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/Iterators.scala x: 327 lines of code y: 12 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/HoodieMultipleBaseFileFormat.scala x: 217 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala x: 253 lines of code y: 22 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DedupeSparkJob.scala x: 167 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunBootstrapProcedure.scala x: 116 lines of code y: 14 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowColumnStatsOverlapProcedure.scala x: 234 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowFileSystemViewProcedure.scala x: 228 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowFsPathDetailProcedure.scala x: 85 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowHoodieLogFileMetadataProcedure.scala x: 114 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/StatsFileSizeProcedure.scala x: 97 lines of code y: 6 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HMSDDLExecutor.java x: 250 lines of code y: 14 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/QueryBasedDDLExecutor.java x: 174 lines of code y: 9 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java x: 224 lines of code y: 33 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java x: 245 lines of code y: 36 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieRepairTool.java x: 338 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotExporter.java x: 238 lines of code y: 32 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HiveIncrPullSource.java x: 84 lines of code y: 16 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DFSPathSelector.java x: 109 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/SpillableMapBasedFileSystemView.java x: 198 lines of code y: 17 # changes hudi-common/src/main/java/org/apache/hudi/common/util/collection/BitCaskDiskMap.java x: 333 lines of code y: 13 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java x: 94 lines of code y: 20 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringPlanOperator.java x: 98 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/ChainedTransformer.java x: 140 lines of code y: 10 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/ErrorTableAwareChainedTransformer.java x: 36 lines of code y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieErrorTableConfig.java x: 71 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/LegacyArchivedMetaEntryReader.java x: 237 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java x: 85 lines of code y: 17 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionPredicates.java x: 396 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/plan/generators/HoodieLogCompactionPlanGenerator.java x: 76 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java x: 327 lines of code y: 39 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java x: 135 lines of code y: 20 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkConsistentBucketClusteringExecutionStrategy.java x: 74 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/ConsistentBucketIndexBulkInsertPartitionerWithRows.java x: 131 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala x: 285 lines of code y: 13 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ExpressionUtils.java x: 241 lines of code y: 4 # changes hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 524 lines of code y: 11 # changes hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 524 lines of code y: 10 # changes hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 524 lines of code y: 9 # changes hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 524 lines of code y: 4 # changes hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java x: 262 lines of code y: 4 # changes hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java x: 262 lines of code y: 3 # changes hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java x: 262 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/execution/datasources/Spark3ParsePartitionUtil.scala x: 190 lines of code y: 5 # changes hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileBlockType.java x: 57 lines of code y: 1 # changes hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileTrailer.java x: 122 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala x: 236 lines of code y: 12 # changes hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/adapter/Utils.java x: 44 lines of code y: 5 # changes hudi-flink-datasource/hudi-flink1.15.x/src/main/java/org/apache/hudi/adapter/Utils.java x: 45 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileWriterFactory.java x: 102 lines of code y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/FourToFiveUpgradeHandler.java x: 61 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatWriter.java x: 192 lines of code y: 20 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/SerDeHelper.java x: 271 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieBootstrapRecordIterator.java x: 54 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/utils/TransactionUtils.java x: 99 lines of code y: 13 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/savepoint/SavepointActionExecutor.java x: 109 lines of code y: 16 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkTableServiceClient.java x: 174 lines of code y: 14 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaBulkInsertHelper.java x: 88 lines of code y: 13 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBulkInsertHelper.java x: 84 lines of code y: 14 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkInsertOverwriteCommitActionExecutor.java x: 81 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieConfig.java x: 190 lines of code y: 27 # changes hudi-common/src/main/java/org/apache/hudi/index/secondary/SecondaryIndexManager.java x: 124 lines of code y: 2 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java x: 249 lines of code y: 13 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/utils/KafkaConnectUtils.java x: 176 lines of code y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/JsonToAvroSchemaConverter.java x: 203 lines of code y: 2 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java x: 174 lines of code y: 17 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/util/ExecutorFactory.java x: 51 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java x: 167 lines of code y: 15 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitSink.java x: 157 lines of code y: 11 # changes doap_HUDI.rdf x: 142 lines of code y: 26 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/ZookeeperBasedLockProvider.java x: 166 lines of code y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/HoodieFlinkStreamer.java x: 88 lines of code y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java x: 156 lines of code y: 16 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/TimelineRelation.scala x: 76 lines of code y: 1 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java x: 130 lines of code y: 17 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieConversionUtils.scala x: 24 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/LegacyHoodieParquetFileFormat.scala x: 34 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark33LegacyHoodieParquetFileFormat.scala x: 389 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark34LegacyHoodieParquetFileFormat.scala x: 399 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark35LegacyHoodieParquetFileFormat.scala x: 401 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/InsertIntoHoodieTableCommand.scala x: 117 lines of code y: 37 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/HoodieTimelineArchiver.java x: 233 lines of code y: 7 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java x: 102 lines of code y: 29 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HoodieIncrSource.java x: 147 lines of code y: 34 # changes hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java x: 196 lines of code y: 2 # changes hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/AdbSyncTool.java x: 204 lines of code y: 7 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/SparkAdapter.scala x: 78 lines of code y: 39 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/adapter/Spark2Adapter.scala x: 138 lines of code y: 38 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_5Adapter.scala x: 83 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala x: 383 lines of code y: 50 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/HoodieSpark2CatalystPlanUtils.scala x: 84 lines of code y: 13 # changes hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/HoodieSpark3CatalystPlanUtils.scala x: 60 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/HoodieSpark30CatalystPlanUtils.scala x: 49 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/HoodieSpark31CatalystPlanUtils.scala x: 50 lines of code y: 10 # changes hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/HoodieSpark34CatalystPlanUtils.scala x: 87 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/catalog/HoodieCatalog.scala x: 348 lines of code y: 5 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BulkInsertDataInternalWriterHelper.java x: 164 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/kafka/HoodieWriteCommitKafkaCallback.java x: 88 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/BootstrapExecutorUtils.java x: 258 lines of code y: 12 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/bloom/SparkHoodieBloomIndexHelper.java x: 190 lines of code y: 10 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/common/model/HoodieSparkRecord.java x: 333 lines of code y: 8 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieInternalRowUtils.scala x: 323 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableLikeCommand.scala x: 74 lines of code y: 2 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java x: 129 lines of code y: 20 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodiePartitionCDCFileGroupMapping.scala x: 11 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCFileGroupIterator.scala x: 415 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/ActiveAction.java x: 132 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/MetadataConversionUtils.java x: 227 lines of code y: 3 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/MarkerHandler.java x: 196 lines of code y: 9 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/DeleteMetadataTableProcedure.scala x: 46 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsSource.java x: 132 lines of code y: 11 # changes hudi-examples/hudi-examples-dbt/dbt_project.yml x: 16 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/HoodieMetrics.java x: 341 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/RocksDbBasedFileSystemView.java x: 484 lines of code y: 24 # changes hudi-common/src/main/java/org/apache/hudi/common/util/RocksDBSchemaHelper.java x: 101 lines of code y: 9 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java x: 58 lines of code y: 16 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineServerHelper.java x: 25 lines of code y: 10 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/BaseFileHandler.java x: 55 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java x: 95 lines of code y: 12 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/UpgradeOrDowngradeProcedure.scala x: 79 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala x: 299 lines of code y: 27 # changes hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySyncConfig.java x: 144 lines of code y: 11 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/CompactionUtil.java x: 97 lines of code y: 9 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelector.java x: 193 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala x: 106 lines of code y: 24 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieBucketIndex.java x: 64 lines of code y: 10 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieSimpleBucketIndex.java x: 68 lines of code y: 6 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudStoreIngestionConfig.java x: 29 lines of code y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadOperator.java x: 186 lines of code y: 3 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/append/AppendWriteFunction.java x: 105 lines of code y: 7 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/HoodieFlinkClusteringJob.java x: 231 lines of code y: 16 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java x: 209 lines of code y: 17 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java x: 314 lines of code y: 31 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/SparkAdapterSupport.scala x: 26 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/DataFrameUtil.scala x: 14 lines of code y: 3 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystExpressionUtils.scala x: 143 lines of code y: 10 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieSchemaUtils.scala x: 9 lines of code y: 2 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieUnsafeUtils.scala x: 38 lines of code y: 6 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/BaseValidateDatasetNode.java x: 182 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodiePathCommand.scala x: 32 lines of code y: 10 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodieTableCommand.scala x: 21 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionShowHoodieTableCommand.scala x: 18 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/adapter/BaseSpark3Adapter.scala x: 63 lines of code y: 25 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark32LegacyHoodieParquetFileFormat.scala x: 383 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/antlr4/imports/SqlBase.g4 x: 1760 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 375 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 324 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroUtils.scala x: 128 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark35NestedSchemaPruning.scala x: 116 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_5ExtendedSqlAstBuilder.scala x: 2354 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_5ExtendedSqlParser.scala x: 140 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunCompactionProcedure.scala x: 122 lines of code y: 13 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableAddColumnsCommand.scala x: 105 lines of code y: 12 # changes hudi-aws/src/main/java/org/apache/hudi/aws/credentials/HoodieAWSCredentialsProviderFactory.java x: 30 lines of code y: 3 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/HadoopConfigurations.java x: 31 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCExtractor.java x: 246 lines of code y: 15 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java x: 134 lines of code y: 21 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoHoodieTableCommand.scala x: 474 lines of code y: 58 # changes hudi-common/src/main/java/org/apache/hudi/common/model/WriteOperationType.java x: 107 lines of code y: 21 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/SchemaChangeUtils.java x: 217 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/CopyToTableProcedure.scala x: 95 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/model/FileSlice.java x: 102 lines of code y: 11 # changes hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java x: 366 lines of code y: 1 # changes style/scalastyle.xml x: 114 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieDataSourceHelper.scala x: 99 lines of code y: 15 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/ComplexAvroKeyGenerator.java x: 28 lines of code y: 11 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/BuiltinKeyGenerator.java x: 334 lines of code y: 14 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecordLocation.java x: 80 lines of code y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/BucketIdentifier.java x: 82 lines of code y: 11 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/SparkBucketIndexPartitioner.java x: 108 lines of code y: 6 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketBulkInsertWriterHelper.java x: 78 lines of code y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bucket/BucketStreamWriteFunction.java x: 107 lines of code y: 14 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java x: 213 lines of code y: 19 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java x: 515 lines of code y: 44 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/HiveSyncContext.java x: 93 lines of code y: 14 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunClusteringProcedure.scala x: 187 lines of code y: 21 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/functional/HoodieSparkFunctionalIndex.java x: 190 lines of code y: 1 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieBackedTableMetadataWriter.java x: 163 lines of code y: 37 # changes hudi-common/src/main/java/org/apache/hudi/common/config/ConfigGroups.java x: 131 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMetadataConfig.java x: 547 lines of code y: 54 # changes hudi-common/src/main/java/org/apache/hudi/metadata/MetadataPartitionType.java x: 32 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark/src/main/antlr4/org/apache/hudi/spark/sql/parser/HoodieSqlCommon.g4 x: 239 lines of code y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/CompactionCommitSink.java x: 119 lines of code y: 10 # changes hudi-aws/src/main/java/org/apache/hudi/config/DynamoDbBasedLockConfig.java x: 122 lines of code y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLockConfig.java x: 282 lines of code y: 21 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/WaitBasedTimeGenerator.java x: 43 lines of code y: 2 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkSortAndSizeExecutionStrategy.java x: 64 lines of code y: 20 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieCleanConfig.java x: 250 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkers.java x: 83 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndex.java x: 204 lines of code y: 18 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/antlr4/imports/SqlBase.g4 x: 1760 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_2ExtendedSqlAstBuilder.scala x: 2345 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_2ExtendedSqlParser.scala x: 139 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_3ExtendedSqlAstBuilder.scala x: 2351 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_4ExtendedSqlAstBuilder.scala x: 2353 lines of code y: 2 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/SanitizationUtils.java x: 140 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/BaseConsistentHashingBucketClusteringPlanStrategy.java x: 223 lines of code y: 4 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowDataCreateHandle.java x: 158 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileFormat.java x: 43 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala x: 100 lines of code y: 28 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark32NestedSchemaPruning.scala x: 117 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala x: 353 lines of code y: 23 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseWriteHelper.java x: 58 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/internal/DataSourceInternalWriterHelper.java x: 81 lines of code y: 14 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java x: 367 lines of code y: 96 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriteFunction.java x: 110 lines of code y: 7 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/SparkLazyInsertIterable.java x: 60 lines of code y: 15 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/execution/RangeSample.scala x: 433 lines of code y: 6 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java x: 335 lines of code y: 12 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java x: 172 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala x: 439 lines of code y: 19 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/CopyOnWriteRestoreActionExecutor.java x: 40 lines of code y: 8 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkTable.java x: 83 lines of code y: 26 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstant.java x: 256 lines of code y: 23 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkWriteClients.java x: 167 lines of code y: 14 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java x: 173 lines of code y: 5 # changes hudi-platform-service/hudi-metaserver/hudi-metaserver-client/src/main/java/org/apache/hudi/common/table/HoodieTableMetaserverClient.java x: 110 lines of code y: 5 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieStreamSource.scala x: 142 lines of code y: 13 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowCommitsProcedure.scala x: 120 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi/command/Spark30AlterTableCommand.scala x: 258 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/hudi/command/Spark31AlterTableCommand.scala x: 258 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterTableCommand.scala x: 278 lines of code y: 9 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java x: 170 lines of code y: 27 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/execution/HoodieLazyInsertIterable.java x: 78 lines of code y: 10 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java x: 165 lines of code y: 37 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/FileSystemViewCommand.java x: 216 lines of code y: 20 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/CompactionAdminClient.java x: 247 lines of code y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/MarkerBasedRollbackStrategy.java x: 61 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/deltacommit/SparkUpsertDeltaCommitPartitioner.java x: 97 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java x: 139 lines of code y: 16 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormat.java x: 198 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java x: 316 lines of code y: 20 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/ListBasedHoodieBloomIndexHelper.java x: 54 lines of code y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLookupHandle.java x: 72 lines of code y: 10 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/multitable/HoodieMultiTableServicesMain.java x: 197 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/CustomAvroKeyGenerator.java x: 89 lines of code y: 11 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieInternalConfig.java x: 29 lines of code y: 7 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java x: 145 lines of code y: 12 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java x: 273 lines of code y: 34 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/CleansCommand.java x: 122 lines of code y: 17 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieIndexConfig.java x: 528 lines of code y: 35 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java x: 309 lines of code y: 34 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataWriter.java x: 26 lines of code y: 12 # changes hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/BigQuerySchemaResolver.java x: 148 lines of code y: 2 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/InternalSchema.java x: 179 lines of code y: 5 # changes hudi-common/src/main/avro/HoodieCommitMetadata.avsc x: 192 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/avro/JsonEncoder.java x: 230 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineMetadataUtils.java x: 168 lines of code y: 17 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/BootstrapExecutor.java x: 165 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieBootstrapConfig.java x: 166 lines of code y: 16 # changes hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/bootstrap/SparkParquetBootstrapDataProvider.java x: 13 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/HashFunction.java x: 38 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIdentifier.java x: 125 lines of code y: 4 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkInternalSchemaConverter.java x: 396 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/avro/MercifulJsonConverter.java x: 295 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/util/AvroOrcUtils.java x: 703 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/util/BinaryUtil.java x: 144 lines of code y: 5 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/ProtoConversionUtil.java x: 400 lines of code y: 9 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala x: 162 lines of code y: 17 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/hudi/Spark32ResolveHudiAlterTableCommand.scala x: 44 lines of code y: 3 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java x: 73 lines of code y: 18 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/common/JavaTaskContextSupplier.java x: 27 lines of code y: 3 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/SixToFiveDowngradeHandler.java x: 76 lines of code y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RollbackUtils.java x: 52 lines of code y: 20 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/SchemaEvolutionContext.java x: 299 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieCreateRecordUtils.scala x: 216 lines of code y: 6 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/RecordIterators.java x: 112 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataMetrics.java x: 109 lines of code y: 11 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieArchivalConfig.java x: 135 lines of code y: 7 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderBase.java x: 20 lines of code y: 3 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/AvroConvertor.java x: 128 lines of code y: 19 # changes hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/DataSourceUtils.java x: 231 lines of code y: 40 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieStreamingSink.scala x: 275 lines of code y: 16 # changes hudi-cli/src/main/java/org/apache/hudi/cli/HoodieTableHeaderFields.java x: 143 lines of code y: 15 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/TimelineCommand.java x: 346 lines of code y: 5 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieROTablePathFilter.java x: 173 lines of code y: 31 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableAsSelectCommand.scala x: 88 lines of code y: 21 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDConsistentBucketBulkInsertPartitioner.java x: 108 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark2/src/main/java/org/apache/hudi/internal/HoodieBulkInsertDataInternalWriter.java x: 43 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/parser/HoodieDateTimeParser.java x: 84 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HiveIncrPullSourceConfig.java x: 22 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/ProtoClassBasedSchemaProvider.java x: 67 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/CsvDFSSource.java x: 72 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/PulsarSource.java x: 199 lines of code y: 5 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DatePartitionPathSelector.java x: 149 lines of code y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/SqlQueryBasedTransformer.java x: 38 lines of code y: 12 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaUpsertPartitioner.java x: 246 lines of code y: 9 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDTableServiceClient.java x: 51 lines of code y: 10 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark24LegacyHoodieParquetFileFormat.scala x: 186 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark30LegacyHoodieParquetFileFormat.scala x: 319 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_1Adapter.scala x: 77 lines of code y: 16 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/SyncUtilHelpers.java x: 102 lines of code y: 12 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java x: 222 lines of code y: 7 # changes hudi-aws/src/main/java/org/apache/hudi/aws/cloudwatch/CloudWatchReporter.java x: 251 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 315 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 360 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 364 lines of code y: 8 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 377 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 375 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 375 lines of code y: 2 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/FlinkClusteringConfig.java x: 138 lines of code y: 11 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionEvaluators.java x: 412 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/expression/BindVisitor.java x: 135 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/expression/Predicates.java x: 311 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/Types.java x: 569 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/DeleteHoodieTableCommand.scala x: 45 lines of code y: 24 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/TypeConverters.java x: 304 lines of code y: 1 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/RollbacksCommand.java x: 122 lines of code y: 18 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/catalyst/analysis/HoodieSpark30Analysis.scala x: 121 lines of code y: 2 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/HDFSParquetImportCommand.java x: 59 lines of code y: 14 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkConfigs.scala x: 5 lines of code y: 3 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java x: 36 lines of code y: 89 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamerMetrics.java x: 9 lines of code y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieMultiTableDeltaStreamer.java x: 13 lines of code y: 29 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/PostWriteTerminationStrategy.java x: 4 lines of code y: 2 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/NullTargetSchemaRegistryProvider.java x: 13 lines of code y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndex.java x: 121 lines of code y: 15 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkDeleteHelper.java x: 92 lines of code y: 10 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaDeleteHelper.java x: 94 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/CopyOnWriteRollbackActionExecutor.java x: 53 lines of code y: 8 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkMergeOnReadTable.java x: 125 lines of code y: 17 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/SparkSizeBasedClusteringPlanStrategy.java x: 46 lines of code y: 12 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimeFileSplit.java x: 90 lines of code y: 14 # changes hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/service/TableService.java x: 50 lines of code y: 3 # changes hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/resources/mybatis/DDLMapper.xml x: 102 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CollectionUtils.java x: 173 lines of code y: 22 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/common/HoodieFlinkEngineContext.java x: 157 lines of code y: 17 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/common/HoodieJavaEngineContext.java x: 123 lines of code y: 11 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/common/HoodieSparkEngineContext.java x: 188 lines of code y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/engine/EngineProperty.java x: 10 lines of code y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/WriteStatus.java x: 178 lines of code y: 9 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/index/FlinkHoodieIndexFactory.java x: 45 lines of code y: 6 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieMetadataBulkInsertPartitioner.java x: 63 lines of code y: 2 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/validator/SparkPreCommitValidator.java x: 86 lines of code y: 7 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/Transformer.java x: 21 lines of code y: 9 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java x: 158 lines of code y: 6 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/FlinkWriteHelper.java x: 77 lines of code y: 15 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/compact/HoodieFlinkMergeOnReadTableCompactor.java x: 30 lines of code y: 10 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java x: 116 lines of code y: 30 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/HiveSchemaUtil.java x: 390 lines of code y: 11 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieRealtimeRecordReader.java x: 70 lines of code y: 12 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/bulkinsert/RDDCustomColumnsSortPartitioner.java x: 47 lines of code y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/RowBasedSchemaProvider.java x: 22 lines of code y: 6 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieHiveUtils.java x: 112 lines of code y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/avro/SchemaConverters.scala x: 155 lines of code y: 3 # changes hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/HoodieAdbJdbcClient.java x: 413 lines of code y: 3 # changes hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java x: 161 lines of code y: 6 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 296 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 331 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 327 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 297 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark30NestedSchemaPruning.scala x: 166 lines of code y: 1 # changes hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi/Spark30ResolveHudiAlterTableCommand.scala x: 236 lines of code y: 1 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/execution/FlinkLazyInsertIterable.java x: 51 lines of code y: 11 # changes hudi-common/src/main/java/org/apache/hudi/common/util/queue/DisruptorMessageQueue.java x: 113 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/common/util/queue/HoodieMessageQueue.java x: 14 lines of code y: 4 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java x: 572 lines of code y: 9 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RollbackToSavepointProcedure.scala x: 63 lines of code y: 7 # changes docker/compose/docker-compose_hadoop284_hive233_spark244.yml x: 287 lines of code y: 7 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ValidateHoodieSyncProcedure.scala x: 153 lines of code y: 4 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieParquetRealtimeInputFormat.java x: 77 lines of code y: 37 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/NonpartitionedAvroKeyGenerator.java x: 31 lines of code y: 12 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/GlobalDeleteKeyGenerator.java x: 47 lines of code y: 11 # changes hudi-common/src/main/java/org/apache/hudi/keygen/BaseKeyGenerator.java x: 43 lines of code y: 10 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroIndexedRecord.java x: 175 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroRecord.java x: 172 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/util/SpillableMapUtils.java x: 110 lines of code y: 18 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/HoodiePipeline.java x: 181 lines of code y: 6 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineHiveInputFormat.java x: 732 lines of code y: 20 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieMultiWriterTestSuiteJob.java x: 157 lines of code y: 5 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/configuration/DeltaConfig.java x: 388 lines of code y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCUtils.java x: 91 lines of code y: 7 # changes hudi-common/src/main/resources/hbase-site.xml x: 2077 lines of code y: 6 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetRowDataWriter.java x: 462 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewStorageConfig.java x: 349 lines of code y: 28 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/InternalSchemaBuilder.java x: 191 lines of code y: 3 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/action/TableChanges.java x: 285 lines of code y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieHBaseIndexConfig.java x: 364 lines of code y: 16 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteCommitCallbackConfig.java x: 109 lines of code y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsPrometheusConfig.java x: 140 lines of code y: 4 # changes hudi-common/src/main/java/org/apache/hudi/common/fs/ConsistencyGuardConfig.java x: 145 lines of code y: 9 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectConfigs.java x: 184 lines of code y: 12 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/callback/pulsar/HoodieWriteCommitPulsarCallbackConfig.java x: 92 lines of code y: 3 # changes hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkTempViewProvider.java x: 109 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/bootstrap/FullRecordBootstrapDataProvider.java x: 21 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/datadog/DatadogReporter.java x: 127 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/BaseRestoreActionExecutor.java x: 117 lines of code y: 16 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkCreateHandle.java x: 108 lines of code y: 19 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeAndReplaceHandle.java x: 134 lines of code y: 10 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeHandle.java x: 141 lines of code y: 20 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/sort/SpaceCurveSortingHelper.java x: 206 lines of code y: 3 # changes hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkUpsertNode.scala x: 17 lines of code y: 9 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionCoordinator.java x: 347 lines of code y: 6 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionParticipant.java x: 221 lines of code y: 5 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/BufferedConnectWriter.java x: 92 lines of code y: 6 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/transaction/lock/HiveMetastoreBasedLockProvider.java x: 188 lines of code y: 4 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java x: 280 lines of code y: 18 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java x: 343 lines of code y: 32 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/compact/HoodieSparkMergeOnReadTableCompactor.java x: 32 lines of code y: 17 # changes hudi-common/src/main/java/org/apache/hudi/common/data/HoodieData.java x: 61 lines of code y: 10 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HiveSchemaUtils.java x: 171 lines of code y: 8 # changes hudi-common/src/main/java/org/apache/hudi/common/data/HoodieListPairData.java x: 145 lines of code y: 2 # changes hudi-platform-service/hudi-metaserver/hudi-metaserver-server/src/main/java/org/apache/hudi/metaserver/store/bean/TableBean.java x: 92 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/HoodieSparkSessionExtension.scala x: 23 lines of code y: 8 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieSortedMergeHandle.java x: 81 lines of code y: 18 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/WriteHandleFactory.java x: 14 lines of code y: 5 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/JmxReporterServer.java x: 112 lines of code y: 2 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieReadClient.java x: 20 lines of code y: 10 # changes hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/QuickstartUtils.java x: 185 lines of code y: 9 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/SavepointsCommand.java x: 125 lines of code y: 25 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/StatsCommand.java x: 129 lines of code y: 14 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/util/WriteStatMerger.java x: 111 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/common/model/ActionType.java x: 4 lines of code y: 5 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/MiniBatchHandle.java x: 8 lines of code y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ObjectSizeCalculator.java x: 7 lines of code y: 14 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkEnvCommand.java x: 38 lines of code y: 9 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark31NestedSchemaPruning.scala x: 116 lines of code y: 3 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/hudi/Spark31ResolveHudiAlterTableCommand.scala x: 224 lines of code y: 1 # changes hudi-common/src/main/java/org/apache/hudi/common/HoodieCleanStat.java x: 159 lines of code y: 8 # changes hudi-cli/src/main/java/org/apache/hudi/cli/utils/CommitUtil.java x: 27 lines of code y: 11 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/DagUtils.java x: 362 lines of code y: 10 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/GenericRecordFullPayloadGenerator.java x: 289 lines of code y: 14 # changes hudi-common/src/main/java/org/apache/hudi/common/util/DefaultSizeEstimator.java x: 8 lines of code y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/util/NetworkUtils.java x: 51 lines of code y: 7 # changes hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/utils/SparkSqlUtils.scala x: 231 lines of code y: 2 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/hudi/parser/HoodieSpark2ExtendedSqlAstBuilder.scala x: 162 lines of code y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BucketType.java x: 4 lines of code y: 4 # changes hudi-spark-datasource/hudi-spark2/src/main/antlr4/imports/SqlBase.g4 x: 971 lines of code y: 1 # changes
212.0
# changes
  min: 1.0
  average: 6.7
  25th percentile: 1.0
  median: 3.0
  75th percentile: 7.0
  max: 212.0
0 2526.0
lines of code
min: 2.0 | average: 102.12 | 25th percentile: 22.0 | median: 49.0 | 75th percentile: 114.0 | max: 2526.0

Number of Contributors vs. Number of Changes: 2461 points

hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java x: 3 # contributors y: 3 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java x: 18 # contributors y: 27 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java x: 27 # contributors y: 55 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java x: 15 # contributors y: 28 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java x: 7 # contributors y: 14 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodiePayloadConfig.java x: 11 # contributors y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java x: 64 # contributors y: 212 # changes hudi-common/src/main/java/org/apache/hudi/common/model/DefaultHoodieRecordPayload.java x: 13 # contributors y: 16 # changes hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java x: 16 # contributors y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/model/RecordPayloadType.java x: 2 # contributors y: 2 # changes hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableConfig.java x: 36 # contributors y: 82 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala x: 23 # contributors y: 39 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java x: 11 # contributors y: 14 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java x: 15 # contributors y: 32 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java x: 33 # contributors y: 86 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/HoodieJavaWriteClient.java x: 20 # contributors y: 30 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala x: 15 # contributors y: 42 # changes hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java x: 35 # contributors y: 72 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java x: 4 # contributors y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java x: 38 # contributors y: 73 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java x: 15 # contributors y: 34 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfigHolder.java x: 6 # contributors y: 9 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala x: 12 # contributors y: 20 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala x: 1 # contributors y: 1 # changes hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaUtils.java x: 11 # contributors y: 16 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala x: 43 # contributors y: 107 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java x: 3 # contributors y: 5 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java x: 8 # contributors y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java x: 4 # contributors y: 5 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/RecordLevelIndexSupport.scala x: 2 # contributors y: 4 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java x: 23 # contributors y: 44 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineDiffHelper.java x: 5 # contributors y: 6 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java x: 38 # contributors y: 116 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/metadata/FlinkHoodieBackedTableMetadataWriter.java x: 11 # contributors y: 37 # changes hudi-cli/src/main/java/org/apache/hudi/cli/HoodieCLI.java x: 12 # contributors y: 15 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java x: 12 # contributors y: 18 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsConfig.java x: 10 # contributors y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanActionExecutor.java x: 15 # contributors y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java x: 39 # contributors y: 68 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java x: 17 # contributors y: 25 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/RemoteHoodieTableFileSystemView.java x: 25 # contributors y: 42 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java x: 13 # contributors y: 17 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java x: 21 # contributors y: 27 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java x: 14 # contributors y: 18 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DefaultSource.scala x: 23 # contributors y: 50 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java x: 11 # contributors y: 26 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java x: 16 # contributors y: 45 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java x: 19 # contributors y: 29 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java x: 6 # contributors y: 6 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java x: 30 # contributors y: 58 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java x: 22 # contributors y: 41 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java x: 25 # contributors y: 48 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java x: 17 # contributors y: 31 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/filedistribution/partitioner/StreamReadAppendPartitioner.java x: 1 # contributors y: 2 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java x: 25 # contributors y: 56 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java x: 33 # contributors y: 64 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java x: 23 # contributors y: 34 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java x: 47 # contributors y: 100 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkCopyOnWriteTable.java x: 25 # contributors y: 46 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaCopyOnWriteTable.java x: 21 # contributors y: 34 # changes hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/BaseJavaCommitActionExecutor.java x: 19 # contributors y: 27 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java x: 22 # contributors y: 39 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java x: 15 # contributors y: 27 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BaseBootstrapMetadataHandler.java x: 5 # contributors y: 5 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java x: 31 # contributors y: 48 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java x: 15 # contributors y: 37 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java x: 14 # contributors y: 21 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java x: 9 # contributors y: 15 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java x: 15 # contributors y: 31 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieDeltaWriteStat.java x: 7 # contributors y: 7 # changes hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java x: 17 # contributors y: 27 # changes hudi-aws/src/main/java/org/apache/hudi/config/GlueCatalogSyncClientConfig.java x: 3 # contributors y: 4 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java x: 33 # contributors y: 49 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncClient.java x: 11 # contributors y: 15 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieMetaSyncOperations.java x: 7 # contributors y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java x: 29 # contributors y: 52 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/KeyGenUtils.java x: 17 # contributors y: 23 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/factory/HoodieAvroKeyGeneratorFactory.java x: 7 # contributors y: 9 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala x: 10 # contributors y: 17 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala x: 8 # contributors y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/ClusteringPlanStrategy.java x: 9 # contributors y: 13 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java x: 22 # contributors y: 32 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIndexUtils.java x: 5 # contributors y: 7 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystPlansUtils.scala x: 8 # contributors y: 13 # changes hudi-common/src/main/java/org/apache/hudi/common/bloom/InternalBloomFilter.java x: 2 # contributors y: 3 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileIndex.scala x: 21 # contributors y: 45 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataWriteUtils.java x: 9 # contributors y: 12 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineUtils.java x: 11 # contributors y: 22 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/catalog/HoodieCatalogTable.scala x: 18 # contributors y: 29 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncClient.java x: 8 # contributors y: 11 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieArchivedTimeline.java x: 20 # contributors y: 38 # changes hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java x: 8 # contributors y: 10 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanActionExecutor.java x: 19 # contributors y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java x: 45 # contributors y: 79 # changes hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderFactory.java x: 4 # contributors y: 4 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSchemaUtils.scala x: 3 # contributors y: 6 # changes azure-pipelines-20230430.yml x: 9 # contributors y: 16 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/config/CloudSourceConfig.java x: 4 # contributors y: 10 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsHoodieIncrSource.java x: 10 # contributors y: 15 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java x: 15 # contributors y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelectorCommon.java x: 9 # contributors y: 11 # changes hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaCompatibility.java x: 6 # contributors y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/TableSchemaResolver.java x: 25 # contributors y: 41 # changes hudi-common/src/main/java/org/apache/hudi/common/util/collection/ExternalSpillableMap.java x: 16 # contributors y: 19 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/MetadataCommand.java x: 15 # contributors y: 17 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/RunIndexActionExecutor.java x: 13 # contributors y: 20 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java x: 28 # contributors y: 76 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieIndexer.java x: 8 # contributors y: 12 # changes hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java x: 45 # contributors y: 96 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewManager.java x: 20 # contributors y: 32 # changes hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java x: 22 # contributors y: 36 # changes hudi-common/src/main/java/org/apache/hudi/common/engine/HoodieReaderContext.java x: 3 # contributors y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieKeyBasedFileGroupRecordBuffer.java x: 4 # contributors y: 7 # changes hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodiePositionBasedFileGroupRecordBuffer.java x: 4 # contributors y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java x: 10 # contributors y: 16 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java x: 18 # contributors y: 35 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java x: 16 # contributors y: 26 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonKafkaSource.java x: 21 # contributors y: 30 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java x: 16 # contributors y: 23 # changes hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/AvroSchemaEvolutionUtils.java x: 9 # contributors y: 14 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala x: 43 # contributors y: 116 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieWriterUtils.scala x: 16 # contributors y: 31 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowParquetWriteSupport.java x: 6 # contributors y: 8 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HadoopFSUtils.java x: 1 # contributors y: 3 # changes hudi-hadoop-common/src/main/java/org/apache/hudi/storage/hadoop/HoodieHadoopStorage.java x: 1 # contributors y: 4 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDWriteClient.java x: 34 # contributors y: 77 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstantTimeGenerator.java x: 11 # contributors y: 18 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/HoodieProcedures.scala x: 12 # contributors y: 33 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java x: 20 # contributors y: 22 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieInputFormatUtils.java x: 23 # contributors y: 41 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelation.scala x: 18 # contributors y: 33 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java x: 58 # contributors y: 143 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ProtoKafkaSource.java x: 6 # contributors y: 11 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java x: 12 # contributors y: 17 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java x: 5 # contributors y: 9 # changes hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncConfig.java x: 13 # contributors y: 22 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBaseRelation.scala x: 17 # contributors y: 49 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieHadoopFsRelationFactory.scala x: 2 # contributors y: 10 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/FileSystemBasedLockProvider.java x: 6 # contributors y: 12 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadata.java x: 14 # contributors y: 30 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java x: 11 # contributors y: 19 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java x: 6 # contributors y: 10 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FilePathUtils.java x: 5 # contributors y: 8 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ViewStorageProperties.java x: 3 # contributors y: 9 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SparkSampleWritesUtils.java x: 2 # contributors y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CleanerUtils.java x: 13 # contributors y: 19 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieHFileDataBlock.java x: 15 # contributors y: 30 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/HoodieCompactor.java x: 14 # contributors y: 19 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieWriteStat.java x: 11 # contributors y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieClusteringJob.java x: 19 # contributors y: 28 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackHelper.java x: 10 # contributors y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java x: 20 # contributors y: 34 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java x: 29 # contributors y: 41 # changes hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java x: 19 # contributors y: 32 # changes hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java x: 29 # contributors y: 66 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecord.java x: 21 # contributors y: 28 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFileReader.java x: 30 # contributors y: 46 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java x: 18 # contributors y: 28 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCommandBlock.java x: 9 # contributors y: 9 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieLogBlock.java x: 14 # contributors y: 24 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala x: 5 # contributors y: 14 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/CompactionCommand.java x: 22 # contributors y: 37 # changes hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePartitionMetadata.java x: 11 # contributors y: 17 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java x: 33 # contributors y: 68 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactionAdminTool.java x: 8 # contributors y: 14 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/perf/TimelineServerPerf.java x: 14 # contributors y: 27 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndexUtils.java x: 16 # contributors y: 25 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieMergeHelper.java x: 11 # contributors y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/util/ParquetUtils.java x: 17 # contributors y: 30 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java x: 25 # contributors y: 36 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkMain.java x: 39 # contributors y: 67 # changes hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkUtil.java x: 18 # contributors y: 22 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowCreateHandle.java x: 12 # contributors y: 16 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java x: 19 # contributors y: 37 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java x: 22 # contributors y: 40 # changes hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java x: 7 # contributors y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala x: 14 # contributors y: 22 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunBootstrapProcedure.scala x: 10 # contributors y: 14 # changes hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HMSDDLExecutor.java x: 13 # contributors y: 14 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java x: 21 # contributors y: 33 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java x: 23 # contributors y: 36 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotExporter.java x: 18 # contributors y: 32 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/DFSPathSelector.java x: 15 # contributors y: 18 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java x: 14 # contributors y: 20 # changes hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java x: 27 # contributors y: 39 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala x: 6 # contributors y: 13 # changes hudi-flink-datasource/hudi-flink1.16.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 7 # contributors y: 10 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala x: 5 # contributors y: 12 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/savepoint/SavepointActionExecutor.java x: 14 # contributors y: 16 # changes hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryExecutor.java x: 14 # contributors y: 17 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java x: 8 # contributors y: 17 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/InsertIntoHoodieTableCommand.scala x: 18 # contributors y: 37 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieRealtimeInputFormatUtils.java x: 15 # contributors y: 29 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ZeroToOneUpgradeHandler.java x: 11 # contributors y: 11 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/SparkAdapter.scala x: 16 # contributors y: 39 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/adapter/Spark2Adapter.scala x: 16 # contributors y: 38 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala x: 19 # contributors y: 50 # changes hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/HoodieSpark2CatalystPlanUtils.scala x: 7 # contributors y: 13 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/prune/PartitionPruners.java x: 3 # contributors y: 2 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java x: 10 # contributors y: 20 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/HoodieMetrics.java x: 16 # contributors y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/RocksDbBasedFileSystemView.java x: 12 # contributors y: 24 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java x: 15 # contributors y: 16 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLocationFetchHandle.java x: 10 # contributors y: 10 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineServerHelper.java x: 9 # contributors y: 10 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala x: 12 # contributors y: 27 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala x: 11 # contributors y: 24 # changes hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieCatalystExpressionUtils.scala x: 5 # contributors y: 10 # changes hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/BaseValidateDatasetNode.java x: 5 # contributors y: 11 # changes hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/adapter/BaseSpark3Adapter.scala x: 13 # contributors y: 25 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCleaner.java x: 16 # contributors y: 22 # changes hudi-common/src/main/java/org/apache/hudi/common/table/cdc/HoodieCDCExtractor.java x: 8 # contributors y: 15 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/PartitionAwareClusteringPlanStrategy.java x: 16 # contributors y: 21 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bootstrap/BootstrapOperator.java x: 7 # contributors y: 12 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoHoodieTableCommand.scala x: 27 # contributors y: 58 # changes hudi-common/src/main/java/org/apache/hudi/common/model/WriteOperationType.java x: 15 # contributors y: 21 # changes hudi-common/src/main/java/org/apache/hudi/common/model/FileSlice.java x: 10 # contributors y: 11 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieDataSourceHelper.scala x: 7 # contributors y: 15 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java x: 27 # contributors y: 44 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RunClusteringProcedure.scala x: 11 # contributors y: 21 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieBackedTableMetadataWriter.java x: 13 # contributors y: 37 # changes hudi-common/src/main/java/org/apache/hudi/common/config/ConfigGroups.java x: 8 # contributors y: 18 # changes hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMetadataConfig.java x: 19 # contributors y: 54 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLockConfig.java x: 13 # contributors y: 21 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala x: 12 # contributors y: 28 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala x: 11 # contributors y: 23 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java x: 30 # contributors y: 96 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkTable.java x: 14 # contributors y: 26 # changes hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstant.java x: 14 # contributors y: 23 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java x: 16 # contributors y: 27 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java x: 24 # contributors y: 37 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/common/AbstractStreamWriteFunction.java x: 4 # contributors y: 12 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java x: 24 # contributors y: 34 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieIndexConfig.java x: 19 # contributors y: 35 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java x: 10 # contributors y: 18 # changes hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/DataSourceUtils.java x: 26 # contributors y: 40 # changes hudi-cli/src/main/java/org/apache/hudi/cli/HoodieTableHeaderFields.java x: 6 # contributors y: 15 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieROTablePathFilter.java x: 21 # contributors y: 31 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/TimestampBasedAvroKeyGenerator.java x: 12 # contributors y: 14 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/postprocessor/DropColumnSchemaPostProcessor.java x: 5 # contributors y: 4 # changes hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/adapter/Spark3_1Adapter.scala x: 8 # contributors y: 16 # changes hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/UpdateHoodieTableCommand.scala x: 8 # contributors y: 20 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java x: 48 # contributors y: 89 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamerMetrics.java x: 13 # contributors y: 13 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieMultiTableDeltaStreamer.java x: 26 # contributors y: 29 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndex.java x: 13 # contributors y: 15 # changes hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieMergeOnReadRDD.scala x: 12 # contributors y: 21 # changes hudi-common/src/main/java/org/apache/hudi/common/util/CollectionUtils.java x: 12 # contributors y: 22 # changes hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java x: 19 # contributors y: 30 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetSchemaConverter.java x: 4 # contributors y: 9 # changes hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLayoutConfig.java x: 6 # contributors y: 5 # changes hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewStorageConfig.java x: 17 # contributors y: 28 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkCreateHandle.java x: 8 # contributors y: 19 # changes hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkMergeHandle.java x: 5 # contributors y: 20 # changes hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/HoodieSparkCompactor.java x: 9 # contributors y: 8 # changes hudi-utilities/src/main/java/org/apache/hudi/utilities/HiveIncrementalPuller.java x: 13 # contributors y: 18 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HiveSchemaUtils.java x: 3 # contributors y: 8 # changes packaging/bundle-validation/service/read.scala x: 2 # contributors y: 1 # changes hudi-cli/src/main/java/org/apache/hudi/cli/commands/SavepointsCommand.java x: 18 # contributors y: 25 # changes hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/DataTypeUtils.java x: 2 # contributors y: 6 # changes hudi-cli/src/main/java/org/apache/hudi/cli/utils/HiveUtil.java x: 7 # contributors y: 6 # changes
212.0
# changes
  min: 1.0
  average: 6.7
  25th percentile: 1.0
  median: 3.0
  75th percentile: 7.0
  max: 212.0
0 64.0
# contributors
min: 1.0 | average: 4.59 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 64.0

Number of Contributors vs. File Size: 2461 points

hudi-common/src/main/java/org/apache/hudi/common/table/read/IncrementalQueryAnalyzer.java x: 3 # contributors y: 266 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/ClusteringUtils.java x: 18 # contributors y: 211 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/FlinkOptions.java x: 27 # contributors y: 900 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/IncrementalInputSplits.java x: 15 # contributors y: 391 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadMonitoringFunction.java x: 7 # contributors y: 189 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodiePayloadConfig.java x: 11 # contributors y: 77 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieWriteConfig.java x: 64 # contributors y: 2526 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/DefaultHoodieRecordPayload.java x: 13 # contributors y: 126 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/OverwriteWithLatestAvroPayload.java x: 16 # contributors y: 50 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/RecordPayloadType.java x: 2 # contributors y: 67 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableConfig.java x: 36 # contributors y: 613 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/ProvidesHoodieConfig.scala x: 23 # contributors y: 396 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieClient.java x: 11 # contributors y: 197 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieTableServiceClient.java x: 15 # contributors y: 800 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/BaseHoodieWriteClient.java x: 33 # contributors y: 840 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/HoodieJavaWriteClient.java x: 20 # contributors y: 187 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieSparkUtils.scala x: 15 # contributors y: 247 lines of code hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroUtils.java x: 35 # contributors y: 982 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/ErrorEvent.java x: 3 # contributors y: 40 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamerUtils.java x: 4 # contributors y: 137 lines of code hudi-common/src/main/java/org/apache/hudi/common/fs/FSUtils.java x: 38 # contributors y: 557 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieMetadataTableValidator.java x: 15 # contributors y: 1158 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfigHolder.java x: 6 # contributors y: 126 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/AvroConversionUtils.scala x: 12 # contributors y: 153 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/util/ExceptionWrappingIterator.scala x: 1 # contributors y: 15 lines of code hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaUtils.java x: 11 # contributors y: 322 lines of code hudi-common/src/main/java/org/apache/hudi/exception/HoodieAvroSchemaException.java x: 1 # contributors y: 6 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSparkSqlWriter.scala x: 43 # contributors y: 870 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/config/HoodieStreamerConfig.java x: 3 # contributors y: 105 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/RowSource.java x: 8 # contributors y: 34 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SourceFormatAdapter.java x: 4 # contributors y: 212 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/RecordLevelIndexSupport.scala x: 2 # contributors y: 123 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanner.java x: 23 # contributors y: 408 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineDiffHelper.java x: 5 # contributors y: 111 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadataWriter.java x: 38 # contributors y: 1115 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/metadata/FlinkHoodieBackedTableMetadataWriter.java x: 11 # contributors y: 131 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/HoodieCLI.java x: 12 # contributors y: 78 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/TableCommand.java x: 12 # contributors y: 332 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/metrics/HoodieMetricsConfig.java x: 10 # contributors y: 154 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanPlanActionExecutor.java x: 15 # contributors y: 143 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/AbstractTableFileSystemView.java x: 39 # contributors y: 1039 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/PriorityBasedFileSystemView.java x: 17 # contributors y: 264 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/RemoteHoodieTableFileSystemView.java x: 25 # contributors y: 547 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/TableFileSystemView.java x: 13 # contributors y: 54 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java x: 21 # contributors y: 536 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/FileSliceHandler.java x: 14 # contributors y: 124 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DefaultSource.scala x: 23 # contributors y: 301 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/StreamSync.java x: 11 # contributors y: 969 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataPayload.java x: 16 # contributors y: 551 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/PreferWriterConflictResolutionStrategy.java x: 3 # contributors y: 65 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/ClusteringPlanActionExecutor.java x: 10 # contributors y: 77 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/BaseRollbackActionExecutor.java x: 19 # contributors y: 248 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/RestorePlanActionExecutor.java x: 6 # contributors y: 62 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieDefaultTimeline.java x: 30 # contributors y: 447 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieTimeline.java x: 22 # contributors y: 299 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/StreamerUtil.java x: 25 # contributors y: 371 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSource.java x: 17 # contributors y: 541 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/FirstValueAvroPayload.java x: 1 # contributors y: 45 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieAppendHandle.java x: 25 # contributors y: 519 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergeHandle.java x: 33 # contributors y: 370 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieWriteHandle.java x: 23 # contributors y: 191 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/HoodieTable.java x: 47 # contributors y: 562 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkCopyOnWriteTable.java x: 25 # contributors y: 280 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/action/commit/BaseFlinkCommitActionExecutor.java x: 18 # contributors y: 142 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/HoodieJavaCopyOnWriteTable.java x: 21 # contributors y: 263 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/BaseJavaCommitActionExecutor.java x: 19 # contributors y: 238 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkCopyOnWriteTable.java x: 22 # contributors y: 241 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/HoodieSparkTable.java x: 15 # contributors y: 107 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/BaseBootstrapMetadataHandler.java x: 5 # contributors y: 56 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java x: 31 # contributors y: 303 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/configuration/OptionsResolver.java x: 15 # contributors y: 212 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/timeline/LSMTimelineWriter.java x: 4 # contributors y: 230 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableFactory.java x: 14 # contributors y: 318 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieCatalog.java x: 9 # contributors y: 516 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/HoodieHiveCatalog.java x: 15 # contributors y: 809 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieDeltaWriteStat.java x: 7 # contributors y: 78 lines of code hudi-aws/src/main/java/org/apache/hudi/aws/sync/AWSGlueCatalogSyncClient.java x: 17 # contributors y: 785 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncTool.java x: 33 # contributors y: 358 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HoodieHiveSyncClient.java x: 11 # contributors y: 378 lines of code hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieMetaSyncOperations.java x: 7 # contributors y: 86 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/KafkaOffsetGen.java x: 29 # contributors y: 332 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/KeyGenUtils.java x: 17 # contributors y: 186 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/keygen/factory/HoodieSparkKeyGeneratorFactory.java x: 11 # contributors y: 125 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/hudi/HoodieDatasetBulkInsertHelper.scala x: 10 # contributors y: 190 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/SqlKeyGenerator.scala x: 8 # contributors y: 140 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/ClusteringPlanStrategy.java x: 9 # contributors y: 105 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/clustering/plan/strategy/FlinkSizeBasedClusteringPlanStrategyRecently.java x: 1 # contributors y: 89 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BaseCommitActionExecutor.java x: 22 # contributors y: 249 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/ConsistentBucketIndexUtils.java x: 5 # contributors y: 190 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/sort/SortOperator.java x: 3 # contributors y: 90 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieFileIndex.scala x: 21 # contributors y: 373 lines of code scripts/pr_compliance.py x: 3 # contributors y: 333 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/ScheduleCompactionActionExecutor.java x: 13 # contributors y: 178 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkUtil.java x: 1 # contributors y: 103 lines of code hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/streaming/StructuredStreamingSinkTestWriter.scala x: 1 # contributors y: 71 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCreateHandle.java x: 19 # contributors y: 177 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGeneratorBase.java x: 2 # contributors y: 82 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimeGenerators.java x: 2 # contributors y: 26 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataWriteUtils.java x: 9 # contributors y: 177 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/TimelineUtils.java x: 11 # contributors y: 338 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/catalyst/catalog/HoodieCatalogTable.scala x: 18 # contributors y: 236 lines of code hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncClient.java x: 8 # contributors y: 160 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieArchivedTimeline.java x: 20 # contributors y: 217 lines of code hudi-gcp/src/main/java/org/apache/hudi/gcp/bigquery/HoodieBigQuerySyncClient.java x: 8 # contributors y: 257 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/clean/CleanActionExecutor.java x: 19 # contributors y: 228 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/UtilHelpers.java x: 45 # contributors y: 514 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileReaderFactory.java x: 5 # contributors y: 35 lines of code hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReaderFactory.java x: 4 # contributors y: 51 lines of code hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileReaderFactory.java x: 8 # contributors y: 104 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieSchemaUtils.scala x: 3 # contributors y: 131 lines of code azure-pipelines-20230430.yml x: 9 # contributors y: 329 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/config/CloudSourceConfig.java x: 4 # contributors y: 109 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/config/S3EventsHoodieIncrSourceConfig.java x: 3 # contributors y: 56 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsHoodieIncrSource.java x: 10 # contributors y: 111 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/S3EventsHoodieIncrSource.java x: 15 # contributors y: 130 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/CloudObjectsSelectorCommon.java x: 9 # contributors y: 227 lines of code hudi-common/src/main/java/org/apache/hudi/avro/AvroSchemaCompatibility.java x: 6 # contributors y: 603 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/TableSchemaResolver.java x: 25 # contributors y: 392 lines of code hudi-common/src/main/java/org/apache/hudi/exception/SchemaCompatibilityException.java x: 2 # contributors y: 13 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/convert/AvroInternalSchemaConverter.java x: 7 # contributors y: 326 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/MetricsReporterType.java x: 3 # contributors y: 4 lines of code hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/HoodieSparkFunctionalIndexClient.java x: 2 # contributors y: 105 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/collection/ExternalSpillableMap.java x: 16 # contributors y: 242 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/MetadataCommand.java x: 15 # contributors y: 303 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/index/RunIndexActionExecutor.java x: 13 # contributors y: 250 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ThreeToFourUpgradeHandler.java x: 3 # contributors y: 28 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadataUtil.java x: 28 # contributors y: 1273 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieIndexer.java x: 8 # contributors y: 267 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/HoodieTableMetaClient.java x: 45 # contributors y: 976 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewManager.java x: 20 # contributors y: 172 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java x: 22 # contributors y: 365 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupRecordBuffer.java x: 3 # contributors y: 32 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieKeyBasedFileGroupRecordBuffer.java x: 4 # contributors y: 122 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodiePositionBasedFileGroupRecordBuffer.java x: 4 # contributors y: 154 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/transform/RowDataToHoodieFunction.java x: 2 # contributors y: 56 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/streamer/FlinkStreamerConfig.java x: 10 # contributors y: 378 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/mor/MergeOnReadInputFormat.java x: 12 # contributors y: 707 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/RowDataToAvroConverters.java x: 5 # contributors y: 284 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteOperatorCoordinator.java x: 18 # contributors y: 432 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/hbase/SparkHoodieHBaseIndex.java x: 16 # contributors y: 544 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieWithTimelineServer.java x: 10 # contributors y: 89 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/KafkaOffsetPostProcessor.java x: 6 # contributors y: 58 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonKafkaSource.java x: 21 # contributors y: 93 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/HoodieCommonConfig.java x: 16 # contributors y: 140 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/AvroSchemaEvolutionUtils.java x: 9 # contributors y: 98 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/DataSourceOptions.scala x: 43 # contributors y: 758 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieWriterUtils.scala x: 16 # contributors y: 202 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/HoodieSparkFileWriterFactory.java x: 3 # contributors y: 76 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/HoodieStorageConfig.java x: 6 # contributors y: 330 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/CreateHoodieTableCommand.scala x: 12 # contributors y: 180 lines of code hudi-hadoop-common/src/main/java/org/apache/hudi/storage/hadoop/HoodieHadoopStorage.java x: 1 # contributors y: 144 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/HoodiePartitionTTLStrategyFactory.java x: 1 # contributors y: 51 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByCreationTimeStrategy.java x: 1 # contributors y: 27 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/KeepByTimeStrategy.java x: 1 # contributors y: 65 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/ttl/strategy/PartitionTTLStrategy.java x: 1 # contributors y: 35 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/SparkRDDWriteClient.java x: 34 # contributors y: 262 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieInstantTimeGenerator.java x: 11 # contributors y: 114 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/UpsertPartitioner.java x: 20 # contributors y: 281 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadTableInputFormat.java x: 11 # contributors y: 305 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HoodieInputFormatUtils.java x: 23 # contributors y: 349 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadIncrementalRelation.scala x: 18 # contributors y: 201 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/utils/HiveAvroSerializer.java x: 6 # contributors y: 324 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieMultiTableStreamer.java x: 2 # contributors y: 383 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/DeltaSync.java x: 58 # contributors y: 28 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroKafkaSource.java x: 20 # contributors y: 104 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/KafkaSource.java x: 8 # contributors y: 71 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/ProtoKafkaSource.java x: 6 # contributors y: 84 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/Source.java x: 12 # contributors y: 55 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/HoodieStreamer.java x: 5 # contributors y: 742 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieOptionConfig.scala x: 15 # contributors y: 194 lines of code hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/HoodieSyncConfig.java x: 13 # contributors y: 242 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTableFileSystemView.java x: 16 # contributors y: 295 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/ddl/HiveQueryDDLExecutor.java x: 9 # contributors y: 121 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBaseRelation.scala x: 17 # contributors y: 532 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieHadoopFsRelationFactory.scala x: 2 # contributors y: 297 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/ExportCommand.java x: 11 # contributors y: 186 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/heartbeat/HeartbeatUtils.java x: 7 # contributors y: 49 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/FileSystemBasedLockProvider.java x: 6 # contributors y: 173 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkMetadataWriterUtils.java x: 3 # contributors y: 201 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieTableMetadata.java x: 14 # contributors y: 101 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/meta/CkpMetadata.java x: 11 # contributors y: 156 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/FileIndex.java x: 8 # contributors y: 244 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/catalog/TableOptionProperties.java x: 6 # contributors y: 192 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FilePathUtils.java x: 5 # contributors y: 314 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClientIds.java x: 5 # contributors y: 174 lines of code hudi-io/src/main/java/org/apache/hudi/storage/StoragePath.java x: 1 # contributors y: 222 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ExportInstantsProcedure.scala x: 8 # contributors y: 177 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerBasedEarlyConflictDetectionRunnable.java x: 3 # contributors y: 87 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/streamer/SparkSampleWritesUtils.java x: 2 # contributors y: 130 lines of code hudi-common/src/main/java/org/apache/hudi/common/bootstrap/index/HFileBootstrapIndex.java x: 10 # contributors y: 584 lines of code hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieNativeAvroHFileReader.java x: 1 # contributors y: 459 lines of code hudi-io/src/main/java/org/apache/hudi/io/hfile/HFileReaderImpl.java x: 1 # contributors y: 233 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/CleanerUtils.java x: 13 # contributors y: 148 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieParquetDataBlock.java x: 9 # contributors y: 143 lines of code hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/inline/InLineFsDataInputStream.java x: 1 # contributors y: 92 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/HoodieCompactor.java x: 14 # contributors y: 186 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieWriteStat.java x: 11 # contributors y: 251 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/compact/CompactHelpers.java x: 8 # contributors y: 83 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/InstantRange.java x: 2 # contributors y: 184 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/CompletionTimeQueryView.java x: 4 # contributors y: 183 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataLogRecordReader.java x: 6 # contributors y: 166 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ClusteringUtil.java x: 5 # contributors y: 64 lines of code hudi-io/src/main/java/org/apache/hudi/common/util/Option.java x: 2 # contributors y: 115 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCRelation.scala x: 5 # contributors y: 147 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/BaseActionExecutor.java x: 9 # contributors y: 87 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDataTableValidator.java x: 7 # contributors y: 280 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieDropPartitionsTool.java x: 6 # contributors y: 302 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieSnapshotCopier.java x: 20 # contributors y: 143 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/TableSizeStats.java x: 5 # contributors y: 326 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/HiveSyncConfig.java x: 29 # contributors y: 161 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/SparkMetadataTableRecordIndex.java x: 3 # contributors y: 120 lines of code hudi-common/src/main/avro/HoodieMetadata.avsc x: 6 # contributors y: 436 lines of code hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieHBaseAvroHFileReader.java x: 2 # contributors y: 517 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/BaseTableMetadata.java x: 19 # contributors y: 314 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieBackedTableMetadata.java x: 29 # contributors y: 597 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/FunctionalIndexSupport.scala x: 2 # contributors y: 140 lines of code hudi-aws/src/main/java/org/apache/hudi/config/HoodieAWSConfig.java x: 7 # contributors y: 139 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/PartitionFilterGenerator.java x: 2 # contributors y: 166 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieRecord.java x: 21 # contributors y: 269 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFileReader.java x: 30 # contributors y: 376 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java x: 18 # contributors y: 257 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCDCDataBlock.java x: 7 # contributors y: 31 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCommandBlock.java x: 9 # contributors y: 33 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieCorruptBlock.java x: 7 # contributors y: 24 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieDataBlock.java x: 11 # contributors y: 288 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieLogBlock.java x: 14 # contributors y: 203 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordReader.java x: 4 # contributors y: 249 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieBaseFileGroupRecordBuffer.java x: 5 # contributors y: 214 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/read/HoodieFileGroupReader.java x: 5 # contributors y: 264 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/HoodieRecordSizeEstimator.java x: 9 # contributors y: 18 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/HoodieFileGroupReaderBasedParquetFileFormat.scala x: 5 # contributors y: 343 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/CompactionCommand.java x: 22 # contributors y: 592 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/HoodieFunctionalIndexConfig.java x: 2 # contributors y: 220 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodiePartitionMetadata.java x: 11 # contributors y: 172 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/HoodieActiveTimeline.java x: 33 # contributors y: 583 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/ConfigUtils.java x: 6 # contributors y: 356 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/InternalSchemaCache.java x: 6 # contributors y: 150 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/MarkerUtils.java x: 5 # contributors y: 187 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/io/FileBasedInternalSchemaStorageManager.java x: 5 # contributors y: 155 lines of code hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieWrapperFileSystem.java x: 1 # contributors y: 865 lines of code hudi-io/src/main/java/org/apache/hudi/common/util/FileIOUtils.java x: 1 # contributors y: 175 lines of code hudi-sync/hudi-sync-common/src/main/java/org/apache/hudi/sync/common/util/ManifestFileWriter.java x: 6 # contributors y: 98 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/marker/MarkerDirState.java x: 6 # contributors y: 251 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactionAdminTool.java x: 8 # contributors y: 124 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/perf/TimelineServerPerf.java x: 14 # contributors y: 269 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/FilebasedSchemaProvider.java x: 12 # contributors y: 68 lines of code hudi-io/src/main/java/org/apache/hudi/common/util/ComparableVersion.java x: 1 # contributors y: 252 lines of code hudi-common/src/main/java/org/apache/hudi/avro/GenericAvroSerializer.java x: 2 # contributors y: 98 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieCommitMetadata.java x: 22 # contributors y: 422 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieConsistentHashingMetadata.java x: 5 # contributors y: 125 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieReplaceCommitMetadata.java x: 5 # contributors y: 96 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/debezium/PostgresDebeziumAvroPayload.java x: 5 # contributors y: 74 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/Base64CodecUtil.java x: 3 # contributors y: 16 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/InputSplitUtils.java x: 4 # contributors y: 24 lines of code hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/cli/HDFSParquetImporterUtils.java x: 5 # contributors y: 251 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/HoodieIndexUtils.java x: 16 # contributors y: 261 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieMergeHelper.java x: 11 # contributors y: 165 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/JavaExecutionStrategy.java x: 9 # contributors y: 162 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/MultipleSparkJobExecutionStrategy.java x: 22 # contributors y: 358 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SingleSparkJobExecutionStrategy.java x: 9 # contributors y: 117 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/ParquetBootstrapMetadataHandler.java x: 8 # contributors y: 99 lines of code hudi-common/src/main/java/org/apache/hudi/common/bloom/SimpleBloomFilter.java x: 4 # contributors y: 93 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/HoodieReaderConfig.java x: 4 # contributors y: 46 lines of code hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileWriterFactory.java x: 5 # contributors y: 88 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringOperator.java x: 19 # contributors y: 303 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieHFileRecordReader.java x: 4 # contributors y: 79 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/reader/DFSHoodieDatasetInputReader.java x: 18 # contributors y: 295 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/ParquetUtils.java x: 17 # contributors y: 365 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/HoodieLogFileCommand.java x: 25 # contributors y: 252 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/SparkMain.java x: 39 # contributors y: 589 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/utils/SparkUtil.java x: 18 # contributors y: 77 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineService.java x: 14 # contributors y: 228 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/DirectWriteMarkers.java x: 6 # contributors y: 148 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/marker/WriteMarkersFactory.java x: 4 # contributors y: 34 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/TwoToOneDowngradeHandler.java x: 4 # contributors y: 84 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkPartitionUtils.java x: 2 # contributors y: 30 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/io/storage/row/HoodieRowCreateHandle.java x: 12 # contributors y: 197 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/bootstrap/SparkBootstrapCommitActionExecutor.java x: 17 # contributors y: 250 lines of code hudi-common/src/main/java/org/apache/hudi/BaseHoodieTableFileIndex.java x: 15 # contributors y: 356 lines of code hudi-common/src/main/java/org/apache/hudi/common/fs/FailSafeConsistencyGuard.java x: 6 # contributors y: 131 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieBaseFile.java x: 4 # contributors y: 116 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieLogFile.java x: 14 # contributors y: 195 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/AbstractHoodieLogRecordReader.java x: 19 # contributors y: 699 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/BaseHoodieLogRecordReader.java x: 3 # contributors y: 592 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/HoodieTablePreCommitFileSystemView.java x: 5 # contributors y: 41 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/FormatUtils.java x: 10 # contributors y: 238 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cdc/CdcInputFormat.java x: 9 # contributors y: 607 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/cow/CopyOnWriteInputFormat.java x: 8 # contributors y: 285 lines of code hudi-hadoop-common/src/main/java/org/apache/hudi/hadoop/fs/HoodieRetryWrapperFileSystem.java x: 1 # contributors y: 216 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieMergeOnReadSnapshotReader.java x: 3 # contributors y: 168 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeCompactedRecordReader.java x: 22 # contributors y: 172 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeSplit.java x: 6 # contributors y: 76 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/RealtimeUnmergedRecordReader.java x: 17 # contributors y: 104 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/SparkDataSourceContinuousIngestTool.java x: 5 # contributors y: 100 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/generator/DeltaGenerator.java x: 12 # contributors y: 276 lines of code hudi-io/src/main/java/org/apache/hudi/common/util/ReflectionUtils.java x: 1 # contributors y: 124 lines of code hudi-kafka-connect/src/main/java/org/apache/hudi/connect/writers/KafkaConnectTransactionServices.java x: 7 # contributors y: 127 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/HoodieSqlCommonUtils.scala x: 14 # contributors y: 253 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/DedupeSparkJob.scala x: 5 # contributors y: 167 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/RepairOverwriteHoodiePropsProcedure.scala x: 4 # contributors y: 64 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowColumnStatsOverlapProcedure.scala x: 2 # contributors y: 234 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowFileSystemViewProcedure.scala x: 7 # contributors y: 228 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HDFSParquetImporter.java x: 21 # contributors y: 224 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/HoodieCompactor.java x: 23 # contributors y: 245 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/HiveIncrPullSource.java x: 12 # contributors y: 84 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieCDCLogger.java x: 8 # contributors y: 198 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/transaction/lock/LockManager.java x: 14 # contributors y: 94 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieErrorTableConfig.java x: 2 # contributors y: 71 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieLogFormatReader.java x: 13 # contributors y: 85 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionPredicates.java x: 2 # contributors y: 396 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieMergedReadHandle.java x: 3 # contributors y: 143 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieMergedLogRecordScanner.java x: 27 # contributors y: 327 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/log/HoodieUnMergedLogRecordScanner.java x: 16 # contributors y: 135 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkConsistentBucketClusteringExecutionStrategy.java x: 9 # contributors y: 74 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/ColumnStatsIndexSupport.scala x: 6 # contributors y: 285 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/ExpressionUtils.java x: 4 # contributors y: 241 lines of code hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 7 # contributors y: 524 lines of code hudi-flink-datasource/hudi-flink1.17.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 6 # contributors y: 524 lines of code hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/ParquetSplitReaderUtil.java x: 4 # contributors y: 524 lines of code hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java x: 4 # contributors y: 262 lines of code hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ParquetColumnarRowSplitReader.java x: 2 # contributors y: 262 lines of code hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/execution/datasources/Spark3ParsePartitionUtil.scala x: 4 # contributors y: 190 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/DataSkippingUtils.scala x: 5 # contributors y: 236 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/SerDeHelper.java x: 5 # contributors y: 271 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java x: 9 # contributors y: 249 lines of code hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/handlers/TimelineHandler.java x: 6 # contributors y: 24 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/converter/JsonToAvroSchemaConverter.java x: 2 # contributors y: 203 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/JsonDFSSource.java x: 8 # contributors y: 28 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/schema/SchemaRegistryProvider.java x: 12 # contributors y: 174 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryExecutor.java x: 14 # contributors y: 54 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/queue/BoundedInMemoryQueue.java x: 12 # contributors y: 167 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/ClusteringCommitSink.java x: 8 # contributors y: 157 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/CommitUtils.java x: 14 # contributors y: 156 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/HoodieTableSink.java x: 8 # contributors y: 130 lines of code hudi-aws/src/main/java/org/apache/hudi/aws/transaction/lock/DynamoDBBasedLockProvider.java x: 7 # contributors y: 168 lines of code hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark33LegacyHoodieParquetFileFormat.scala x: 3 # contributors y: 389 lines of code hudi-spark-datasource/hudi-spark3.4.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark34LegacyHoodieParquetFileFormat.scala x: 3 # contributors y: 399 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark35LegacyHoodieParquetFileFormat.scala x: 2 # contributors y: 401 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/InsertIntoHoodieTableCommand.scala x: 18 # contributors y: 117 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/upgrade/ZeroToOneUpgradeHandler.java x: 11 # contributors y: 83 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/debezium/AbstractDebeziumAvroPayload.java x: 7 # contributors y: 56 lines of code hudi-flink-datasource/hudi-flink1.14.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/AbstractColumnReader.java x: 2 # contributors y: 196 lines of code hudi-sync/hudi-adb-sync/src/main/java/org/apache/hudi/sync/adb/AdbSyncTool.java x: 7 # contributors y: 204 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/SparkAdapter.scala x: 16 # contributors y: 78 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/analysis/HoodieAnalysis.scala x: 19 # contributors y: 383 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/common/model/HoodieSparkRecord.java x: 8 # contributors y: 333 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieTestSuiteWriter.java x: 10 # contributors y: 129 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/CDCFileGroupIterator.scala x: 1 # contributors y: 415 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/timeline/MetadataConversionUtils.java x: 3 # contributors y: 227 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/ConfigProperty.java x: 7 # contributors y: 187 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/GcsEventsSource.java x: 9 # contributors y: 132 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/metrics/HoodieMetrics.java x: 16 # contributors y: 341 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/RocksDbBasedFileSystemView.java x: 12 # contributors y: 484 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/RocksDBSchemaHelper.java x: 7 # contributors y: 101 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieDeltaStreamerWrapper.java x: 15 # contributors y: 58 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieKeyLocationFetchHandle.java x: 10 # contributors y: 48 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/embedded/EmbeddedTimelineServerHelper.java x: 9 # contributors y: 25 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/keygen/AutoRecordGenWrapperAvroKeyGenerator.java x: 2 # contributors y: 49 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/TypedProperties.java x: 10 # contributors y: 95 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/SparkHoodieTableFileIndex.scala x: 12 # contributors y: 299 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/BaseFileOnlyRelation.scala x: 11 # contributors y: 106 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bucket/HoodieBucketIndex.java x: 9 # contributors y: 64 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/StreamReadOperator.java x: 3 # contributors y: 186 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/clustering/HoodieFlinkClusteringJob.java x: 9 # contributors y: 231 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/compact/HoodieFlinkCompactor.java x: 11 # contributors y: 209 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/utils/Pipelines.java x: 17 # contributors y: 314 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/HoodieSchemaUtils.scala x: 2 # contributors y: 9 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionHoodieTableCommand.scala x: 5 # contributors y: 21 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/CompactionShowHoodieTableCommand.scala x: 5 # contributors y: 18 lines of code hudi-spark-datasource/hudi-spark3-common/src/main/scala/org/apache/spark/sql/adapter/BaseSpark3Adapter.scala x: 13 # contributors y: 63 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/antlr4/imports/SqlBase.g4 x: 1 # contributors y: 1760 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 1 # contributors y: 375 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 1 # contributors y: 324 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark35NestedSchemaPruning.scala x: 1 # contributors y: 116 lines of code hudi-spark-datasource/hudi-spark3.5.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_5ExtendedSqlAstBuilder.scala x: 1 # contributors y: 2354 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterHoodieTableChangeColumnCommand.scala x: 7 # contributors y: 61 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/MergeIntoHoodieTableCommand.scala x: 27 # contributors y: 474 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/FileSlice.java x: 10 # contributors y: 102 lines of code hudi-flink-datasource/hudi-flink1.18.x/src/main/java/org/apache/hudi/table/format/cow/vector/reader/ArrayColumnReader.java x: 1 # contributors y: 366 lines of code style/scalastyle.xml x: 8 # contributors y: 114 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieDataSourceHelper.scala x: 7 # contributors y: 99 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/PartialUpdateAvroPayload.java x: 6 # contributors y: 118 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/CompactionUtils.java x: 14 # contributors y: 213 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieClusteringConfig.java x: 27 # contributors y: 515 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/index/functional/HoodieSparkFunctionalIndex.java x: 1 # contributors y: 190 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/metadata/SparkHoodieBackedTableMetadataWriter.java x: 13 # contributors y: 163 lines of code hudi-common/src/main/java/org/apache/hudi/common/config/HoodieMetadataConfig.java x: 19 # contributors y: 547 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieLockConfig.java x: 13 # contributors y: 282 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/clustering/run/strategy/SparkSortAndSizeExecutionStrategy.java x: 15 # contributors y: 64 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/index/bloom/HoodieBloomIndex.java x: 11 # contributors y: 204 lines of code hudi-spark-datasource/hudi-spark3.2.x/src/main/antlr4/imports/SqlBase.g4 x: 2 # contributors y: 1760 lines of code hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_2ExtendedSqlAstBuilder.scala x: 3 # contributors y: 2345 lines of code hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/parser/HoodieSpark3_3ExtendedSqlAstBuilder.scala x: 2 # contributors y: 2351 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/SanitizationUtils.java x: 4 # contributors y: 140 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/MergeOnReadSnapshotRelation.scala x: 12 # contributors y: 100 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/payload/ExpressionPayload.scala x: 11 # contributors y: 353 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/client/HoodieFlinkWriteClient.java x: 30 # contributors y: 367 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/execution/SparkLazyInsertIterable.java x: 11 # contributors y: 60 lines of code hudi-client/hudi-spark-client/src/main/scala/org/apache/spark/sql/hudi/execution/RangeSample.scala x: 4 # contributors y: 433 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/StreamWriteFunction.java x: 7 # contributors y: 335 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/BulkInsertWriterHelper.java x: 7 # contributors y: 172 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/cdc/HoodieCDCRDD.scala x: 11 # contributors y: 439 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/table/HoodieFlinkTable.java x: 14 # contributors y: 83 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/HoodieInlineTestSuiteWriter.java x: 4 # contributors y: 173 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/hudi/streaming/HoodieStreamSource.scala x: 7 # contributors y: 142 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/procedures/ShowArchivedCommitsProcedure.scala x: 5 # contributors y: 138 lines of code hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/hudi/command/Spark30AlterTableCommand.scala x: 3 # contributors y: 258 lines of code hudi-spark-datasource/hudi-spark3.2plus-common/src/main/scala/org/apache/spark/sql/hudi/command/AlterTableCommand.scala x: 6 # contributors y: 278 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/helpers/IncrSourceHelper.java x: 16 # contributors y: 170 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/AbstractRealtimeRecordReader.java x: 24 # contributors y: 165 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/FileSystemViewCommand.java x: 16 # contributors y: 216 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/client/CompactionAdminClient.java x: 11 # contributors y: 247 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/rollback/MarkerBasedRollbackStrategy.java x: 8 # contributors y: 61 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieFileGroup.java x: 13 # contributors y: 139 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/IncrementalTimelineSyncFileSystemView.java x: 12 # contributors y: 316 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/RepairsCommand.java x: 24 # contributors y: 273 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaInsertOverwriteTableCommitActionExecutor.java x: 6 # contributors y: 37 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieIndexConfig.java x: 19 # contributors y: 528 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieCompactionConfig.java x: 23 # contributors y: 309 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/utils/InternalSchemaUtils.java x: 6 # contributors y: 187 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/HoodieWriteHelper.java x: 8 # contributors y: 54 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/client/utils/SparkInternalSchemaConverter.java x: 6 # contributors y: 396 lines of code hudi-common/src/main/java/org/apache/hudi/avro/HoodieAvroWriteSupport.java x: 11 # contributors y: 51 lines of code hudi-common/src/main/java/org/apache/hudi/avro/MercifulJsonConverter.java x: 9 # contributors y: 295 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/AvroOrcUtils.java x: 6 # contributors y: 703 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieBootstrapRelation.scala x: 10 # contributors y: 162 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/SchemaEvolutionContext.java x: 3 # contributors y: 299 lines of code hudi-common/src/main/java/org/apache/hudi/metadata/HoodieMetadataMetrics.java x: 6 # contributors y: 109 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/stats/ColumnStatsIndices.java x: 4 # contributors y: 199 lines of code hudi-spark-datasource/hudi-spark-common/src/main/java/org/apache/hudi/DataSourceUtils.java x: 26 # contributors y: 231 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/hudi/HoodieStreamingSink.scala x: 9 # contributors y: 275 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/TimelineCommand.java x: 4 # contributors y: 346 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieROTablePathFilter.java x: 21 # contributors y: 173 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/nodes/RollbackNode.java x: 6 # contributors y: 42 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/PulsarSource.java x: 5 # contributors y: 199 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/SqlQueryBasedTransformer.java x: 10 # contributors y: 38 lines of code hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/execution/datasources/parquet/Spark24LegacyHoodieParquetFileFormat.scala x: 1 # contributors y: 186 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/bulk/RowDataKeyGen.java x: 5 # contributors y: 222 lines of code hudi-spark-datasource/hudi-spark2/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 6 # contributors y: 315 lines of code hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 2 # contributors y: 360 lines of code hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 6 # contributors y: 364 lines of code hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 4 # contributors y: 377 lines of code hudi-spark-datasource/hudi-spark3.3.x/src/main/scala/org/apache/spark/sql/avro/AvroDeserializer.scala x: 5 # contributors y: 375 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/source/ExpressionEvaluators.java x: 2 # contributors y: 412 lines of code hudi-common/src/main/java/org/apache/hudi/expression/BindVisitor.java x: 1 # contributors y: 135 lines of code hudi-common/src/main/java/org/apache/hudi/expression/Predicates.java x: 1 # contributors y: 311 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/Types.java x: 4 # contributors y: 569 lines of code hudi-spark-datasource/hudi-spark/src/main/scala/org/apache/spark/sql/hudi/command/DeleteHoodieTableCommand.scala x: 11 # contributors y: 45 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/table/format/TypeConverters.java x: 1 # contributors y: 304 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamer.java x: 48 # contributors y: 36 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieDeltaStreamerMetrics.java x: 13 # contributors y: 9 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/deltastreamer/HoodieMultiTableDeltaStreamer.java x: 26 # contributors y: 13 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/ingestion/HoodieIngestionService.java x: 3 # contributors y: 114 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/cluster/strategy/UpdateStrategy.java x: 7 # contributors y: 18 lines of code hudi-common/src/main/java/org/apache/hudi/common/engine/EngineProperty.java x: 4 # contributors y: 10 lines of code hudi-client/hudi-java-client/src/main/java/org/apache/hudi/table/action/commit/JavaWriteHelper.java x: 9 # contributors y: 54 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormat.java x: 19 # contributors y: 116 lines of code hudi-sync/hudi-hive-sync/src/main/java/org/apache/hudi/hive/util/HiveSchemaUtil.java x: 10 # contributors y: 390 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/transform/FlatteningTransformer.java x: 8 # contributors y: 49 lines of code hudi-spark-datasource/hudi-spark-common/src/main/scala/org/apache/spark/sql/avro/SchemaConverters.scala x: 2 # contributors y: 155 lines of code hudi-sync/hudi-datahub-sync/src/main/java/org/apache/hudi/sync/datahub/DataHubSyncClient.java x: 4 # contributors y: 161 lines of code hudi-spark-datasource/hudi-spark3.1.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 4 # contributors y: 296 lines of code hudi-spark-datasource/hudi-spark3.2.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 5 # contributors y: 331 lines of code hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/avro/AvroSerializer.scala x: 1 # contributors y: 297 lines of code hudi-spark-datasource/hudi-spark3.0.x/src/main/scala/org/apache/spark/sql/execution/datasources/Spark30NestedSchemaPruning.scala x: 1 # contributors y: 166 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/realtime/HoodieParquetRealtimeInputFormat.java x: 19 # contributors y: 77 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/HoodieAvroIndexedRecord.java x: 3 # contributors y: 175 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/SpillableMapUtils.java x: 16 # contributors y: 110 lines of code hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/hive/HoodieCombineHiveInputFormat.java x: 14 # contributors y: 732 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/configuration/DeltaConfig.java x: 8 # contributors y: 388 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/WriterContext.java x: 7 # contributors y: 113 lines of code hudi-common/src/main/resources/hbase-site.xml x: 5 # contributors y: 2077 lines of code hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/storage/row/parquet/ParquetRowDataWriter.java x: 3 # contributors y: 462 lines of code hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/AvroSchemaConverter.java x: 6 # contributors y: 298 lines of code hudi-common/src/main/java/org/apache/hudi/common/table/view/FileSystemViewStorageConfig.java x: 17 # contributors y: 349 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/InternalSchemaBuilder.java x: 3 # contributors y: 191 lines of code hudi-common/src/main/java/org/apache/hudi/internal/schema/action/TableChanges.java x: 3 # contributors y: 285 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/config/HoodieHBaseIndexConfig.java x: 12 # contributors y: 364 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/restore/BaseRestoreActionExecutor.java x: 13 # contributors y: 117 lines of code hudi-integ-test/src/main/scala/org/apache/hudi/integ/testsuite/dag/nodes/SparkUpsertNode.scala x: 6 # contributors y: 17 lines of code hudi-kafka-connect/src/main/java/org/apache/hudi/connect/transaction/ConnectTransactionCoordinator.java x: 3 # contributors y: 347 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/CommitsCommand.java x: 22 # contributors y: 343 lines of code hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/compact/HoodieSparkMergeOnReadTableCompactor.java x: 13 # contributors y: 32 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/io/HoodieSortedMergeHandle.java x: 16 # contributors y: 81 lines of code hudi-spark-datasource/hudi-spark/src/main/java/org/apache/hudi/QuickstartUtils.java x: 8 # contributors y: 185 lines of code hudi-cli/src/main/java/org/apache/hudi/cli/commands/SavepointsCommand.java x: 18 # contributors y: 125 lines of code hudi-common/src/main/java/org/apache/hudi/common/model/ActionType.java x: 5 # contributors y: 4 lines of code hudi-common/src/main/java/org/apache/hudi/common/util/ObjectSizeCalculator.java x: 12 # contributors y: 7 lines of code hudi-common/src/main/java/org/apache/hudi/common/HoodieCleanStat.java x: 7 # contributors y: 159 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/DagUtils.java x: 10 # contributors y: 362 lines of code hudi-integ-test/src/main/java/org/apache/hudi/integ/testsuite/dag/scheduler/DagScheduler.java x: 11 # contributors y: 96 lines of code hudi-utilities/src/main/java/org/apache/hudi/utilities/sources/AvroDFSSource.java x: 11 # contributors y: 39 lines of code hudi-client/hudi-client-common/src/main/java/org/apache/hudi/table/action/commit/BucketType.java x: 4 # contributors y: 4 lines of code hudi-spark-datasource/hudi-spark2/src/main/antlr4/imports/SqlBase.g4 x: 1 # contributors y: 971 lines of code
2526.0
lines of code
  min: 2.0
  average: 102.12
  25th percentile: 22.0
  median: 49.0
  75th percentile: 114.0
  max: 2526.0
0 64.0
# contributors
min: 1.0 | average: 4.59 | 25th percentile: 1.0 | median: 3.0 | 75th percentile: 5.0 | max: 64.0