apache / gobblin
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,680 files with 192,809 lines of code.
    • 1 file changed more than 100 times (786 lines of code)
    • 9 files changed 51-100 times (1,832 lines of code)
    • 44 files changed 21-50 times (16,018 lines of code)
    • 308 files changed 6-20 times (52,287 lines of code)
    • 2,318 files changed 1-5 times (121,886 lines of code)
<1% | <1% | 8% | 27% | 63%
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,680 files with 192,809 lines of code.
    • 2 files changed by more than 25 contributors (799 lines of code)
    • 44 files changed by 11-25 contributors (13,960 lines of code)
    • 135 files changed by 6-10 contributors (30,435 lines of code)
    • 1,038 files changed by 2-5 contributors (90,348 lines of code)
    • 1,461 files changed by 1 contributor (57,267 lines of code)
<1% | 7% | 15% | 46% | 29%
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, gradle, md, json, properties, avsc, sh, xml, yaml, ddl, js, txt, sql, css, gitignore, py, html, groovy, dockerignore, bat, proto, xsl, svg
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java<1% | <1% | 8% | 26% | 63%
xml0% | 0% | 0% | 93% | 6%
js0% | 0% | 0% | 94% | 5%
css0% | 0% | 0% | 100% | 0%
html0% | 0% | 0% | 100% | 0%
sql0% | 0% | 0% | 74% | 25%
py0% | 0% | 0% | 10% | 89%
avsc0% | 0% | 0% | 0% | 100%
yaml0% | 0% | 0% | 0% | 100%
xsl0% | 0% | 0% | 0% | 100%
groovy0% | 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
gobblin-api12% | <1% | 2% | 9% | 75%
gobblin-service0% | 8% | 11% | 45% | 35%
gobblin-cluster0% | 9% | 28% | 39% | 22%
gobblin-runtime0% | <1% | 18% | 25% | 55%
gobblin-yarn0% | 0% | 56% | 25% | 17%
gobblin-data-management0% | 0% | 6% | 25% | 67%
gobblin-iceberg0% | 0% | 52% | 16% | 30%
gobblin-modules0% | 0% | 3% | 19% | 77%
gobblin-utility0% | 0% | 5% | 23% | 71%
gobblin-hive-registration0% | 0% | 14% | 40% | 45%
gobblin-metastore0% | 0% | 10% | 10% | 78%
gobblin-metrics-libs0% | 0% | 3% | 24% | 71%
gobblin-core0% | 0% | 0% | 26% | 73%
gobblin-compaction0% | 0% | 0% | 42% | 57%
gobblin-temporal0% | 0% | 0% | 41% | 58%
gobblin-admin0% | 0% | 0% | 66% | 33%
gobblin-salesforce0% | 0% | 0% | 70% | 29%
gobblin-restli0% | 0% | 0% | 29% | 70%
gobblin-docs0% | 0% | 0% | 100% | 0%
gobblin-core-base0% | 0% | 0% | 12% | 87%
gobblin-aws0% | 0% | 0% | 20% | 79%
gobblin-completeness0% | 0% | 0% | 54% | 45%
ligradle0% | 0% | 0% | 100% | 0%
maven-sonatype0% | 0% | 0% | 100% | 0%
gobblin-config-management0% | 0% | 0% | 0% | 100%
gobblin-example0% | 0% | 0% | 0% | 100%
gobblin-binary-management0% | 0% | 0% | 0% | 100%
gobblin-tunnel0% | 0% | 0% | 0% | 100%
gobblin-audit0% | 0% | 0% | 0% | 100%
gobblin-kubernetes0% | 0% | 0% | 0% | 100%
gobblin-rest-service0% | 0% | 0% | 0% | 100%
gradle0% | 0% | 0% | 0% | 100%
ROOT0% | 0% | 0% | 0% | 100%
gobblin-runtime-hadoop0% | 0% | 0% | 0% | 100%
conf0% | 0% | 0% | 0% | 100%
buildSrc0% | 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
ConfigurationKeys.java
in gobblin-api/src/main/java/org/apache/gobblin/configuration
 786 - 2017-07-30 2025-04-25 140 32 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
JobState.java
in gobblin-runtime/src/main/java/gobblin/runtime
 30 6 2015-02-18 2017-07-31 77 25 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
GobblinServiceJobScheduler.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler
 564 23 2017-07-30 2024-09-07 72 15 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
State.java
in gobblin-api/src/main/java/gobblin/configuration
 13 3 2015-02-18 2017-07-31 71 26 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
Orchestrator.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration
 229 14 2017-07-30 2024-11-19 70 15 abhishektiwari.btech@gmail.com vsinghal85@gmail.com
TaskState.java
in gobblin-runtime/src/main/java/gobblin/runtime
 3 - 2015-02-18 2017-08-30 65 23 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
GobblinServiceManager.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/core
 314 18 2017-07-30 2024-09-10 58 18 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
GobblinHelixJobLauncher.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 535 19 2017-07-30 2024-02-26 56 16 abhishektiwari.btech@gmail.com ckohn@linkedin.com
GobblinClusterConfigurationKeys.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 130 - 2017-07-30 2024-04-25 55 14 abhishektiwari.btech@gmail.com lo.william97@gmail.com
WorkUnitState.java
in gobblin-api/src/main/java/gobblin/configuration
 14 3 2015-02-18 2017-07-31 52 22 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
AbstractJobLauncher.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 840 40 2017-07-30 2024-12-24 49 18 abhishektiwari.btech@gmail.com ckohn@linkedin.com
GobblinTaskRunner.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 612 43 2017-07-30 2022-11-21 44 11 abhishektiwari.btech@gmail.com umust77@gmail.com
KafkaJobStatusMonitor.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 329 14 2019-02-05 2024-09-07 42 14 suvasude@linkedin.biz arjun4084346@gmail.com
YarnService.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 840 39 2017-07-30 2024-05-30 42 13 abhishektiwari.btech@gmail.com pradeeppallikila1234@gmail.com
WorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 24 5 2015-02-19 2017-07-31 38 16 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
JobExecutionPlan.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec
 175 13 2018-07-30 2025-04-25 37 9 suvasude@linkedin.biz thesingh.adi.work@gmail.com
GobblinYarnAppLauncher.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 815 31 2017-07-30 2025-01-29 37 13 abhishektiwari.btech@gmail.com abhishekmjain97@gmail.com
SourceState.java
in gobblin-api/src/main/java/gobblin/configuration
 24 4 2015-02-18 2017-07-31 36 14 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
ServiceConfigKeys.java
in gobblin-api/src/main/java/org/apache/gobblin/service
 93 - 2017-09-12 2024-09-10 36 14 autumnust@gmail.com arjun4084346@gmail.com
DagActionStoreChangeMonitor.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 171 9 2022-10-17 2024-09-10 35 6 umust77@gmail.com arjun4084346@gmail.com
GobblinClusterManager.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 389 29 2017-07-30 2023-06-30 35 10 abhishektiwari.btech@gmail.com 112960226+peiyingy@users.no...
FlowCatalog.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog
 333 33 2017-07-30 2024-09-07 33 12 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
MultiHopFlowCompiler.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow
 284 13 2018-07-30 2023-11-22 32 8 suvasude@linkedin.biz ckohn@linkedin.com
KafkaSource.java
in gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka
 806 33 2017-07-30 2024-08-06 32 16 abhishektiwari.btech@gmail.com 9762455+arpit09@users.norep...
IcebergMetadataWriter.java
in gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer
 949 42 2021-02-04 2024-06-03 31 11 zihli@linkedin.com pradeeppallikila1234@gmail.com
GobblinServiceGuiceModule.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/core
 200 5 2021-06-08 2024-09-10 30 7 aprokofiev@linkedin.com arjun4084346@gmail.com
GobblinHelixJobScheduler.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 432 17 2017-07-30 2024-01-04 30 7 abhishektiwari.btech@gmail.com nate.hanghang.liu@gmail.com
HelixUtils.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 333 19 2017-07-30 2023-06-30 28 10 abhishektiwari.btech@gmail.com 112960226+peiyingy@users.no...
FileAwareInputStreamDataWriter.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer
 378 20 2017-07-30 2024-07-17 28 14 abhishektiwari.btech@gmail.com lo.william97@gmail.com
MRJobLauncher.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce
 687 32 2017-07-30 2024-09-17 28 17 abhishektiwari.btech@gmail.com lo.william97@gmail.com
MultiWorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 7 1 2015-02-19 2017-07-31 26 15 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
KafkaAvroJobStatusMonitor.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 153 4 2019-02-05 2024-05-29 26 10 suvasude@linkedin.biz abora@linkedin.com
TimingEvent.java
in gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event
 161 9 2017-07-30 2025-01-02 26 11 abhishektiwari.btech@gmail.com ckohn@linkedin.com
AvroUtils.java
in gobblin-utility/src/main/java/org/apache/gobblin/util
 753 47 2017-07-30 2022-10-19 26 16 abhishektiwari.btech@gmail.com bohravikram@gmail.com
GobblinYarnConfigurationKeys.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 102 - 2017-07-30 2024-11-14 24 11 abhishektiwari.btech@gmail.com abhishekmjain97@gmail.com
JobStatusRetriever.java
in gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring
 173 15 2017-07-30 2024-06-28 24 11 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
GobblinMultiTaskAttempt.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 460 20 2017-07-30 2024-01-31 24 14 abhishektiwari.btech@gmail.com mho@linkedin.com
ServiceMetricNames.java
in gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics
 62 - 2019-05-24 2024-09-07 23 8 abora@linkedin.com arjun4084346@gmail.com
FlowStatusGenerator.java
in gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring
 92 7 2017-07-30 2024-08-29 23 9 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
MysqlStateStore.java
in gobblin-metastore/src/main/java/org/apache/gobblin/metastore
 429 23 2017-07-30 2024-07-18 23 10 abhishektiwari.btech@gmail.com abora@linkedin.com
HiveMetaStoreBasedRegister.java
in gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore
 645 38 2017-07-30 2022-01-14 23 9 abhishektiwari.btech@gmail.com lo.william97@gmail.com
DagManagementTaskStreamImpl.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration
 163 9 2024-03-09 2024-11-13 22 4 abora@linkedin.com ckohn@linkedin.com
GobblinHelixTask.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 183 6 2017-07-30 2023-06-02 22 10 abhishektiwari.btech@gmail.com zihli@linkedin.com
GobblinApplicationMaster.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 188 16 2017-07-30 2024-03-15 22 9 abhishektiwari.btech@gmail.com mho@linkedin.com
AzkabanJobLauncher.java
in gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban
 297 11 2017-07-30 2025-04-25 22 17 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
GobblinMCEWriter.java
in gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer
 454 21 2021-02-04 2024-03-27 22 6 zihli@linkedin.com zihli@linkedin.com
Task.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 759 43 2017-07-30 2024-08-06 22 15 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
ImmutableWorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 6 1 2015-02-19 2017-07-31 21 17 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
CopyableFile.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy
 315 22 2017-07-30 2024-06-27 21 11 abhishektiwari.btech@gmail.com lo.william97@gmail.com
CopyDataPublisher.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher
 316 23 2017-07-30 2024-10-08 21 11 abhishektiwari.btech@gmail.com lo.william97@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
ConfigurationKeys.java
in gobblin-api/src/main/java/org/apache/gobblin/configuration
 786 - 2017-07-30 2025-04-25 140 32 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
State.java
in gobblin-api/src/main/java/gobblin/configuration
 13 3 2015-02-18 2017-07-31 71 26 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
JobState.java
in gobblin-runtime/src/main/java/gobblin/runtime
 30 6 2015-02-18 2017-07-31 77 25 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
TaskState.java
in gobblin-runtime/src/main/java/gobblin/runtime
 3 - 2015-02-18 2017-08-30 65 23 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
WorkUnitState.java
in gobblin-api/src/main/java/gobblin/configuration
 14 3 2015-02-18 2017-07-31 52 22 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
GobblinServiceManager.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/core
 314 18 2017-07-30 2024-09-10 58 18 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
AbstractJobLauncher.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 840 40 2017-07-30 2024-12-24 49 18 abhishektiwari.btech@gmail.com ckohn@linkedin.com
MRJobLauncher.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce
 687 32 2017-07-30 2024-09-17 28 17 abhishektiwari.btech@gmail.com lo.william97@gmail.com
AzkabanJobLauncher.java
in gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban
 297 11 2017-07-30 2025-04-25 22 17 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
ImmutableWorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 6 1 2015-02-19 2017-07-31 21 17 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
GobblinHelixJobLauncher.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 535 19 2017-07-30 2024-02-26 56 16 abhishektiwari.btech@gmail.com ckohn@linkedin.com
WorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 24 5 2015-02-19 2017-07-31 38 16 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
KafkaSource.java
in gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka
 806 33 2017-07-30 2024-08-06 32 16 abhishektiwari.btech@gmail.com 9762455+arpit09@users.norep...
AvroUtils.java
in gobblin-utility/src/main/java/org/apache/gobblin/util
 753 47 2017-07-30 2022-10-19 26 16 abhishektiwari.btech@gmail.com bohravikram@gmail.com
GobblinServiceJobScheduler.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler
 564 23 2017-07-30 2024-09-07 72 15 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
Orchestrator.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration
 229 14 2017-07-30 2024-11-19 70 15 abhishektiwari.btech@gmail.com vsinghal85@gmail.com
MultiWorkUnit.java
in gobblin-api/src/main/java/gobblin/source/workunit
 7 1 2015-02-19 2017-07-31 26 15 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
Task.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 759 43 2017-07-30 2024-08-06 22 15 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
GobblinClusterConfigurationKeys.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 130 - 2017-07-30 2024-04-25 55 14 abhishektiwari.btech@gmail.com lo.william97@gmail.com
KafkaJobStatusMonitor.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 329 14 2019-02-05 2024-09-07 42 14 suvasude@linkedin.biz arjun4084346@gmail.com
ServiceConfigKeys.java
in gobblin-api/src/main/java/org/apache/gobblin/service
 93 - 2017-09-12 2024-09-10 36 14 autumnust@gmail.com arjun4084346@gmail.com
SourceState.java
in gobblin-api/src/main/java/gobblin/configuration
 24 4 2015-02-18 2017-07-31 36 14 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
FileAwareInputStreamDataWriter.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer
 378 20 2017-07-30 2024-07-17 28 14 abhishektiwari.btech@gmail.com lo.william97@gmail.com
GobblinMultiTaskAttempt.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 460 20 2017-07-30 2024-01-31 24 14 abhishektiwari.btech@gmail.com mho@linkedin.com
findbugsExclude.xml
in ligradle/findbugs
 33 - 2015-04-16 2023-09-06 20 14 chavdar@users.noreply.githu... zihli@linkedin.com
ImmutableWorkUnitState.java
in gobblin-api/src/main/java/gobblin/configuration
 6 1 2015-07-16 2017-07-31 18 14 liyinan926@users.noreply.gi... abhishektiwari.btech@gmail.com
YarnService.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 840 39 2017-07-30 2024-05-30 42 13 abhishektiwari.btech@gmail.com pradeeppallikila1234@gmail.com
GobblinYarnAppLauncher.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 815 31 2017-07-30 2025-01-29 37 13 abhishektiwari.btech@gmail.com abhishekmjain97@gmail.com
CopySource.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy
 434 21 2017-07-30 2024-04-12 21 13 abhishektiwari.btech@gmail.com ckohn@linkedin.com
Watermark.java
in gobblin-api/src/main/java/gobblin/source/extractor
 3 - 2015-04-29 2017-07-31 20 13 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
HiveRegProps.java
in gobblin-hive-registration/src/main/java/gobblin/hive
 10 2 2016-01-13 2017-07-31 18 13 ziliu@linkedin.com abhishektiwari.btech@gmail.com
Extract.java
in gobblin-api/src/main/java/gobblin/source/workunit
 26 3 2015-02-19 2017-07-31 18 13 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
FlowCatalog.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog
 333 33 2017-07-30 2024-09-07 33 12 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
WatermarkInterval.java
in gobblin-api/src/main/java/gobblin/source/extractor
 6 1 2015-05-04 2017-07-31 16 12 takiar.sahil@gmail.com abhishektiwari.btech@gmail.com
GobblinTaskRunner.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 612 43 2017-07-30 2022-11-21 44 11 abhishektiwari.btech@gmail.com umust77@gmail.com
IcebergMetadataWriter.java
in gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer
 949 42 2021-02-04 2024-06-03 31 11 zihli@linkedin.com pradeeppallikila1234@gmail.com
TimingEvent.java
in gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event
 161 9 2017-07-30 2025-01-02 26 11 abhishektiwari.btech@gmail.com ckohn@linkedin.com
JobStatusRetriever.java
in gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring
 173 15 2017-07-30 2024-06-28 24 11 abhishektiwari.btech@gmail.com thesingh.adi.work@gmail.com
GobblinYarnConfigurationKeys.java
in gobblin-yarn/src/main/java/org/apache/gobblin/yarn
 102 - 2017-07-30 2024-11-14 24 11 abhishektiwari.btech@gmail.com abhishekmjain97@gmail.com
Fork.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork
 448 33 2017-07-30 2024-08-06 21 11 abhishektiwari.btech@gmail.com arjun4084346@gmail.com
CopyableFile.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy
 315 22 2017-07-30 2024-06-27 21 11 abhishektiwari.btech@gmail.com lo.william97@gmail.com
CopyDataPublisher.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher
 316 23 2017-07-30 2024-10-08 21 11 abhishektiwari.btech@gmail.com lo.william97@gmail.com
JobContext.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime
 370 29 2017-07-30 2024-05-23 18 11 abhishektiwari.btech@gmail.com lo.william97@gmail.com
KafkaExtractor.java
in gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka
 261 17 2017-07-30 2023-08-21 17 11 abhishektiwari.btech@gmail.com zihli@linkedin.com
FsDataWriter.java
in gobblin-core/src/main/java/org/apache/gobblin/writer
 231 15 2017-07-30 2022-03-07 14 11 abhishektiwari.btech@gmail.com abora@linkedin.com
index.html
in gobblin-admin/src/main/resources/static
 234 - 2016-01-09 2017-07-27 13 11 eric@nerdwallet.com joel.baranick@ensighten.com
GobblinClusterManager.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 389 29 2017-07-30 2023-06-30 35 10 abhishektiwari.btech@gmail.com 112960226+peiyingy@users.no...
HelixUtils.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 333 19 2017-07-30 2023-06-30 28 10 abhishektiwari.btech@gmail.com 112960226+peiyingy@users.no...
KafkaAvroJobStatusMonitor.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 153 4 2019-02-05 2024-05-29 26 10 suvasude@linkedin.biz abora@linkedin.com
MysqlStateStore.java
in gobblin-metastore/src/main/java/org/apache/gobblin/metastore
 429 23 2017-07-30 2024-07-18 23 10 abhishektiwari.btech@gmail.com abora@linkedin.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
DatabaseJobHistoryStoreV101.java
in gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database
 878 33 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
DatabaseJobHistoryStoreV100.java
in gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database
 750 25 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
KafkaWrapper.java
in gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka
 429 41 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
TypeDescriptionToObjectInspectorUtil.java
in gobblin-hive-registration/src/main/java/org/apache/hadoop/hive/ql/io/orc
 367 40 2021-08-18 2021-08-18 1 1 zihli@linkedin.com zihli@linkedin.com
JsonElementConversionFactory.java
in gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet
 349 39 2019-12-25 2019-12-25 1 1 sdas@linkedin.com sdas@linkedin.com
GitMonitoringService.java
in gobblin-service/src/main/java/org/apache/gobblin/service/monitoring
 334 16 2022-08-31 2022-08-31 1 1 lo.william97@gmail.com lo.william97@gmail.com
WikipediaExtractor.java
in gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia
 332 19 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
AWSSdkClient.java
in gobblin-aws/src/main/java/org/apache/gobblin/aws
 308 16 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
ReflectivePredicateEvaluator.java
in gobblin-runtime/src/main/java/org/apache/gobblin/util
 266 17 2019-03-04 2019-03-04 1 1 issac.buenrostro@gmail.com issac.buenrostro@gmail.com
SerialCompactor.java
in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hive
 266 25 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
MRStressTest.java
in gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest
 257 17 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
AvroTestTools.java
in gobblin-binary-management/src/main/java/org/apache/gobblin/binary_creation
 255 14 2019-03-07 2019-03-14 2 1 lesun@lesun-mn3.linkedin.biz lesun@lesun-mn3.linkedin.biz
HivePurgerSource.java
in gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger
 251 20 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
OutputStreamReporter.java
in gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter
 250 18 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
SalesforceHistogramService.java
in gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce
 248 10 2023-09-13 2023-09-22 2 1 gautamguptabasant@gmail.com gautamguptabasant@gmail.com
GoogleDriveFileSystem.java
in gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google
 238 20 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
RotatingAESCodec.java
in gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/crypto
 236 15 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
GlobalMetadata.java
in gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types
 234 30 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
StandardGobblinInstanceLauncher.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance
 228 32 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
AzkabanJobHelper.java
in gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration
 226 12 2017-08-08 2017-10-26 3 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
MySqlMultiContextIssueRepository.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/troubleshooter
 223 12 2021-08-12 2021-08-12 1 1 aprokofiev@linkedin.com aprokofiev@linkedin.com
BaseFlowGraphHelper.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph
 211 14 2022-10-04 2024-05-07 4 1 lo.william97@gmail.com lo.william97@gmail.com
ZuoraExtractor.java
in gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora
 210 16 2019-02-01 2019-02-01 1 1 almightygc@gmail.com almightygc@gmail.com
DagUtils.java
in gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration
 208 25 2024-09-07 2024-09-07 1 1 arjun4084346@gmail.com arjun4084346@gmail.com
ZuoraClientImpl.java
in gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora
 203 8 2019-02-01 2019-02-01 1 1 almightygc@gmail.com almightygc@gmail.com
ConfigBasedDatasetsFinder.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication
 199 8 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
JsonSchema.java
in gobblin-core/src/main/java/org/apache/gobblin/converter/json
 198 20 2017-10-18 2017-10-18 1 1 tilakpatidar@gmail.com tilakpatidar@gmail.com
ScalingDirectiveParser.java
in gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic
 190 11 2024-11-19 2024-12-24 2 1 ckohn@linkedin.com ckohn@linkedin.com
KafkaSimpleStreamingExtractor.java
in gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka
 185 17 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
AvroExternalTable.java
in gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hive
 183 20 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
TimePartitionGlobFinder.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset
 182 10 2019-12-21 2020-01-03 2 1 zhchen@linkedin.com zhchen@linkedin.com
ParquetGroup.java
in gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet
 182 31 2019-12-25 2019-12-25 1 1 sdas@linkedin.com sdas@linkedin.com
InfluxDBReporter.java
in gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb
 181 21 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
JobInfoPrintUtils.java
in gobblin-admin/src/main/java/org/apache/gobblin/cli
 179 6 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
GraphiteReporter.java
in gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite
 172 22 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
FileBasedJobLockFactory.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks
 166 19 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
IcebergPartitionDataset.java
in gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg
 166 8 2024-10-23 2024-10-23 1 1 43493515+blazer-007@users.n... 43493515+blazer-007@users.n...
PublicMethodsCliObjectFactory.java
in gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli
 164 8 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
GoogleCommon.java
in gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google
 162 14 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
HivePartitionVersionRetentionReaper.java
in gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention
 156 10 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
ReadWriteHandler.java
in gobblin-tunnel/src/main/java/org/apache/gobblin/tunnel
 156 4 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
RestorableHivePartitionDataset.java
in gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore
 155 12 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
ElasticsearchRestWriter.java
in gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer
 155 8 2018-09-01 2019-04-02 2 1 sdas@linkedin.com sdas@linkedin.com
SimpleHadoopFilesystemConfigStoreFactory.java
in gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs
 154 15 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
xsl
rat-output-to-html.xsl
in gradle/resources
 153 - 2018-01-03 2018-01-03 1 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
FutureCallbackHolder.java
in gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer
 151 2 2018-09-01 2018-09-01 1 1 sdas@linkedin.com sdas@linkedin.com
JobListeners.java
in gobblin-runtime/src/main/java/org/apache/gobblin/runtime/listeners
 149 9 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
AbstractHttpWriter.java
in gobblin-core/src/main/java/org/apache/gobblin/writer/http
 149 18 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
SimpleKafkaConsumer.java
in gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/tool
 148 5 2017-07-30 2017-07-31 2 1 abhishektiwari.btech@gmail.com abhishektiwari.btech@gmail.com
ContainerHealthMetricsService.java
in gobblin-cluster/src/main/java/org/apache/gobblin/cluster
 147 6 2019-09-16 2020-01-16 3 1 sudarshanv@gmail.com sudarshanv@gmail.com
Correlations

File Size vs. Number of Changes: 2681 points

gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ManifestBasedDataset.java x: 171 lines of code y: 17 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/OwnerAndPermission.java x: 64 lines of code y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java x: 786 lines of code y: 140 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java x: 297 lines of code y: 22 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlan.java x: 175 lines of code y: 37 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/assistance/Help.java x: 203 lines of code y: 10 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java x: 37 lines of code y: 5 # changes gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java x: 25 lines of code y: 3 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GaaSJobObservabilityEvent.avsc x: 275 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DatasetTaskSummary.java x: 23 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTable.java x: 223 lines of code y: 16 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java x: 100 lines of code y: 7 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/TemporalMetricsHelper.java x: 78 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/DagTask.java x: 41 lines of code y: 10 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/GobblinTemporalConfigurationKeys.java x: 69 lines of code y: 12 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/ProcessWorkUnitImpl.java x: 203 lines of code y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/RecommendScalingForWorkUnitsLinearHeuristicImpl.java x: 53 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/worker/WorkFulfillmentWorker.java x: 47 lines of code y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java x: 217 lines of code y: 17 # changes gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java x: 165 lines of code y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java x: 43 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java x: 243 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java x: 40 lines of code y: 8 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/ActivityType.java x: 65 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/CommitStepWorkflowImpl.java x: 44 lines of code y: 8 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/NestingExecOfProcessWorkUnitWorkflowImpl.java x: 17 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/loadgen/workflow/impl/NestingExecOfIllustrationItemActivityWorkflowImpl.java x: 18 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/TemporalEventTimer.java x: 84 lines of code y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ProcessWorkUnitsWorkflowImpl.java x: 115 lines of code y: 15 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/helloworld/GreetingWorkflowImpl.java x: 24 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/CommitActivityImpl.java x: 222 lines of code y: 11 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/GenerateWorkUnitsImpl.java x: 248 lines of code y: 13 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ProcessWorkUnitsJobLauncher.java x: 76 lines of code y: 11 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/util/JobStateUtils.java x: 145 lines of code y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WUProcessingSpec.java x: 52 lines of code y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/CommitStepWorkflow.java x: 11 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/ProcessWorkUnitsWorkflow.java x: 12 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/loadgen/launcher/GenArbitraryLoadJobLauncher.java x: 53 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/NestingExecWorkloadInput.java x: 21 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java x: 125 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/NestingExecWorkflow.java x: 10 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java x: 120 lines of code y: 16 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/AbstractDynamicScalingYarnServiceManager.java x: 79 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/DynamicScalingYarnService.java x: 184 lines of code y: 8 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java x: 589 lines of code y: 12 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java x: 321 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinJobLauncher.java x: 203 lines of code y: 7 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncher.java x: 133 lines of code y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java x: 231 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/client/TemporalWorkflowClientFactory.java x: 95 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/service/ManagedWorkflowServiceStubs.java x: 28 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java x: 815 lines of code y: 37 # changes gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java x: 58 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java x: 29 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java x: 63 lines of code y: 3 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java x: 258 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/Workload.java x: 15 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WorkUnitsSizeSummary.java x: 60 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergDatasetFinder.java x: 123 lines of code y: 9 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java x: 161 lines of code y: 26 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FsSpecConsumer.java x: 125 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/BaseFlowToJobSpecCompiler.java x: 231 lines of code y: 20 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/template/StaticFlowTemplate.java x: 153 lines of code y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventTimer.java x: 18 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java x: 840 lines of code y: 49 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalClusterManager.java x: 268 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/RecommendScalingForWorkUnits.java x: 14 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/AbstractRecommendScalingForWorkUnitsImpl.java x: 40 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/CommitStats.java x: 23 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/DatasetStats.java x: 17 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/DirDeletionResult.java x: 19 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/ExecGobblinStats.java x: 18 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/TimeBudget.java x: 18 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WorkUnitClaimCheck.java x: 37 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/FsScalingDirectiveSource.java x: 92 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/FsScalingDirectivesRecipient.java x: 39 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ProfileDerivation.java x: 37 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ProfileOverlay.java x: 139 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirective.java x: 39 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirectiveParser.java x: 190 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirectivesRecipient.java x: 6 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforcePlan.java x: 106 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/WorkflowAddr.java x: 35 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/FsSourceDynamicScalingYarnServiceManager.java x: 42 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/WorkUnitSizeInfo.java x: 81 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagProcessingEngine.java x: 119 lines of code y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java x: 62 lines of code y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProcUtils.java x: 267 lines of code y: 18 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java x: 259 lines of code y: 14 # changes gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/JobCommitPolicy.java x: 36 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/exception/FailedDatasetUrnsException.java x: 19 lines of code y: 1 # changes gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutoTroubleshooterLogAppender.java x: 118 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/GenerateWorkUnits.java x: 14 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/EagerFsDirBackedWorkUnitClaimCheckWorkload.java x: 47 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/PriorJobStateWUProcessingSpec.java x: 46 lines of code y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirectiveSource.java x: 6 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java x: 216 lines of code y: 11 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkerProfile.java x: 13 lines of code y: 2 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/modules/restli/FlowConfigsV2ResourceHandler.java x: 293 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TooSoonToRerunSameFlowException.java x: 17 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementStateStore.java x: 59 lines of code y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/InstrumentedLeaseArbiter.java x: 73 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MultiActiveLeaseArbiter.java x: 9 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MySqlDagManagementStateStore.java x: 192 lines of code y: 8 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java x: 477 lines of code y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java x: 229 lines of code y: 70 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforceProfiles.java x: 50 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforceStaffing.java x: 69 lines of code y: 1 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java x: 73 lines of code y: 11 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanLauncherUtils.java x: 24 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java x: 102 lines of code y: 24 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsV2Resource.java x: 209 lines of code y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagActionReminderScheduler.java x: 130 lines of code y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementTaskStreamImpl.java x: 163 lines of code y: 22 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/FlowLaunchHandler.java x: 179 lines of code y: 15 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/LeaseAttemptStatus.java x: 42 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagManagementDagActionStoreChangeMonitor.java x: 75 lines of code y: 16 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTableMetadataValidatorUtils.java x: 48 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/BaseIcebergCatalog.java x: 39 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergCatalog.java x: 13 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergOverwritePartitionsStep.java x: 110 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionDataset.java x: 166 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/predicates/IcebergMatchesAnyPropNamePartitionFilterPredicate.java x: 23 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/predicates/IcebergPartitionFilterPredicateUtil.java x: 33 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java x: 262 lines of code y: 5 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java x: 187 lines of code y: 17 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java x: 316 lines of code y: 21 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SafeDatasetCommit.java x: 322 lines of code y: 21 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java x: 226 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ExecuteGobblinJobLauncher.java x: 72 lines of code y: 7 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/GenerateWorkUnitsJobLauncher.java x: 54 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java x: 687 lines of code y: 28 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/HdfsJarUploadUtils.java x: 37 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/util/TemporalWorkFlowUtils.java x: 31 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/helloworld/HelloWorldJobLauncher.java x: 34 lines of code y: 5 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanClient.java x: 367 lines of code y: 14 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/DeleteWorkDirsActivityImpl.java x: 68 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/Dag.java x: 202 lines of code y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java x: 199 lines of code y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/MysqlJobStatusRetriever.java x: 88 lines of code y: 12 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/DeleteWorkDirsActivity.java x: 12 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/GenerateWorkUnitsWorkflowImpl.java x: 30 lines of code y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java x: 93 lines of code y: 36 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowExecutionResource.java x: 168 lines of code y: 12 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java x: 47 lines of code y: 15 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/InjectionNames.java x: 4 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceConfiguration.java x: 47 lines of code y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceGuiceModule.java x: 200 lines of code y: 30 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java x: 314 lines of code y: 58 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/restli/FlowExecutionResourceHandler.java x: 101 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java x: 171 lines of code y: 35 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java x: 137 lines of code y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MultiActiveLeaseArbiterFactory.java x: 29 lines of code y: 2 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/ServiceMetricNames.java x: 62 lines of code y: 23 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java x: 333 lines of code y: 33 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/AbstractUserQuotaManager.java x: 59 lines of code y: 5 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagActionStore.java x: 76 lines of code y: 12 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagerMetrics.java x: 192 lines of code y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagStateStore.java x: 25 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagStateStoreWithDagNodes.java x: 12 lines of code y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagUtils.java x: 208 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/FSDagStateStore.java x: 120 lines of code y: 11 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/InMemoryUserQuotaManager.java x: 210 lines of code y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlDagStateStoreWithDagNodes.java x: 186 lines of code y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlUserQuotaManager.java x: 406 lines of code y: 9 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/UserQuotaManager.java x: 11 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceFlowFinishDeadlineDagProc.java x: 38 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/LaunchDagProc.java x: 56 lines of code y: 15 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/ReevaluateDagProc.java x: 108 lines of code y: 16 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/ResumeDagProc.java x: 58 lines of code y: 9 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/EnforceFlowFinishDeadlineDagTask.java x: 14 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java x: 564 lines of code y: 72 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanDagFactory.java x: 58 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanListSerializer.java x: 61 lines of code y: 5 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java x: 329 lines of code y: 42 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitorFactory.java x: 73 lines of code y: 10 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java x: 287 lines of code y: 10 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetricsBase.java x: 31 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java x: 92 lines of code y: 23 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/Trash.java x: 229 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TrashFactory.java x: 59 lines of code y: 4 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java x: 732 lines of code y: 10 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java x: 189 lines of code y: 9 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java x: 107 lines of code y: 3 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java x: 163 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java x: 207 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java x: 460 lines of code y: 8 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/TimingEventUtils.java x: 51 lines of code y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/KillDagProc.java x: 49 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDataset.java x: 182 lines of code y: 20 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/GobblinKafkaConsumerClient.java x: 63 lines of code y: 7 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java x: 806 lines of code y: 32 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java x: 759 lines of code y: 22 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java x: 448 lines of code y: 21 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagProcFactory.java x: 55 lines of code y: 8 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DeadlineEnforcementDagProc.java x: 48 lines of code y: 5 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ExceptionUtils.java x: 26 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/DagProcessingEngineMetrics.java x: 132 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/InMemorySpecExecutor.java x: 47 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanListDeserializer.java x: 87 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/SerializationConstants.java x: 18 lines of code y: 5 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/predicates/DatasetHiveSchemaContainsNonOptionalUnion.java x: 72 lines of code y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/NoopGaaSJobObservabilityEventProducer.java x: 19 lines of code y: 2 # changes gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql x: 102 lines of code y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlDagActionStore.java x: 134 lines of code y: 9 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/finder/CleanableHiveDatasetFinder.java x: 31 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java x: 431 lines of code y: 16 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java x: 429 lines of code y: 23 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/retry/RetryerFactory.java x: 115 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java x: 378 lines of code y: 28 # changes gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/CreateDirectoryWithPermissionsCommitStep.java x: 51 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlSpecStore.java x: 132 lines of code y: 13 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java x: 153 lines of code y: 20 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergRegisterStep.java x: 121 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagement.java x: 5 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java x: 173 lines of code y: 24 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/FsJobStatusRetriever.java x: 130 lines of code y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/LocalFsJobStatusRetriever.java x: 103 lines of code y: 8 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyableFile.java x: 315 lines of code y: 21 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/SubsetFilesCopyableDataset.java x: 81 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelper.java x: 607 lines of code y: 17 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergDataset.java x: 266 lines of code y: 13 # changes gobblin-data-management/src/main/java/org/apache/gobblin/util/commit/SetPermissionCommitStep.java x: 53 lines of code y: 3 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java x: 604 lines of code y: 14 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java x: 112 lines of code y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/FlowGraphPath.java x: 127 lines of code y: 9 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/ChangeMonitorUtils.java x: 24 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java x: 382 lines of code y: 21 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.java x: 108 lines of code y: 8 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java x: 542 lines of code y: 7 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java x: 158 lines of code y: 3 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java x: 949 lines of code y: 31 # changes gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java x: 36 lines of code y: 9 # changes gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriterConfigurationKeys.java x: 37 lines of code y: 7 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnEventConstants.java x: 26 lines of code y: 3 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAutoScalingManager.java x: 374 lines of code y: 16 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java x: 840 lines of code y: 42 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java x: 153 lines of code y: 26 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobContext.java x: 370 lines of code y: 18 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/DagActionStoreChangeEvent.avsc x: 55 lines of code y: 5 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagTaskVisitor.java x: 15 lines of code y: 5 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/publisher/GobblinMCEPublisher.java x: 183 lines of code y: 12 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java x: 105 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowGraphHelper.java x: 211 lines of code y: 4 # changes gobblin-api/src/main/java/org/apache/gobblin/source/extractor/ComparableWatermark.java x: 4 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java x: 90 lines of code y: 7 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java x: 562 lines of code y: 11 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java x: 130 lines of code y: 55 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java x: 143 lines of code y: 12 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java x: 75 lines of code y: 6 # changes gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java x: 392 lines of code y: 15 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java x: 434 lines of code y: 21 # changes gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/FlushingExtractor.java x: 254 lines of code y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java x: 102 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java x: 142 lines of code y: 4 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/GobblinMCEProducer.java x: 255 lines of code y: 9 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/Utils/IcebergUtils.java x: 209 lines of code y: 4 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java x: 454 lines of code y: 22 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinMetadataChangeEvent.avsc x: 304 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/predicates/AlwaysFalse.java x: 9 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/AbstractTokenRefresher.java x: 115 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/AbstractYarnAppSecurityManager.java x: 29 lines of code y: 6 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java x: 188 lines of code y: 22 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManagerWithKeytabs.java x: 87 lines of code y: 5 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/helix/HelixClusterLifecycleManager.java x: 131 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/helix/HelixInstancePurgerWithMetrics.java x: 102 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java x: 93 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/finder/GlobModTimeDatasetVersionFinder.java x: 41 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/GlobModTimeDatasetVersionFinder.java x: 51 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java x: 62 lines of code y: 19 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagTaskStream.java x: 5 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/SubmitGTEActivityImpl.java x: 24 lines of code y: 2 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java x: 535 lines of code y: 56 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/AbstractTemporalWorker.java x: 45 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/UnixTimestampRecursiveCopyableDataset.java x: 120 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java x: 219 lines of code y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/NoWorkUnitsInfiniteSource.java x: 56 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergSnapshotInfo.java x: 41 lines of code y: 5 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixRetriggeringJobCallable.java x: 291 lines of code y: 15 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java x: 183 lines of code y: 4 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/EventSubmitter.java x: 114 lines of code y: 7 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/GobblinMultiTaskAttempt.java x: 460 lines of code y: 24 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java x: 99 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/helloworld/HelloWorldWorker.java x: 23 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/assistance/MDCContextPropagator.java x: 45 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyConfiguration.java x: 102 lines of code y: 9 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/StreamModelTaskRunner.java x: 120 lines of code y: 9 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/LoggingUncaughtExceptionHandler.java x: 22 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java x: 169 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java x: 171 lines of code y: 8 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java x: 432 lines of code y: 30 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaTopicGroupingWorkUnitPacker.java x: 267 lines of code y: 10 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java x: 94 lines of code y: 5 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java x: 246 lines of code y: 12 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskStateCollectorService.java x: 231 lines of code y: 13 # changes gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java x: 200 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/DatasetDescriptorConfigKeys.java x: 33 lines of code y: 9 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/MultiHopFlowCompiler.java x: 284 lines of code y: 32 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/lineage/LineageEventBuilder.java x: 93 lines of code y: 6 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/lineage/LineageInfo.java x: 194 lines of code y: 11 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GobblinBaseOrcWriter.java x: 301 lines of code y: 15 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaStreamingExtractor.java x: 486 lines of code y: 9 # changes gobblin-api/src/main/java/org/apache/gobblin/source/workunit/MultiWorkUnit.java x: 83 lines of code y: 5 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/InstrumentedGobblinOrcWriter.java x: 48 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlBaseSpecStore.java x: 285 lines of code y: 8 # changes gobblin-runtime/src/main/java/org/apache/gobblin/util/DBStatementExecutor.java x: 67 lines of code y: 1 # changes gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java x: 258 lines of code y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/styles/FileSystemJobStateful.java x: 3 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/WorkerConfig.java x: 30 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/SeqSliceBackedWorkSpan.java x: 44 lines of code y: 1 # changes gobblin-completeness/src/main/java/org/apache/gobblin/completeness/verifier/KafkaAuditCountVerifier.java x: 155 lines of code y: 6 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaIngestionHealthCheck.java x: 116 lines of code y: 4 # changes gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java x: 214 lines of code y: 6 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/SingleTask.java x: 164 lines of code y: 14 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java x: 275 lines of code y: 7 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java x: 65 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/client/AbstractBaseKafkaConsumerClient.java x: 104 lines of code y: 11 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/validator/TopicValidators.java x: 74 lines of code y: 1 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java x: 130 lines of code y: 3 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GenericRecordToOrcValueWriter.java x: 355 lines of code y: 10 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/OrcConverterMemoryManager.java x: 112 lines of code y: 2 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobSchedulerMetrics.java x: 64 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalPlanningJobLauncherMetrics.java x: 42 lines of code y: 1 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/helloworld/FormatActivityImpl.java x: 7 lines of code y: 1 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java x: 71 lines of code y: 7 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobTask.java x: 185 lines of code y: 10 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/BulkResultIterator.java x: 163 lines of code y: 3 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java x: 779 lines of code y: 20 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceHistogramService.java x: 248 lines of code y: 2 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java x: 355 lines of code y: 17 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/JobConfigurationUtils.java x: 55 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionOrcJobConfigurator.java x: 72 lines of code y: 5 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcKeyCompactorOutputFormat.java x: 40 lines of code y: 4 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/CompletenessWatermarkUpdater.java x: 203 lines of code y: 3 # changes ligradle/findbugs/findbugsExclude.xml x: 33 lines of code y: 20 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java x: 415 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaTopic.java x: 35 lines of code y: 4 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java x: 385 lines of code y: 19 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/DataFlowTopology.java x: 45 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ReplicaHadoopFsEndPoint.java x: 155 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/WatermarkMetadataGenerationCommitStep.java x: 54 lines of code y: 3 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/spec/SimpleHiveSpec.java x: 80 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalogListener.java x: 65 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java x: 216 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionStateListener.java x: 77 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java x: 56 lines of code y: 6 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/writer/HiveMetadataWriter.java x: 410 lines of code y: 20 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/KafkaCommonUtil.java x: 59 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java x: 261 lines of code y: 17 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java x: 233 lines of code y: 3 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/orc/HiveOrcSerDeManager.java x: 207 lines of code y: 8 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java x: 389 lines of code y: 35 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java x: 333 lines of code y: 28 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetsFinderFilteringDecorator.java x: 78 lines of code y: 3 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java x: 445 lines of code y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitorFactory.java x: 38 lines of code y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java x: 183 lines of code y: 22 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/version/HiveDatasetVersionCleaner.java x: 116 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractHiveDatasetVersionFinder.java x: 58 lines of code y: 4 # changes gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecProducer.java x: 168 lines of code y: 9 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java x: 146 lines of code y: 14 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java x: 225 lines of code y: 7 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java x: 277 lines of code y: 5 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/serde/HiveSerDeConverter.java x: 72 lines of code y: 4 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/HiveWritableHdfsDataWriterBuilder.java x: 30 lines of code y: 3 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java x: 281 lines of code y: 20 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDataset.java x: 235 lines of code y: 9 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java x: 85 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/PriorityIterableBasedRequestAllocator.java x: 81 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergCatalogFactory.java x: 17 lines of code y: 3 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java x: 474 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpecSearchObject.java x: 144 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/InstrumentedSpecStore.java x: 145 lines of code y: 8 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java x: 25 lines of code y: 9 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java x: 275 lines of code y: 14 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java x: 52 lines of code y: 7 # changes gobblin-metastore/src/main/java/org/apache/gobblin/runtime/StateStoreBasedWatermarkStorage.java x: 98 lines of code y: 3 # changes gobblin-modules/gobblin-helix/src/main/java/org/apache/gobblin/metastore/ZkStateStore.java x: 216 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/PreserveAttributes.java x: 63 lines of code y: 5 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java x: 235 lines of code y: 4 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java x: 174 lines of code y: 7 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/JobHistoryDataSourceProvider.java x: 35 lines of code y: 5 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcProvider.java x: 56 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/db/ServiceDatabaseProviderImpl.java x: 78 lines of code y: 5 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/EncryptionConfig.java x: 110 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/FSDatasetDescriptor.java x: 106 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/FSDatasetPartitionConfig.java x: 106 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/FSVolumeDatasetDescriptor.java x: 33 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/IcebergDatasetDescriptor.java x: 58 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/SqlDatasetDescriptor.java x: 83 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/DatasetDescriptorErrorUtils.java x: 62 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/AbstractPathFinder.java x: 240 lines of code y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java x: 66 lines of code y: 7 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixAssignedParticipantCheck.java x: 111 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopyManifest.java x: 93 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/FSPathAlterationFlowGraphListener.java x: 62 lines of code y: 2 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlDataSourceFactory.java x: 43 lines of code y: 2 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java x: 70 lines of code y: 3 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/publisher/JdbcPublisher.java x: 145 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreFactory.java x: 27 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/jdbc/DataSourceBuilder.java x: 91 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/source/CompactionSource.java x: 383 lines of code y: 12 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java x: 612 lines of code y: 44 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/datanodes/hive/HiveDataNode.java x: 22 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/SharedFlowGraphHelper.java x: 80 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java x: 753 lines of code y: 26 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java x: 239 lines of code y: 5 # changes gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java x: 101 lines of code y: 5 # changes gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java x: 110 lines of code y: 9 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java x: 87 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java x: 560 lines of code y: 7 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java x: 141 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/query/HiveAvroORCQueryGenerator.java x: 631 lines of code y: 12 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedMultiDatasets.java x: 146 lines of code y: 5 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/Utils/TypeInfoToSchemaParser.java x: 249 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopePayloadConverter.java x: 60 lines of code y: 3 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java x: 179 lines of code y: 3 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java x: 362 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/orc/AvroOrcSchemaConverter.java x: 89 lines of code y: 2 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/RowBatchPool.java x: 92 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowGraph.java x: 156 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/FlowGraphMonitor.java x: 5 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GitConfigMonitor.java x: 47 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/callbacks/CallbacksDispatcher.java x: 133 lines of code y: 5 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java x: 201 lines of code y: 5 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java x: 374 lines of code y: 13 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/TimeAwareRecursiveCopyableDataset.java x: 164 lines of code y: 11 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlSpecStoreWithUpdate.java x: 54 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/messaging/data/DynamicWorkUnitSerde.java x: 58 lines of code y: 1 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GitMonitoringService.java x: 334 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java x: 39 lines of code y: 10 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java x: 21 lines of code y: 5 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java x: 210 lines of code y: 8 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactionTask.java x: 99 lines of code y: 9 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionTimeRangeVerifier.java x: 109 lines of code y: 9 # changes gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java x: 71 lines of code y: 3 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java x: 58 lines of code y: 5 # changes gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java x: 271 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveUtils.java x: 123 lines of code y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiConnector.java x: 199 lines of code y: 7 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceConnector.java x: 107 lines of code y: 10 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java x: 231 lines of code y: 14 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java x: 197 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskExecutor.java x: 322 lines of code y: 9 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HivePartitionFileSet.java x: 164 lines of code y: 13 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/UnpartitionedTableFileSet.java x: 88 lines of code y: 10 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java x: 163 lines of code y: 8 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java x: 554 lines of code y: 15 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java x: 469 lines of code y: 7 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/LimiterServerResource.java x: 126 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/services/JMXReportingService.java x: 50 lines of code y: 5 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java x: 645 lines of code y: 23 # changes gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecConsumer.java x: 182 lines of code y: 11 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatus.java x: 37 lines of code y: 12 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/BaseJdbcBufferedInserter.java x: 95 lines of code y: 3 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java x: 31 lines of code y: 4 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/PostgresWriterCommands.java x: 128 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java x: 351 lines of code y: 9 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunner.java x: 572 lines of code y: 11 # changes gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java x: 536 lines of code y: 17 # changes gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java x: 28 lines of code y: 9 # changes gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedStreamingDataPublisher.java x: 100 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/publisher/TimestampDataPublisher.java x: 42 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatus.java x: 19 lines of code y: 4 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/writer/MetadataWriter.java x: 17 lines of code y: 4 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterManager.java x: 107 lines of code y: 5 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanMultiCallables.java x: 382 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java x: 246 lines of code y: 6 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MysqlJobCatalog.java x: 145 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecSearchObject.java x: 8 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java x: 252 lines of code y: 11 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/FsJobConfigurationManager.java x: 90 lines of code y: 4 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/util/SchemaVersionWriter.java x: 10 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/AuditCountClient.java x: 7 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/audit/KafkaAuditCountHttpClient.java x: 111 lines of code y: 4 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionAuditCountVerifier.java x: 127 lines of code y: 8 # changes gobblin-completeness/src/main/java/org/apache/gobblin/completeness/audit/AuditCountHttpClient.java x: 107 lines of code y: 1 # changes gobblin-utility/src/main/java/org/apache/gobblin/time/TimeIterator.java x: 82 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MysqlDatasetStateStore.java x: 70 lines of code y: 7 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/FsCleanableHelper.java x: 101 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java x: 101 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/ProxiedTrash.java x: 89 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FsSpecProducer.java x: 112 lines of code y: 5 # changes gobblin-hive-registration/src/main/java/org/apache/hadoop/hive/ql/io/orc/TypeDescriptionToObjectInspectorUtil.java x: 367 lines of code y: 1 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java x: 67 lines of code y: 6 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/writer/InstrumentedDataWriterBase.java x: 189 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java x: 220 lines of code y: 13 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/DatabaseJobHistoryStoreSchemaManager.java x: 126 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/InMemoryMultiContextIssueRepository.java x: 86 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/JobIssueEventHandler.java x: 72 lines of code y: 2 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/troubleshooter/MySqlMultiContextIssueRepository.java x: 223 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java x: 482 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaAvroJobMonitor.java x: 84 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableIcebergDataset.java x: 122 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java x: 113 lines of code y: 4 # changes gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/utils/HttpUtils.java x: 134 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java x: 277 lines of code y: 8 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java x: 331 lines of code y: 11 # changes gobblin-admin/src/main/java/org/apache/gobblin/cli/CliTablePrinter.java x: 108 lines of code y: 3 # changes gobblin-api/src/main/java/org/apache/gobblin/typedconfig/ConstraintUtil.java x: 104 lines of code y: 2 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java x: 122 lines of code y: 7 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterMetricTagNames.java x: 9 lines of code y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/TaskRunnerSuiteThreadModel.java x: 64 lines of code y: 8 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionAvroJobConfigurator.java x: 115 lines of code y: 10 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionJobConfigurator.java x: 249 lines of code y: 6 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyMapper.java x: 74 lines of code y: 4 # changes gobblin-core-base/src/main/java/org/apache/gobblin/crypto/EncryptionConfigParser.java x: 122 lines of code y: 5 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java x: 429 lines of code y: 8 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java x: 240 lines of code y: 5 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriter.java x: 14 lines of code y: 6 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkAwareWriterWrapper.java x: 16 lines of code y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpLightWeightFileSystem.java x: 212 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/AbstractAsyncDataWriter.java x: 35 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/ConsoleWriter.java x: 49 lines of code y: 4 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/SimpleDataWriter.java x: 67 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java x: 427 lines of code y: 12 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/provider/HdfsBasedUpdateProvider.java x: 49 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/publisher/HiveConvertPublisher.java x: 370 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/watermarker/PartitionLevelWatermarker.java x: 244 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDataset.java x: 167 lines of code y: 3 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableHiveDataset.java x: 98 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java x: 140 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/TimeBasedRetentionPolicy.java x: 67 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java x: 79 lines of code y: 5 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/filesystem/MetricsFileSystemInstrumentation.java x: 235 lines of code y: 3 # changes gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/ElasticsearchWriterBase.java x: 127 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/Kafka08DataWriter.java x: 104 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java x: 11 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/writer/Kafka09DataWriter.java x: 143 lines of code y: 9 # changes gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/KafkaDataWriterBuilder.java x: 11 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/ConfigDrivenMd5SchemaRegistry.java x: 84 lines of code y: 3 # changes gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/type/SerializedRecordWithMetadata.java x: 7 lines of code y: 5 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/GroupOwnershipService.java x: 5 lines of code y: 3 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/RateComputingLimiterContainer.java x: 90 lines of code y: 3 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ZookeeperLeaderElection.java x: 168 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractTaskStateTracker.java x: 66 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DynamicConfigGeneratorFactory.java x: 21 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/LimitingExtractorDecorator.java x: 97 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/StateStoreBasedWatermarkStorageCli.java x: 128 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableJobCatalog.java x: 41 lines of code y: 6 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/cli/JobStateStoreCLI.java x: 167 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/DefaultGobblinInstanceDriverImpl.java x: 230 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java x: 78 lines of code y: 8 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/SLAEventKafkaJobMonitor.java x: 148 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/template/StaticJobTemplate.java x: 97 lines of code y: 6 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/ForkMetrics.java x: 34 lines of code y: 3 # changes gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/ResultChainingIterator.java x: 44 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowEdge.java x: 116 lines of code y: 9 # changes gobblin-utility/src/main/java/org/apache/gobblin/broker/DefaultBrokerCache.java x: 179 lines of code y: 5 # changes gobblin-utility/src/main/java/org/apache/gobblin/fsm/FiniteStateMachine.java x: 253 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ForkOperatorUtils.java x: 38 lines of code y: 3 # changes gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutomaticTroubleshooterImpl.java x: 135 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/InMemoryIssueRepository.java x: 66 lines of code y: 1 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java x: 861 lines of code y: 9 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaProduceRateTracker.java x: 203 lines of code y: 2 # changes gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecConsumer.java x: 221 lines of code y: 3 # changes gobblin-api/src/main/java/org/apache/gobblin/runtime/api/SpecProducer.java x: 29 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/metrics/kafka/KafkaProducerPusher.java x: 92 lines of code y: 5 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java x: 150 lines of code y: 6 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionThresholdVerifier.java x: 65 lines of code y: 9 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/LdapUtils.java x: 96 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/TrustManagerSecureSocketFactory.java x: 90 lines of code y: 1 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java x: 149 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/client/Kafka1ConsumerClient.java x: 235 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/DownloadUtils.java x: 74 lines of code y: 3 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowExecutionClient.java x: 115 lines of code y: 5 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/PostgresqlExtractor.java x: 228 lines of code y: 5 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java x: 246 lines of code y: 4 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/TeradataExtractor.java x: 275 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionHiveRegistrationAction.java x: 85 lines of code y: 8 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java x: 207 lines of code y: 10 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/extractor/extract/jdbc/MysqlSource.java x: 44 lines of code y: 7 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java x: 179 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/GenericRecordBasedKafkaSchemaChangeInjector.java x: 11 lines of code y: 1 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/HadoopFileInputSource.java x: 131 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-1/src/main/java/org/apache/gobblin/kafka/writer/Kafka1DataWriter.java x: 142 lines of code y: 1 # changes gobblin-docs/css/extra.css x: 15 lines of code y: 9 # changes gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriterBuilder.java x: 43 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaPartition.java x: 107 lines of code y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJob.java x: 53 lines of code y: 8 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java x: 101 lines of code y: 6 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/StreamingJobConfigurationManager.java x: 122 lines of code y: 8 # changes gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/EmbeddedWikipediaExample.java x: 63 lines of code y: 4 # changes gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java x: 349 lines of code y: 5 # changes gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java x: 182 lines of code y: 3 # changes gobblin-api/src/main/java/org/apache/gobblin/typedconfig/TypedConfig.java x: 97 lines of code y: 1 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/event/CompactionSlaEventHelper.java x: 109 lines of code y: 7 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/CompactionCombineFileInputFormat.java x: 54 lines of code y: 2 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcUtils.java x: 407 lines of code y: 8 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/InputRecordCountHelper.java x: 126 lines of code y: 9 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java x: 45 lines of code y: 10 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java x: 259 lines of code y: 10 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java x: 263 lines of code y: 8 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java x: 172 lines of code y: 7 # changes gobblin-example/src/main/java/org/apache/gobblin/example/generic/OneShotRunner.java x: 61 lines of code y: 1 # changes gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/GobblinCli.java x: 33 lines of code y: 4 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/template/HOCONInputStreamFlowTemplate.java x: 30 lines of code y: 4 # changes gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/writer/AsyncHttpWriter.java x: 134 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaBiLevelWorkUnitPacker.java x: 74 lines of code y: 7 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java x: 309 lines of code y: 11 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnTaskRunner.java x: 152 lines of code y: 17 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/TimeBasedSubDirDatasetsFinder.java x: 188 lines of code y: 4 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcValueMapper.java x: 84 lines of code y: 7 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java x: 150 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporterFactory.java x: 76 lines of code y: 1 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaMetricReporterFactory.java x: 59 lines of code y: 1 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/RecordKeyDedupReducerBase.java x: 59 lines of code y: 2 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/suite/CompactionSuite.java x: 19 lines of code y: 5 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java x: 355 lines of code y: 6 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_executorInstance/AbstractSpecExecutor.java x: 111 lines of code y: 2 # changes gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AsyncHttpJoinConverter.java x: 136 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/converter/EnvelopeSchemaConverter.java x: 102 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java x: 172 lines of code y: 6 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroEventReporter.java x: 66 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java x: 210 lines of code y: 9 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/util/KafkaReporterUtils.java x: 71 lines of code y: 1 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/HttpClientFactory.java x: 43 lines of code y: 4 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/csv/CsvToJsonConverterV2.java x: 143 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-common/src/jmh/java/org/apache/gobblin/source/extractor/extract/kafka/HdrHistogramPerformanceBenchmark.java x: 112 lines of code y: 1 # changes gobblin-api/src/main/java/org/apache/gobblin/converter/Converter.java x: 90 lines of code y: 6 # changes gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroProjectionConverter.java x: 52 lines of code y: 5 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java x: 315 lines of code y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/SingleTaskRunner.java x: 118 lines of code y: 9 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMessagingService.java x: 144 lines of code y: 7 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/source/HiveSource.java x: 350 lines of code y: 14 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDataset.java x: 231 lines of code y: 9 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobRunner.java x: 72 lines of code y: 1 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/EmbeddedGobblinYarnAppLauncher.java x: 83 lines of code y: 1 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetricsRegistry.java x: 66 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/TaskMetrics.java x: 66 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java x: 139 lines of code y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/datanodes/HttpDataNode.java x: 41 lines of code y: 2 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java x: 90 lines of code y: 8 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-client/src/main/java/org/apache/gobblin/service/FlowStatusClient.java x: 95 lines of code y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java x: 192 lines of code y: 3 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerHealthMetricsService.java x: 147 lines of code y: 3 # changes gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/writer/ParquetDataWriterBuilder.java x: 84 lines of code y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/TimePartitionGlobFinder.java x: 182 lines of code y: 2 # changes gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java x: 349 lines of code y: 1 # changes gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/ParquetGroup.java x: 182 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/SimpleFileSystemDataset.java x: 26 lines of code y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/task/HiveConverterUtils.java x: 303 lines of code y: 5 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java x: 261 lines of code y: 7 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionWithAvroSchemaFactory.java x: 252 lines of code y: 9 # changes gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigStoreFactoryRegister.java x: 28 lines of code y: 4 # changes gobblin-core/src/main/java/org/apache/gobblin/publisher/HiveRegistrationPublisher.java x: 137 lines of code y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonRecordAvroSchemaToAvroConverter.java x: 90 lines of code y: 9 # changes gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java x: 130 lines of code y: 5 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ReplicationConfiguration.java x: 306 lines of code y: 7 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSJobConfigurationManager.java x: 213 lines of code y: 7 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_spec/JobSpecResolver.java x: 95 lines of code y: 1 # changes gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriter.java x: 285 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/local/LocalJobLauncher.java x: 120 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/ZookeeperBasedJobLock.java x: 180 lines of code y: 4 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java x: 147 lines of code y: 6 # changes gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/zip/ZipFileConfigStore.java x: 124 lines of code y: 3 # changes gobblin-config-management/gobblin-config-client/src/main/java/org/apache/gobblin/config/client/ConfigClientUtils.java x: 119 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java x: 355 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/reporter/KeyValueMetricObjectReporter.java x: 98 lines of code y: 2 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java x: 319 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java x: 82 lines of code y: 6 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/MetricReportReporter.java x: 122 lines of code y: 3 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/LoggingPusher.java x: 45 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/limiter/broker/SharedLimiterFactory.java x: 96 lines of code y: 5 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java x: 181 lines of code y: 3 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/QPSPolicy.java x: 76 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/extractor/FileAwareInputStreamExtractor.java x: 77 lines of code y: 7 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/StandardMetricsBridge.java x: 32 lines of code y: 6 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/java/org/apache/gobblin/restli/throttling/ThrottlingGuiceServletConfig.java x: 163 lines of code y: 5 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/CloseOnFlushWriterWrapper.java x: 148 lines of code y: 9 # changes gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/ElasticsearchRestWriter.java x: 155 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java x: 110 lines of code y: 11 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/JobCatalogBase.java x: 125 lines of code y: 5 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/orc/OrcKeyComparator.java x: 56 lines of code y: 2 # changes gobblin-binary-management/src/main/java/org/apache/gobblin/binary_creation/AvroTestTools.java x: 255 lines of code y: 2 # changes gobblin-binary-management/src/main/java/org/apache/gobblin/binary_creation/OrcTestTools.java x: 277 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobPropCreator.java x: 256 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job/GobblinJobFiniteStateMachine.java x: 120 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/util/ReflectivePredicateEvaluator.java x: 266 lines of code y: 1 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/LatestFlowExecutionIdTracker.java x: 6 lines of code y: 3 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobFactory.java x: 57 lines of code y: 6 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/FsDatasetPartitionConfig.java x: 106 lines of code y: 1 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/util/StateStoreCleaner.java x: 152 lines of code y: 3 # changes gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraClientFilesStreamer.java x: 146 lines of code y: 1 # changes gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraClientImpl.java x: 203 lines of code y: 1 # changes gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraExtractor.java x: 210 lines of code y: 1 # changes gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraParams.java x: 80 lines of code y: 1 # changes gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraUtil.java x: 86 lines of code y: 1 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java x: 167 lines of code y: 4 # changes gobblin-api/src/main/java/org/apache/gobblin/configuration/SourceState.java x: 217 lines of code y: 5 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedExtractor.java x: 358 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java x: 417 lines of code y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/TarArchiveInputStreamDataWriter.java x: 71 lines of code y: 4 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebMasterSource.java x: 110 lines of code y: 3 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java x: 299 lines of code y: 3 # changes gobblin-api/src/main/java/org/apache/gobblin/util/io/GsonInterfaceAdapter.java x: 123 lines of code y: 1 # changes maven-sonatype/github-pr-change-log.py x: 6 lines of code y: 6 # changes gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/FutureCallbackHolder.java x: 151 lines of code y: 1 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanAjaxAPIClient.java x: 284 lines of code y: 4 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/ExecutionResult.java x: 3 lines of code y: 2 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/CloudInitScriptBuilder.java x: 142 lines of code y: 3 # changes gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/crypto/GPGFileDecryptor.java x: 141 lines of code y: 8 # changes gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/crypto/GPGFileEncryptor.java x: 132 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/HadoopFsEndPoint.java x: 51 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaDeserializerExtractor.java x: 121 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/http/SalesforceRestWriter.java x: 278 lines of code y: 5 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/FsDatasetStateStore.java x: 332 lines of code y: 6 # changes gobblin-modules/gobblin-crypto-provider/src/main/java/org/apache/gobblin/converter/StringFieldDecryptorConverter.java x: 88 lines of code y: 1 # changes gobblin-modules/gobblin-crypto-provider/src/main/java/org/apache/gobblin/converter/StringFieldEncryptorConverter.java x: 80 lines of code y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/writer/HiveQueryExecutionWriter.java x: 86 lines of code y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/SingleTaskLauncher.java x: 110 lines of code y: 8 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/Dataset.java x: 287 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java x: 154 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/AvroKeyCombineFileRecordReader.java x: 42 lines of code y: 3 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionVerifier.java x: 20 lines of code y: 6 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-server/src/main/webapp/WEB-INF/web.xml x: 35 lines of code y: 7 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/FSJobCatalog.java x: 155 lines of code y: 5 # changes gobblin-api/src/main/java/org/apache/gobblin/configuration/WorkUnitState.java x: 252 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java x: 175 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/StateStores.java x: 74 lines of code y: 5 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java x: 257 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java x: 366 lines of code y: 3 # changes gradle/resources/rat-output-to-html.xsl x: 153 lines of code y: 1 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/SingleTaskRunnerMainOptions.java x: 61 lines of code y: 2 # changes gobblin-docs/developer-guide/files/codestyle-intellij-gobblin.xml x: 523 lines of code y: 7 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanJobHelper.java x: 226 lines of code y: 3 # changes gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonSchema.java x: 198 lines of code y: 1 # changes gobblin-modules/gobblin-grok/src/main/java/org/apache/gobblin/converter/grok/GrokToJsonConverter.java x: 128 lines of code y: 1 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/source/HiveWorkUnit.java x: 103 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskContext.java x: 223 lines of code y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java x: 239 lines of code y: 3 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java x: 281 lines of code y: 4 # changes gobblin-admin/src/main/resources/static/js/collections/job-executions.js x: 42 lines of code y: 11 # changes gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java x: 3 lines of code y: 9 # changes gobblin-api/src/main/java/org/apache/gobblin/broker/gobblin_scopes/GobblinScopeInstance.java x: 11 lines of code y: 4 # changes gobblin-api/src/main/java/org/apache/gobblin/broker/iface/SubscopedBrokerBuilder.java x: 8 lines of code y: 4 # changes gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java x: 1 lines of code y: 3 # changes gobblin-api/src/main/java/org/apache/gobblin/source/workunit/BasicWorkUnitStream.java x: 89 lines of code y: 4 # changes gobblin-core-base/src/jmh/java/org/apache/gobblin/writer/FineGrainedWatermarkTrackerBenchmark.java x: 114 lines of code y: 4 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/FutureWrappedWriteCallback.java x: 83 lines of code y: 4 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/MultiWriterWatermarkTracker.java x: 94 lines of code y: 4 # changes gobblin-core-base/src/main/java/org/apache/gobblin/writer/WatermarkManager.java x: 54 lines of code y: 4 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/DatasetStateStore.java x: 69 lines of code y: 4 # changes gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/converter/SerializedRecordToEncryptedSerializedRecordConverterBase.java x: 42 lines of code y: 4 # changes gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/r2/R2RestRequestBuilder.java x: 78 lines of code y: 4 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/KafkaSchemaRegistryConfigurationKeys.java x: 9 lines of code y: 5 # changes gobblin-runtime/src/main/java/gobblin/runtime/TaskState.java x: 3 lines of code y: 65 # changes gobblin-runtime/src/main/java/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java x: 10 lines of code y: 8 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskInstantiationException.java x: 6 lines of code y: 4 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/executors/IteratorExecutor.java x: 122 lines of code y: 4 # changes gobblin-api/src/main/java/gobblin/configuration/ImmutableWorkUnitState.java x: 6 lines of code y: 18 # changes gobblin-api/src/main/java/gobblin/configuration/SourceState.java x: 24 lines of code y: 36 # changes gobblin-api/src/main/java/gobblin/configuration/State.java x: 13 lines of code y: 71 # changes gobblin-api/src/main/java/gobblin/configuration/WorkUnitState.java x: 14 lines of code y: 52 # changes gobblin-api/src/main/java/gobblin/source/extractor/Watermark.java x: 3 lines of code y: 20 # changes gobblin-api/src/main/java/gobblin/source/extractor/WatermarkInterval.java x: 6 lines of code y: 16 # changes gobblin-api/src/main/java/gobblin/source/workunit/Extract.java x: 26 lines of code y: 18 # changes gobblin-api/src/main/java/gobblin/source/workunit/ImmutableExtract.java x: 17 lines of code y: 14 # changes gobblin-api/src/main/java/gobblin/source/workunit/ImmutableWorkUnit.java x: 6 lines of code y: 21 # changes gobblin-api/src/main/java/gobblin/source/workunit/MultiWorkUnit.java x: 7 lines of code y: 26 # changes gobblin-api/src/main/java/gobblin/source/workunit/WorkUnit.java x: 24 lines of code y: 38 # changes gobblin-core/src/main/java/gobblin/state/ConstructState.java x: 13 lines of code y: 10 # changes gobblin-data-management/src/main/java/gobblin/data/management/conversion/hive/source/HiveWorkUnit.java x: 10 lines of code y: 9 # changes gobblin-hive-registration/src/main/java/gobblin/hive/HiveRegProps.java x: 10 lines of code y: 18 # changes gobblin-runtime/src/main/java/gobblin/runtime/JobState.java x: 30 lines of code y: 77 # changes gobblin-admin/src/main/java/org/apache/gobblin/admin/AdminWebServer.java x: 90 lines of code y: 2 # changes gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java x: 179 lines of code y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/ack/HierarchicalAckable.java x: 71 lines of code y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/commit/CommitSequence.java x: 70 lines of code y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/source/workunit/ImmutableExtract.java x: 76 lines of code y: 2 # changes gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java x: 308 lines of code y: 2 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/hive/SerialCompactor.java x: 266 lines of code y: 2 # changes gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java x: 117 lines of code y: 2 # changes gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/api/package-info.java x: 1 lines of code y: 2 # changes gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStoreFactory.java x: 154 lines of code y: 2 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/converter/InstrumentedConverterBase.java x: 119 lines of code y: 2 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/fork/InstrumentedForkOperatorBase.java x: 106 lines of code y: 2 # changes gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/qualitychecker/InstrumentedRowLevelPolicyBase.java x: 109 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/http/DefaultHttpClientConfigurator.java x: 95 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/source/extractor/hadoop/OldApiHadoopFileInputSource.java x: 94 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/state/ConstructState.java x: 75 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/ThrottleWriter.java x: 145 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriter.java x: 149 lines of code y: 2 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java x: 126 lines of code y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinder.java x: 199 lines of code y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/action/AccessControlAction.java x: 102 lines of code y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/trash/TestTrash.java x: 133 lines of code y: 2 # changes gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java x: 332 lines of code y: 2 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java x: 750 lines of code y: 2 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java x: 878 lines of code y: 2 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HivePartitionVersionFinder.java x: 121 lines of code y: 2 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerPublisher.java x: 137 lines of code y: 2 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerQueryTemplate.java x: 135 lines of code y: 2 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java x: 251 lines of code y: 2 # changes gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/HivePartitionVersionRetentionReaper.java x: 156 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java x: 429 lines of code y: 2 # changes gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java x: 185 lines of code y: 2 # changes gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java x: 234 lines of code y: 2 # changes gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteEventReporter.java x: 138 lines of code y: 2 # changes gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java x: 172 lines of code y: 2 # changes gobblin-modules/gobblin-metrics-influxdb/src/main/java/org/apache/gobblin/metrics/influxdb/InfluxDBReporter.java x: 181 lines of code y: 2 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java x: 162 lines of code y: 2 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFileSystem.java x: 238 lines of code y: 2 # changes gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleDriveFsHelper.java x: 114 lines of code y: 2 # changes gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/stressTest/MRStressTest.java x: 257 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MultiConverter.java x: 141 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java x: 228 lines of code y: 2 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/locks/FileBasedJobLockFactory.java x: 166 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/ConstructorAndPublicMethodsCliObjectFactory.java x: 83 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/runtime/cli/PublicMethodsCliObjectFactory.java x: 164 lines of code y: 2 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/HierarchicalAllocator.java x: 125 lines of code y: 2 # changes gobblin-admin/src/main/resources/static/css/gobblin.css x: 96 lines of code y: 9 # changes gobblin-admin/src/main/resources/static/css/tablesorter.theme.css x: 171 lines of code y: 9 # changes gobblin-admin/src/main/resources/static/index.html x: 234 lines of code y: 13 # changes gobblin-admin/src/main/resources/static/js/gobblin.js x: 72 lines of code y: 9 # changes gobblin-admin/src/main/resources/static/js/router.js x: 21 lines of code y: 9 # changes gobblin-admin/src/main/resources/static/js/views/job-execution-view.js x: 169 lines of code y: 10 # changes gobblin-admin/src/main/resources/static/js/views/job-view.js x: 200 lines of code y: 11 # changes gobblin-admin/src/main/resources/static/js/views/table-view.js x: 95 lines of code y: 9 # changes gobblin-admin/src/main/resources/static/js/models/task-execution.js x: 48 lines of code y: 9 # changes gobblin-docs/developer-guide/files/codestyle-eclipse.xml x: 291 lines of code y: 6 # changes gobblin-docs/js/extra.js x: 30 lines of code y: 7 # changes
140.0
# changes
  min: 1.0
  average: 3.93
  25th percentile: 2.0
  median: 2.0
  75th percentile: 4.0
  max: 140.0
0 949.0
lines of code
min: 1.0 | average: 71.96 | 25th percentile: 15.0 | median: 37.0 | 75th percentile: 85.5 | max: 949.0

Number of Contributors vs. Number of Changes: 2681 points

gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ManifestBasedDataset.java x: 7 # contributors y: 17 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/OwnerAndPermission.java x: 2 # contributors y: 2 # changes gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java x: 32 # contributors y: 140 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java x: 17 # contributors y: 22 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlan.java x: 9 # contributors y: 37 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/assistance/Help.java x: 3 # contributors y: 10 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java x: 4 # contributors y: 5 # changes gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java x: 2 # contributors y: 3 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DatasetTaskSummary.java x: 3 # contributors y: 4 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTable.java x: 5 # contributors y: 16 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java x: 3 # contributors y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/DagTask.java x: 4 # contributors y: 10 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/GobblinTemporalConfigurationKeys.java x: 5 # contributors y: 12 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/ProcessWorkUnitImpl.java x: 5 # contributors y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/worker/WorkFulfillmentWorker.java x: 4 # contributors y: 9 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java x: 6 # contributors y: 17 # changes gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java x: 5 # contributors y: 6 # changes gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java x: 5 # contributors y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/LaunchDagTask.java x: 4 # contributors y: 8 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/ActivityType.java x: 1 # contributors y: 3 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/NestingExecOfProcessWorkUnitWorkflowImpl.java x: 2 # contributors y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ProcessWorkUnitsWorkflowImpl.java x: 5 # contributors y: 15 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/CommitActivityImpl.java x: 5 # contributors y: 11 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/GenerateWorkUnitsImpl.java x: 4 # contributors y: 13 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ProcessWorkUnitsJobLauncher.java x: 6 # contributors y: 11 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/util/JobStateUtils.java x: 2 # contributors y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WUProcessingSpec.java x: 4 # contributors y: 6 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/ProcessWorkUnitsWorkflow.java x: 4 # contributors y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/NestingExecWorkloadInput.java x: 1 # contributors y: 1 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java x: 7 # contributors y: 16 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/DynamicScalingYarnService.java x: 2 # contributors y: 8 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java x: 3 # contributors y: 5 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinJobLauncher.java x: 4 # contributors y: 7 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncher.java x: 3 # contributors y: 6 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java x: 13 # contributors y: 37 # changes gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java x: 2 # contributors y: 4 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/Workload.java x: 1 # contributors y: 2 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergDatasetFinder.java x: 3 # contributors y: 9 # changes gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java x: 11 # contributors y: 26 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/BaseFlowToJobSpecCompiler.java x: 9 # contributors y: 20 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java x: 18 # contributors y: 49 # changes gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/CommitStats.java x: 3 # contributors y: 3 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagProcessingEngine.java x: 5 # contributors y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java x: 5 # contributors y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProcUtils.java x: 5 # contributors y: 18 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java x: 6 # contributors y: 14 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java x: 4 # contributors y: 11 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementStateStore.java x: 3 # contributors y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MySqlDagManagementStateStore.java x: 5 # contributors y: 8 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java x: 4 # contributors y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java x: 15 # contributors y: 70 # changes gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java x: 8 # contributors y: 11 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java x: 11 # contributors y: 24 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsV2Resource.java x: 8 # contributors y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagActionReminderScheduler.java x: 3 # contributors y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementTaskStreamImpl.java x: 4 # contributors y: 22 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/FlowLaunchHandler.java x: 4 # contributors y: 15 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagManagementDagActionStoreChangeMonitor.java x: 4 # contributors y: 16 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java x: 10 # contributors y: 17 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java x: 11 # contributors y: 21 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SafeDatasetCommit.java x: 10 # contributors y: 21 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java x: 17 # contributors y: 28 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/Dag.java x: 8 # contributors y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java x: 5 # contributors y: 17 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/MysqlJobStatusRetriever.java x: 7 # contributors y: 12 # changes gobblin-api/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java x: 14 # contributors y: 36 # changes gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java x: 6 # contributors y: 15 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceConfiguration.java x: 6 # contributors y: 10 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceGuiceModule.java x: 7 # contributors y: 30 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java x: 18 # contributors y: 58 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java x: 6 # contributors y: 35 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/ServiceMetricNames.java x: 8 # contributors y: 23 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java x: 12 # contributors y: 33 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagActionStore.java x: 4 # contributors y: 12 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/FSDagStateStore.java x: 7 # contributors y: 11 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlDagStateStore.java x: 6 # contributors y: 9 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/LaunchDagProc.java x: 3 # contributors y: 15 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/ReevaluateDagProc.java x: 3 # contributors y: 16 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java x: 15 # contributors y: 72 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanDagFactory.java x: 6 # contributors y: 7 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagManagementDagActionStoreChangeMonitorFactory.java x: 3 # contributors y: 8 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java x: 14 # contributors y: 42 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java x: 7 # contributors y: 10 # changes gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java x: 9 # contributors y: 23 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java x: 7 # contributors y: 9 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java x: 7 # contributors y: 8 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDataset.java x: 8 # contributors y: 20 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java x: 16 # contributors y: 32 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java x: 15 # contributors y: 22 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/SerializationConstants.java x: 5 # contributors y: 5 # changes gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql x: 9 # contributors y: 10 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java x: 6 # contributors y: 16 # changes gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java x: 10 # contributors y: 23 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/retry/RetryerFactory.java x: 6 # contributors y: 6 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java x: 14 # contributors y: 28 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlSpecStore.java x: 7 # contributors y: 13 # changes gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java x: 10 # contributors y: 20 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/FsJobStatusRetriever.java x: 7 # contributors y: 14 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/LocalFsJobStatusRetriever.java x: 6 # contributors y: 8 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java x: 10 # contributors y: 14 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java x: 8 # contributors y: 21 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java x: 11 # contributors y: 31 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAutoScalingManager.java x: 9 # contributors y: 16 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java x: 13 # contributors y: 42 # changes gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaAvroJobStatusMonitor.java x: 10 # contributors y: 26 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobContext.java x: 11 # contributors y: 18 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagTaskVisitor.java x: 1 # contributors y: 5 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/publisher/GobblinMCEPublisher.java x: 6 # contributors y: 12 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowGraphHelper.java x: 1 # contributors y: 4 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java x: 14 # contributors y: 55 # changes gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java x: 10 # contributors y: 15 # changes gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java x: 13 # contributors y: 21 # changes gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java x: 6 # contributors y: 22 # changes gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java x: 9 # contributors y: 22 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/metrics/RuntimeMetrics.java x: 4 # contributors y: 19 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java x: 16 # contributors y: 56 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/GobblinMultiTaskAttempt.java x: 14 # contributors y: 24 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java x: 9 # contributors y: 12 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskStateCollectorService.java x: 8 # contributors y: 13 # changes gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/MultiHopFlowCompiler.java x: 8 # contributors y: 32 # changes gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GobblinBaseOrcWriter.java x: 7 # contributors y: 15 # changes ligradle/findbugs/findbugsExclude.xml x: 14 # contributors y: 20 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java x: 9 # contributors y: 19 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/writer/HiveMetadataWriter.java x: 7 # contributors y: 20 # changes gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java x: 11 # contributors y: 17 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterManager.java x: 10 # contributors y: 35 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java x: 10 # contributors y: 28 # changes gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java x: 9 # contributors y: 13 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java x: 10 # contributors y: 22 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java x: 5 # contributors y: 20 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java x: 11 # contributors y: 44 # changes gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java x: 16 # contributors y: 26 # changes gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java x: 11 # contributors y: 14 # changes gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java x: 9 # contributors y: 15 # changes gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobCatalog.java x: 2 # contributors y: 11 # changes gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobFactory.java x: 1 # contributors y: 6 # changes gobblin-docs/developer-guide/files/codestyle-intellij-gobblin.xml x: 7 # contributors y: 7 # changes gobblin-admin/src/main/resources/static/js/collections/job-executions.js x: 9 # contributors y: 11 # changes gobblin-runtime/src/main/java/gobblin/runtime/TaskState.java x: 23 # contributors y: 65 # changes gobblin-api/src/main/java/gobblin/configuration/ImmutableWorkUnitState.java x: 14 # contributors y: 18 # changes gobblin-api/src/main/java/gobblin/configuration/State.java x: 26 # contributors y: 71 # changes gobblin-api/src/main/java/gobblin/configuration/WorkUnitState.java x: 22 # contributors y: 52 # changes gobblin-api/src/main/java/gobblin/source/extractor/Watermark.java x: 13 # contributors y: 20 # changes gobblin-api/src/main/java/gobblin/source/extractor/WatermarkInterval.java x: 12 # contributors y: 16 # changes gobblin-api/src/main/java/gobblin/source/workunit/Extract.java x: 13 # contributors y: 18 # changes gobblin-api/src/main/java/gobblin/source/workunit/ImmutableWorkUnit.java x: 17 # contributors y: 21 # changes gobblin-api/src/main/java/gobblin/source/workunit/MultiWorkUnit.java x: 15 # contributors y: 26 # changes gobblin-api/src/main/java/gobblin/source/workunit/WorkUnit.java x: 16 # contributors y: 38 # changes gobblin-core/src/main/java/gobblin/state/ConstructState.java x: 8 # contributors y: 10 # changes gobblin-runtime/src/main/java/gobblin/runtime/JobState.java x: 25 # contributors y: 77 # changes gobblin-admin/src/main/resources/static/css/gobblin.css x: 9 # contributors y: 9 # changes gobblin-admin/src/main/resources/static/index.html x: 11 # contributors y: 13 # changes gobblin-admin/src/main/resources/static/js/views/job-execution-view.js x: 10 # contributors y: 10 # changes gobblin-admin/src/main/resources/static/js/views/job-view.js x: 10 # contributors y: 11 # changes gobblin-admin/src/main/resources/static/js/models/job-execution.js x: 10 # contributors y: 9 # changes
140.0
# changes
  min: 1.0
  average: 3.93
  25th percentile: 2.0
  median: 2.0
  75th percentile: 4.0
  max: 140.0
0 32.0
# contributors
min: 1.0 | average: 2.21 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 32.0

Number of Contributors vs. File Size: 2681 points

gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/ManifestBasedDataset.java x: 7 # contributors y: 171 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/OwnerAndPermission.java x: 2 # contributors y: 64 lines of code gobblin-api/src/main/java/org/apache/gobblin/configuration/ConfigurationKeys.java x: 32 # contributors y: 786 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanJobLauncher.java x: 17 # contributors y: 297 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlan.java x: 9 # contributors y: 175 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/assistance/Help.java x: 3 # contributors y: 203 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanTags.java x: 4 # contributors y: 37 lines of code gobblin-core/src/main/java/org/apache/gobblin/qualitychecker/task/TaskLevelPolicyChecker.java x: 2 # contributors y: 25 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GaaSJobObservabilityEvent.avsc x: 2 # contributors y: 275 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/DatasetTaskSummary.java x: 3 # contributors y: 23 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTable.java x: 5 # contributors y: 223 lines of code gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/OpenTelemetryMetrics.java x: 3 # contributors y: 100 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/TemporalMetricsHelper.java x: 2 # contributors y: 78 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/DagTask.java x: 4 # contributors y: 41 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/GobblinTemporalConfigurationKeys.java x: 5 # contributors y: 69 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/ProcessWorkUnitImpl.java x: 5 # contributors y: 203 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/RecommendScalingForWorkUnitsLinearHeuristicImpl.java x: 2 # contributors y: 53 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/worker/WorkFulfillmentWorker.java x: 4 # contributors y: 47 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ExecuteGobblinWorkflowImpl.java x: 6 # contributors y: 217 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/DatePartitionedNestedRetriever.java x: 5 # contributors y: 165 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/PartitionAwareFileRetrieverUtils.java x: 2 # contributors y: 43 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/PartitionedFileSourceBase.java x: 5 # contributors y: 243 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/ActivityType.java x: 1 # contributors y: 65 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/CommitStepWorkflowImpl.java x: 4 # contributors y: 44 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/NestingExecOfProcessWorkUnitWorkflowImpl.java x: 2 # contributors y: 17 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/TemporalEventTimer.java x: 4 # contributors y: 84 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/ProcessWorkUnitsWorkflowImpl.java x: 5 # contributors y: 115 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/helloworld/GreetingWorkflowImpl.java x: 4 # contributors y: 24 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/GenerateWorkUnitsImpl.java x: 4 # contributors y: 248 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ProcessWorkUnitsJobLauncher.java x: 6 # contributors y: 76 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/util/JobStateUtils.java x: 2 # contributors y: 145 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WUProcessingSpec.java x: 4 # contributors y: 52 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/CommitStepWorkflow.java x: 2 # contributors y: 11 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/ProcessWorkUnitsWorkflow.java x: 4 # contributors y: 12 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/loadgen/launcher/GenArbitraryLoadJobLauncher.java x: 4 # contributors y: 53 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/NestingExecWorkloadInput.java x: 1 # contributors y: 21 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/workflow/AbstractNestingExecWorkflowImpl.java x: 4 # contributors y: 125 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/PropertiesUtils.java x: 7 # contributors y: 120 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/AbstractDynamicScalingYarnServiceManager.java x: 3 # contributors y: 79 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/DynamicScalingYarnService.java x: 2 # contributors y: 184 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/YarnService.java x: 5 # contributors y: 589 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalTaskRunner.java x: 3 # contributors y: 321 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinJobLauncher.java x: 4 # contributors y: 203 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobLauncher.java x: 3 # contributors y: 133 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/joblauncher/GobblinTemporalJobScheduler.java x: 3 # contributors y: 231 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/client/TemporalWorkflowClientFactory.java x: 3 # contributors y: 95 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/service/ManagedWorkflowServiceStubs.java x: 1 # contributors y: 28 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnAppLauncher.java x: 13 # contributors y: 815 lines of code gobblin-api/src/main/java/org/apache/gobblin/initializer/Initializer.java x: 2 # contributors y: 58 lines of code gobblin-core/src/main/java/org/apache/gobblin/converter/initializer/MultiConverterInitializer.java x: 2 # contributors y: 29 lines of code gobblin-core/src/main/java/org/apache/gobblin/initializer/MultiInitializer.java x: 2 # contributors y: 63 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/initializer/JdbcWriterInitializer.java x: 2 # contributors y: 258 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/Workload.java x: 1 # contributors y: 15 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergDatasetFinder.java x: 3 # contributors y: 123 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/TimingEvent.java x: 11 # contributors y: 161 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FsSpecConsumer.java x: 5 # contributors y: 125 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/BaseFlowToJobSpecCompiler.java x: 9 # contributors y: 231 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/template/StaticFlowTemplate.java x: 5 # contributors y: 153 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventTimer.java x: 3 # contributors y: 18 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/AbstractJobLauncher.java x: 18 # contributors y: 840 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/cluster/GobblinTemporalClusterManager.java x: 2 # contributors y: 268 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/RecommendScalingForWorkUnits.java x: 1 # contributors y: 14 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/impl/AbstractRecommendScalingForWorkUnitsImpl.java x: 1 # contributors y: 40 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/DirDeletionResult.java x: 2 # contributors y: 19 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/WorkUnitClaimCheck.java x: 2 # contributors y: 37 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/FsScalingDirectiveSource.java x: 1 # contributors y: 92 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ProfileDerivation.java x: 1 # contributors y: 37 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ProfileOverlay.java x: 1 # contributors y: 139 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirectiveParser.java x: 1 # contributors y: 190 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/ScalingDirectivesRecipient.java x: 1 # contributors y: 6 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforcePlan.java x: 1 # contributors y: 106 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/WorkUnitSizeInfo.java x: 1 # contributors y: 81 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagProcessingEngine.java x: 5 # contributors y: 119 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProc.java x: 5 # contributors y: 62 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DagProcUtils.java x: 5 # contributors y: 267 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/kafka/HighLevelConsumer.java x: 6 # contributors y: 259 lines of code gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutoTroubleshooterLogAppender.java x: 2 # contributors y: 118 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/GenerateWorkUnits.java x: 2 # contributors y: 14 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/EagerFsDirBackedWorkUnitClaimCheckWorkload.java x: 2 # contributors y: 47 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/JobLauncherUtils.java x: 4 # contributors y: 216 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/yarn/GobblinTemporalApplicationMaster.java x: 3 # contributors y: 117 lines of code gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/modules/restli/FlowConfigsV2ResourceHandler.java x: 2 # contributors y: 293 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementStateStore.java x: 3 # contributors y: 59 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/InstrumentedLeaseArbiter.java x: 4 # contributors y: 73 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MultiActiveLeaseArbiter.java x: 4 # contributors y: 9 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MySqlDagManagementStateStore.java x: 5 # contributors y: 192 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlMultiActiveLeaseArbiter.java x: 4 # contributors y: 477 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/Orchestrator.java x: 15 # contributors y: 229 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforceProfiles.java x: 1 # contributors y: 50 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/dynamic/WorkforceStaffing.java x: 1 # contributors y: 69 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/AzkabanGobblinYarnAppLauncher.java x: 8 # contributors y: 73 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/AzkabanLauncherUtils.java x: 1 # contributors y: 24 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnConfigurationKeys.java x: 11 # contributors y: 102 lines of code gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowConfigsV2Resource.java x: 8 # contributors y: 209 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagActionReminderScheduler.java x: 3 # contributors y: 130 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagementTaskStreamImpl.java x: 4 # contributors y: 163 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/FlowLaunchHandler.java x: 4 # contributors y: 179 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/LeaseAttemptStatus.java x: 3 # contributors y: 42 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagManagementDagActionStoreChangeMonitor.java x: 4 # contributors y: 75 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergTableMetadataValidatorUtils.java x: 1 # contributors y: 48 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/BaseIcebergCatalog.java x: 3 # contributors y: 39 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergCatalog.java x: 3 # contributors y: 13 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergHiveCatalog.java x: 3 # contributors y: 37 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergOverwritePartitionsStep.java x: 1 # contributors y: 110 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergPartitionDataset.java x: 1 # contributors y: 166 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/predicates/IcebergPartitionFilterPredicateUtil.java x: 1 # contributors y: 33 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDatasetFinder.java x: 4 # contributors y: 262 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnHelixUtils.java x: 10 # contributors y: 187 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/publisher/CopyDataPublisher.java x: 11 # contributors y: 316 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SafeDatasetCommit.java x: 10 # contributors y: 322 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GaaSJobObservabilityEventProducer.java x: 3 # contributors y: 226 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/launcher/ExecuteGobblinJobLauncher.java x: 5 # contributors y: 72 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/MRJobLauncher.java x: 17 # contributors y: 687 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanClient.java x: 6 # contributors y: 367 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/Dag.java x: 8 # contributors y: 202 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/utils/FlowCompilationValidationHelper.java x: 5 # contributors y: 199 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/MysqlJobStatusRetriever.java x: 7 # contributors y: 88 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/workflow/impl/GenerateWorkUnitsWorkflowImpl.java x: 2 # contributors y: 30 lines of code gobblin-api/src/main/java/org/apache/gobblin/service/ServiceConfigKeys.java x: 14 # contributors y: 93 lines of code gobblin-restli/gobblin-flow-config-service/gobblin-flow-config-service-server/src/main/java/org/apache/gobblin/service/FlowStatusResource.java x: 6 # contributors y: 47 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/InjectionNames.java x: 4 # contributors y: 4 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceGuiceModule.java x: 7 # contributors y: 200 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/core/GobblinServiceManager.java x: 18 # contributors y: 314 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/restli/FlowExecutionResourceHandler.java x: 1 # contributors y: 101 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/DagActionStoreChangeMonitor.java x: 6 # contributors y: 171 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/SpecStoreChangeMonitor.java x: 4 # contributors y: 137 lines of code gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/ServiceMetricNames.java x: 8 # contributors y: 62 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalog.java x: 6 # contributors y: 116 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/FlowCatalog.java x: 12 # contributors y: 333 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagStateStore.java x: 5 # contributors y: 25 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagUtils.java x: 1 # contributors y: 208 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/InMemoryUserQuotaManager.java x: 2 # contributors y: 210 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlDagStateStore.java x: 6 # contributors y: 122 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/MysqlUserQuotaManager.java x: 4 # contributors y: 406 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/UserQuotaManager.java x: 3 # contributors y: 11 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/EnforceJobStartDeadlineDagProc.java x: 3 # contributors y: 52 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/LaunchDagProc.java x: 3 # contributors y: 56 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/ReevaluateDagProc.java x: 3 # contributors y: 108 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/scheduler/GobblinServiceJobScheduler.java x: 15 # contributors y: 564 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanDagFactory.java x: 6 # contributors y: 58 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanListSerializer.java x: 4 # contributors y: 61 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/KafkaJobStatusMonitor.java x: 14 # contributors y: 329 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/ConfigUtils.java x: 7 # contributors y: 287 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/FlowStatusGenerator.java x: 9 # contributors y: 92 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactor.java x: 6 # contributors y: 732 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleaner.java x: 7 # contributors y: 189 lines of code gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/restore/ComplianceRestoreJob.java x: 2 # contributors y: 107 lines of code gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/retention/ComplianceRetentionJob.java x: 3 # contributors y: 163 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/app/ServiceBasedAppLauncher.java x: 3 # contributors y: 207 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblin.java x: 7 # contributors y: 460 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/TimingEventUtils.java x: 7 # contributors y: 51 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/RecursiveCopyableDataset.java x: 8 # contributors y: 182 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSource.java x: 16 # contributors y: 806 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/Task.java x: 15 # contributors y: 759 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/fork/Fork.java x: 11 # contributors y: 448 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/proc/DeadlineEnforcementDagProc.java x: 3 # contributors y: 48 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/task/DagProcessingEngineMetrics.java x: 2 # contributors y: 132 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/JobExecutionPlanListDeserializer.java x: 5 # contributors y: 87 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/spec/SerializationConstants.java x: 5 # contributors y: 18 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/predicates/DatasetHiveSchemaContainsNonOptionalUnion.java x: 3 # contributors y: 72 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GaaSFlowObservabilityEvent.avsc x: 1 # contributors y: 100 lines of code gobblin-metastore/src/main/resources/db/migration/V1_0_0__Initial_version.sql x: 9 # contributors y: 102 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractorStatsTracker.java x: 6 # contributors y: 431 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/MysqlStateStore.java x: 10 # contributors y: 429 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/retry/RetryerFactory.java x: 6 # contributors y: 115 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/writer/FileAwareInputStreamDataWriter.java x: 14 # contributors y: 378 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlSpecStore.java x: 7 # contributors y: 132 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/action/CompactionCompleteFileOperationAction.java x: 10 # contributors y: 153 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/orchestration/DagManagement.java x: 2 # contributors y: 5 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/service/monitoring/JobStatusRetriever.java x: 11 # contributors y: 173 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/FsJobStatusRetriever.java x: 7 # contributors y: 130 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/LocalFsJobStatusRetriever.java x: 6 # contributors y: 103 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/SubsetFilesCopyableDataset.java x: 2 # contributors y: 81 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveCopyEntityHelper.java x: 10 # contributors y: 607 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/iceberg/IcebergDataset.java x: 4 # contributors y: 266 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/HadoopUtils.java x: 10 # contributors y: 604 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileStatusEntry.java x: 2 # contributors y: 112 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpec.java x: 8 # contributors y: 382 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/PathUtils.java x: 6 # contributors y: 108 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/conversion/hive/validation/ValidationJob.java x: 4 # contributors y: 542 lines of code gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/HiveProxyQueryExecutor.java x: 2 # contributors y: 158 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/AutomaticTroubleshooterFactory.java x: 2 # contributors y: 39 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriter.java x: 11 # contributors y: 949 lines of code gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseEnvironmentFactory.java x: 7 # contributors y: 36 lines of code gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriterConfigurationKeys.java x: 6 # contributors y: 37 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixConstants.java x: 3 # contributors y: 5 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAutoScalingManager.java x: 9 # contributors y: 374 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnService.java x: 13 # contributors y: 840 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobContext.java x: 11 # contributors y: 370 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/activity/CommitActivity.java x: 1 # contributors y: 10 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/publisher/GobblinMCEPublisher.java x: 6 # contributors y: 183 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaUtils.java x: 5 # contributors y: 105 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowGraphHelper.java x: 1 # contributors y: 211 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/DatasetUtils.java x: 5 # contributors y: 90 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/JobState.java x: 7 # contributors y: 562 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterConfigurationKeys.java x: 14 # contributors y: 130 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinClusterUtils.java x: 7 # contributors y: 143 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnContainerSecurityManager.java x: 3 # contributors y: 75 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/scheduler/JobScheduler.java x: 10 # contributors y: 392 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/LongWatermark.java x: 2 # contributors y: 52 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/CopySource.java x: 13 # contributors y: 434 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/source/extractor/extract/FlushingExtractor.java x: 3 # contributors y: 254 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/workflows/metrics/EventSubmitterContext.java x: 2 # contributors y: 102 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/scheduler/QuartzJobSpecScheduler.java x: 3 # contributors y: 142 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/GobblinMCEProducer.java x: 5 # contributors y: 255 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/GobblinMCEWriter.java x: 6 # contributors y: 454 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/avro/GobblinMetadataChangeEvent.avsc x: 4 # contributors y: 304 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/AbstractTokenRefresher.java x: 1 # contributors y: 115 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/AbstractYarnAppSecurityManager.java x: 5 # contributors y: 29 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinApplicationMaster.java x: 9 # contributors y: 188 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/YarnAppSecurityManagerWithKeytabs.java x: 4 # contributors y: 87 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/helix/HelixClusterLifecycleManager.java x: 1 # contributors y: 131 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/policy/NewestKSelectionPolicy.java x: 2 # contributors y: 93 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/version/finder/AbstractDatasetVersionFinder.java x: 2 # contributors y: 113 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobLauncher.java x: 16 # contributors y: 535 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/ParallelRunner.java x: 4 # contributors y: 219 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/NoWorkUnitsInfiniteSource.java x: 1 # contributors y: 56 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixRetriggeringJobCallable.java x: 5 # contributors y: 291 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/Instrumented.java x: 3 # contributors y: 183 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/GobblinMultiTaskAttempt.java x: 14 # contributors y: 460 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/util/JobMetrics.java x: 4 # contributors y: 99 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java x: 3 # contributors y: 169 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/SourceHadoopFsEndPoint.java x: 5 # contributors y: 133 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/FileListUtils.java x: 5 # contributors y: 171 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobScheduler.java x: 7 # contributors y: 432 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/SourceDecorator.java x: 4 # contributors y: 94 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/WriterUtils.java x: 9 # contributors y: 246 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskStateCollectorService.java x: 8 # contributors y: 231 lines of code gobblin-api/src/main/java/org/apache/gobblin/password/PasswordManager.java x: 4 # contributors y: 200 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/DatasetDescriptorConfigKeys.java x: 5 # contributors y: 33 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/MultiHopFlowCompiler.java x: 8 # contributors y: 284 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/lineage/LineageEventBuilder.java x: 3 # contributors y: 93 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/event/lineage/LineageInfo.java x: 4 # contributors y: 194 lines of code gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GobblinBaseOrcWriter.java x: 7 # contributors y: 301 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaStreamingExtractor.java x: 4 # contributors y: 486 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/MysqlBaseSpecStore.java x: 5 # contributors y: 285 lines of code gobblin-api/src/main/java/org/apache/gobblin/configuration/State.java x: 4 # contributors y: 258 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/ddm/work/styles/FileSystemJobStateful.java x: 1 # contributors y: 3 lines of code gobblin-temporal/src/main/java/org/apache/gobblin/temporal/util/nesting/work/SeqSliceBackedWorkSpan.java x: 1 # contributors y: 44 lines of code gobblin-completeness/src/main/java/org/apache/gobblin/completeness/verifier/KafkaAuditCountVerifier.java x: 5 # contributors y: 155 lines of code gobblin-api/src/main/java/org/apache/gobblin/source/workunit/WorkUnit.java x: 5 # contributors y: 214 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/SingleTask.java x: 8 # contributors y: 164 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskState.java x: 6 # contributors y: 275 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedAvroWriterPartitioner.java x: 3 # contributors y: 65 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/validator/TopicValidators.java x: 1 # contributors y: 74 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/ExecutorsUtils.java x: 2 # contributors y: 130 lines of code gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GenericRecordToOrcValueWriter.java x: 6 # contributors y: 355 lines of code gobblin-modules/gobblin-orc/src/main/java/org/apache/gobblin/writer/GobblinOrcWriter.java x: 5 # contributors y: 41 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/GobblinYarnLogSource.java x: 6 # contributors y: 71 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixJobTask.java x: 3 # contributors y: 185 lines of code gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/BulkResultIterator.java x: 2 # contributors y: 163 lines of code gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceExtractor.java x: 9 # contributors y: 779 lines of code gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceHistogramService.java x: 1 # contributors y: 248 lines of code gobblin-salesforce/src/main/java/org/apache/gobblin/salesforce/SalesforceSource.java x: 8 # contributors y: 355 lines of code ligradle/findbugs/findbugsExclude.xml x: 14 # contributors y: 33 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/FileSystemDecorator.java x: 3 # contributors y: 415 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/PartitionedDataWriter.java x: 9 # contributors y: 385 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ReplicaHadoopFsEndPoint.java x: 3 # contributors y: 155 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobExecutionState.java x: 2 # contributors y: 216 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecCatalogListener.java x: 5 # contributors y: 56 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/writer/HiveMetadataWriter.java x: 7 # contributors y: 410 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaExtractor.java x: 11 # contributors y: 261 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/ProxiedFileSystemCache.java x: 2 # contributors y: 233 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/orc/HiveOrcSerDeManager.java x: 4 # contributors y: 207 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixJobsMapping.java x: 3 # contributors y: 124 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/writer/IcebergMetadataWriterConfigKeys.java x: 4 # contributors y: 33 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/HelixUtils.java x: 10 # contributors y: 333 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreUtils.java x: 9 # contributors y: 445 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTask.java x: 10 # contributors y: 183 lines of code gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecProducer.java x: 4 # contributors y: 168 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/KafkaJobMonitor.java x: 6 # contributors y: 146 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/AvroFlattener.java x: 6 # contributors y: 225 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegistrationUnit.java x: 3 # contributors y: 277 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixDistributeJobExecutionLauncher.java x: 5 # contributors y: 281 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveDataset.java x: 5 # contributors y: 235 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/partition/CopyableDatasetRequestor.java x: 3 # contributors y: 85 lines of code gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSClusterLauncher.java x: 2 # contributors y: 474 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FlowSpecSearchObject.java x: 4 # contributors y: 144 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/InstrumentedSpecStore.java x: 5 # contributors y: 145 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/SpecStore.java x: 6 # contributors y: 25 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_store/FSSpecStore.java x: 7 # contributors y: 275 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/StateStore.java x: 5 # contributors y: 52 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/InnerMetricContext.java x: 3 # contributors y: 235 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/reporter/EventReporter.java x: 6 # contributors y: 174 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/EncryptionConfig.java x: 3 # contributors y: 110 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/FSDatasetDescriptor.java x: 4 # contributors y: 106 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/HiveDatasetDescriptor.java x: 2 # contributors y: 85 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/dataset/SqlDatasetDescriptor.java x: 5 # contributors y: 83 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/DatasetDescriptorErrorUtils.java x: 1 # contributors y: 62 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/AbstractPathFinder.java x: 7 # contributors y: 240 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/pathfinder/BFSPathFinder.java x: 4 # contributors y: 66 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/initializer/AvroToJdbcEntryConverterInitializer.java x: 2 # contributors y: 70 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MysqlDatasetStateStoreFactory.java x: 3 # contributors y: 27 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/source/CompactionSource.java x: 7 # contributors y: 383 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinTaskRunner.java x: 11 # contributors y: 612 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/datanodes/hive/HiveDataNode.java x: 4 # contributors y: 22 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/CountUpAndDownLatch.java x: 3 # contributors y: 60 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/AvroUtils.java x: 16 # contributors y: 753 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/avro/MRCompactorAvroKeyDedupJobRunner.java x: 4 # contributors y: 239 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/AvroSchemaFieldRemover.java x: 4 # contributors y: 101 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/converter/filter/GobblinTrackingEventFlattenFilterConverter.java x: 7 # contributors y: 110 lines of code gobblin-core/src/main/java/org/apache/gobblin/converter/avro/FlattenNestedKeyConverter.java x: 2 # contributors y: 87 lines of code gobblin-core/src/main/java/org/apache/gobblin/converter/avro/JsonElementConversionFactory.java x: 6 # contributors y: 560 lines of code gobblin-core/src/main/java/org/apache/gobblin/converter/filter/AvroFieldsPickConverter.java x: 4 # contributors y: 141 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/query/HiveAvroORCQueryGenerator.java x: 9 # contributors y: 631 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/utils/AvroHiveTypeUtils.java x: 2 # contributors y: 190 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedMultiDatasets.java x: 3 # contributors y: 146 lines of code gobblin-iceberg/src/main/java/org/apache/gobblin/iceberg/Utils/TypeInfoToSchemaParser.java x: 2 # contributors y: 249 lines of code gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractor.java x: 2 # contributors y: 179 lines of code gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterExtractorIterator.java x: 3 # contributors y: 362 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/FlowGraph.java x: 4 # contributors y: 18 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/filesystem/PathAlterationObserver.java x: 3 # contributors y: 201 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixMultiManager.java x: 5 # contributors y: 374 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/messaging/data/DynamicWorkUnitSerde.java x: 1 # contributors y: 58 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/monitoring/GitMonitoringService.java x: 1 # contributors y: 334 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/MutableSpecCatalog.java x: 6 # contributors y: 39 lines of code gobblin-yarn/src/main/java/org/apache/gobblin/yarn/event/NewContainerRequest.java x: 3 # contributors y: 21 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveRegister.java x: 7 # contributors y: 210 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionTimeRangeVerifier.java x: 5 # contributors y: 109 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/runtime/retention/DatasetCleanerCli.java x: 2 # contributors y: 71 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/data/management/retention/DatasetCleanerJob.java x: 4 # contributors y: 58 lines of code gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/ConfigStoreBackedValueInspector.java x: 2 # contributors y: 94 lines of code gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/store/hdfs/SimpleHadoopFilesystemConfigStore.java x: 3 # contributors y: 271 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HiveUtils.java x: 4 # contributors y: 123 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/FsDataWriter.java x: 11 # contributors y: 231 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/restapi/RestApiExtractor.java x: 4 # contributors y: 197 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/TaskExecutor.java x: 5 # contributors y: 322 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/HivePartitionFileSet.java x: 7 # contributors y: 164 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/hive/UnpartitionedTableFileSet.java x: 6 # contributors y: 88 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/RetryWriter.java x: 5 # contributors y: 163 lines of code gobblin-metrics-libs/gobblin-metrics/src/main/java/org/apache/gobblin/metrics/GobblinMetrics.java x: 9 # contributors y: 554 lines of code gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/BatchedPermitsRequester.java x: 3 # contributors y: 469 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/metastore/HiveMetaStoreBasedRegister.java x: 9 # contributors y: 645 lines of code gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/StreamingKafkaSpecConsumer.java x: 4 # contributors y: 182 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/writer/commands/JdbcWriterCommandsFactory.java x: 3 # contributors y: 31 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/QueryBasedSource.java x: 5 # contributors y: 351 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobRunner.java x: 6 # contributors y: 572 lines of code gobblin-core/src/main/java/org/apache/gobblin/publisher/BaseDataPublisher.java x: 10 # contributors y: 536 lines of code gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedDataPublisher.java x: 6 # contributors y: 28 lines of code gobblin-core/src/main/java/org/apache/gobblin/publisher/TimePartitionedStreamingDataPublisher.java x: 2 # contributors y: 100 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanMultiCallables.java x: 4 # contributors y: 382 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/ImmutableFSJobCatalog.java x: 4 # contributors y: 246 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_catalog/MysqlJobCatalog.java x: 1 # contributors y: 145 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporter.java x: 5 # contributors y: 94 lines of code gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/kafka/client/Kafka09ConsumerClient.java x: 7 # contributors y: 252 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionAuditCountVerifier.java x: 6 # contributors y: 127 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/MysqlDatasetStateStore.java x: 4 # contributors y: 70 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/profile/MultiDatasetFinder.java x: 3 # contributors y: 101 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/FsSpecProducer.java x: 4 # contributors y: 112 lines of code gobblin-hive-registration/src/main/java/org/apache/hadoop/hive/ql/io/orc/TypeDescriptionToObjectInspectorUtil.java x: 1 # contributors y: 367 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskStateTracker.java x: 5 # contributors y: 67 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/spec_catalog/TopologyCatalog.java x: 7 # contributors y: 220 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/troubleshooter/InMemoryMultiContextIssueRepository.java x: 1 # contributors y: 86 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/troubleshooter/MySqlMultiContextIssueRepository.java x: 1 # contributors y: 223 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_exec/JobLauncherExecutionDriver.java x: 3 # contributors y: 482 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/dataset/CleanableIcebergDataset.java x: 2 # contributors y: 122 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/util/SchedulerUtils.java x: 3 # contributors y: 113 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/JobSpec.java x: 5 # contributors y: 277 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/hadoop/TokenUtils.java x: 6 # contributors y: 331 lines of code gobblin-aws/src/main/java/org/apache/gobblin/aws/GobblinAWSTaskRunner.java x: 5 # contributors y: 122 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/writer/AsyncWriterManager.java x: 5 # contributors y: 429 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/writer/FineGrainedWatermarkTracker.java x: 3 # contributors y: 240 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/converter/AbstractAvroToOrcConverter.java x: 7 # contributors y: 427 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/publisher/HiveConvertPublisher.java x: 3 # contributors y: 370 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/TimestampBasedCopyableDataset.java x: 2 # contributors y: 167 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/retention/policy/CombineRetentionPolicy.java x: 3 # contributors y: 140 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/runtime/embedded/EmbeddedGobblinDistcp.java x: 4 # contributors y: 79 lines of code gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/ElasticsearchWriterBase.java x: 2 # contributors y: 127 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job_monitor/AvroJobSpecKafkaJobMonitor.java x: 5 # contributors y: 78 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flowgraph/BaseFlowEdge.java x: 4 # contributors y: 116 lines of code gobblin-utility/src/main/java/org/apache/gobblin/fsm/FiniteStateMachine.java x: 2 # contributors y: 253 lines of code gobblin-modules/gobblin-troubleshooter/src/main/java/org/apache/gobblin/troubleshooter/AutomaticTroubleshooterImpl.java x: 1 # contributors y: 135 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/JdbcExtractor.java x: 7 # contributors y: 861 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaProduceRateTracker.java x: 2 # contributors y: 203 lines of code gobblin-modules/gobblin-service-kafka/src/main/java/org/apache/gobblin/service/SimpleKafkaSpecConsumer.java x: 2 # contributors y: 221 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/HiveMetastoreClientPool.java x: 6 # contributors y: 150 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/verify/CompactionThresholdVerifier.java x: 6 # contributors y: 65 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/KafkaReportingFormats.java x: 4 # contributors y: 149 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/OracleExtractor.java x: 3 # contributors y: 258 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/PostgresqlExtractor.java x: 4 # contributors y: 228 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/source/jdbc/SqlServerExtractor.java x: 3 # contributors y: 246 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedSource.java x: 6 # contributors y: 207 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/instrumented/extractor/InstrumentedExtractorBase.java x: 3 # contributors y: 179 lines of code gobblin-docs/css/extra.css x: 6 # contributors y: 15 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ScheduledJobConfigurationManager.java x: 5 # contributors y: 101 lines of code gobblin-modules/gobblin-parquet/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java x: 4 # contributors y: 349 lines of code gobblin-api/src/main/java/org/apache/gobblin/typedconfig/TypedConfig.java x: 1 # contributors y: 97 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/writer/KafkaWriterConfigurationKeys.java x: 7 # contributors y: 45 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/PullFileLoader.java x: 7 # contributors y: 259 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/policy/HiveRegistrationPolicyBase.java x: 5 # contributors y: 263 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/ConfigStoreUtils.java x: 4 # contributors y: 172 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/partitioner/TimeBasedWriterPartitioner.java x: 2 # contributors y: 146 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/workunit/packer/KafkaWorkUnitPacker.java x: 7 # contributors y: 309 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/TimeBasedSubDirDatasetsFinder.java x: 3 # contributors y: 188 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/filebased/FileBasedExtractor.java x: 2 # contributors y: 150 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaEventReporterFactory.java x: 1 # contributors y: 76 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/logs/LogCopier.java x: 5 # contributors y: 355 lines of code gobblin-modules/gobblin-http/src/main/java/org/apache/gobblin/converter/AsyncHttpJoinConverter.java x: 3 # contributors y: 136 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/kafka/schemareg/LiKafkaSchemaRegistry.java x: 3 # contributors y: 172 lines of code gobblin-modules/gobblin-kafka-common/src/main/java/org/apache/gobblin/metrics/kafka/KafkaAvroSchemaRegistry.java x: 5 # contributors y: 210 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/metadata/DatasetStateStoreEntryManager.java x: 4 # contributors y: 27 lines of code gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/kafka/client/Kafka08ConsumerClient.java x: 3 # contributors y: 315 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/source/HiveSource.java x: 8 # contributors y: 350 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDataset.java x: 6 # contributors y: 231 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/azkaban/EmbeddedGobblinYarnAppLauncher.java x: 1 # contributors y: 83 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/dataset/ConvertibleHiveDataset.java x: 5 # contributors y: 139 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/GobblinHelixTaskFactory.java x: 6 # contributors y: 90 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/utils/InputStreamCSVReader.java x: 2 # contributors y: 192 lines of code gobblin-cluster/src/main/java/org/apache/gobblin/cluster/ContainerHealthMetricsService.java x: 1 # contributors y: 147 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/dataset/TimePartitionGlobFinder.java x: 1 # contributors y: 182 lines of code gobblin-modules/gobblin-parquet-apache/src/main/java/org/apache/gobblin/converter/parquet/JsonElementConversionFactory.java x: 1 # contributors y: 349 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/task/HiveConverterUtils.java x: 5 # contributors y: 303 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/FsStateStore.java x: 5 # contributors y: 261 lines of code gobblin-api/src/main/java/org/apache/gobblin/source/workunit/Extract.java x: 4 # contributors y: 130 lines of code gobblin-modules/gobblin-couchbase/src/main/java/org/apache/gobblin/couchbase/writer/CouchbaseWriter.java x: 3 # contributors y: 285 lines of code gobblin-hive-registration/src/main/java/org/apache/gobblin/hive/avro/HiveAvroSerDeManager.java x: 5 # contributors y: 147 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/extract/sftp/SftpFsHelper.java x: 2 # contributors y: 355 lines of code gobblin-metrics-libs/gobblin-metrics-base/src/main/java/org/apache/gobblin/metrics/MetricContext.java x: 4 # contributors y: 319 lines of code gobblin-service/src/main/java/org/apache/gobblin/service/modules/flow/IdentityFlowToJobSpecCompiler.java x: 5 # contributors y: 82 lines of code gobblin-restli/gobblin-throttling-service/gobblin-throttling-service-client/src/main/java/org/apache/gobblin/util/limiter/RedirectAwareRestClientRequestSender.java x: 2 # contributors y: 181 lines of code gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/ElasticsearchRestWriter.java x: 1 # contributors y: 155 lines of code gobblin-binary-management/src/main/java/org/apache/gobblin/binary_creation/AvroTestTools.java x: 1 # contributors y: 255 lines of code gobblin-binary-management/src/main/java/org/apache/gobblin/binary_creation/OrcTestTools.java x: 2 # contributors y: 277 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/mapreduce/MRCompactorJobPropCreator.java x: 3 # contributors y: 256 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/job/GobblinJobFiniteStateMachine.java x: 1 # contributors y: 120 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/util/ReflectivePredicateEvaluator.java x: 1 # contributors y: 266 lines of code gobblin-modules/gobblin-zuora/src/main/java/org/apache/gobblin/zuora/ZuoraClientImpl.java x: 1 # contributors y: 203 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/HiveJdbcConnector.java x: 3 # contributors y: 167 lines of code gobblin-core/src/main/java/org/apache/gobblin/source/extractor/partition/Partitioner.java x: 2 # contributors y: 417 lines of code gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/ingestion/google/webmaster/GoogleWebmasterDataFetcherImpl.java x: 2 # contributors y: 299 lines of code maven-sonatype/github-pr-change-log.py x: 6 # contributors y: 6 lines of code gobblin-core-base/src/main/java/org/apache/gobblin/writer/SequentialBasedBatchAccumulator.java x: 3 # contributors y: 198 lines of code gobblin-modules/gobblin-elasticsearch/src/main/java/org/apache/gobblin/elasticsearch/writer/FutureCallbackHolder.java x: 1 # contributors y: 151 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanAjaxAPIClient.java x: 2 # contributors y: 284 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/FsDatasetStateStore.java x: 4 # contributors y: 332 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/metadata/StateStoreEntryManager.java x: 5 # contributors y: 22 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/conversion/hive/writer/HiveQueryExecutionWriter.java x: 3 # contributors y: 86 lines of code gobblin-compaction/src/main/java/org/apache/gobblin/compaction/dataset/DatasetHelper.java x: 2 # contributors y: 154 lines of code gobblin-utility/src/main/java/org/apache/gobblin/util/request_allocation/ConcurrentBoundedPriorityIterable.java x: 2 # contributors y: 175 lines of code gobblin-modules/gobblin-sql/src/main/java/org/apache/gobblin/converter/jdbc/AvroToJdbcEntryConverter.java x: 2 # contributors y: 257 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceDriver.java x: 2 # contributors y: 366 lines of code gobblin-docs/developer-guide/files/codestyle-intellij-gobblin.xml x: 7 # contributors y: 523 lines of code gobblin-modules/gobblin-azkaban/src/main/java/org/apache/gobblin/service/modules/orchestration/AzkabanJobHelper.java x: 1 # contributors y: 226 lines of code gobblin-core/src/main/java/org/apache/gobblin/converter/json/JsonSchema.java x: 1 # contributors y: 198 lines of code gobblin-modules/gobblin-grok/src/main/java/org/apache/gobblin/converter/grok/GrokToJsonConverter.java x: 1 # contributors y: 128 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/api/TopologySpec.java x: 2 # contributors y: 239 lines of code gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleAnalyticsUnsampledExtractor.java x: 2 # contributors y: 281 lines of code gobblin-admin/src/main/resources/static/js/collections/job-executions.js x: 9 # contributors y: 42 lines of code gobblin-api/src/main/java/gobblin/source/extractor/CheckpointableWatermark.java x: 5 # contributors y: 3 lines of code gobblin-api/src/main/java/org/apache/gobblin/dataset/comparators/package-info.java x: 3 # contributors y: 1 lines of code gobblin-runtime/src/main/java/gobblin/runtime/TaskState.java x: 23 # contributors y: 3 lines of code gobblin-runtime/src/main/java/gobblin/runtime/mapreduce/GobblinWorkUnitsInputFormat.java x: 5 # contributors y: 10 lines of code gobblin-api/src/main/java/gobblin/configuration/ImmutableWorkUnitState.java x: 14 # contributors y: 6 lines of code gobblin-api/src/main/java/gobblin/configuration/SourceState.java x: 14 # contributors y: 24 lines of code gobblin-api/src/main/java/gobblin/configuration/State.java x: 26 # contributors y: 13 lines of code gobblin-api/src/main/java/gobblin/configuration/WorkUnitState.java x: 22 # contributors y: 14 lines of code gobblin-api/src/main/java/gobblin/source/extractor/Watermark.java x: 13 # contributors y: 3 lines of code gobblin-api/src/main/java/gobblin/source/extractor/WatermarkInterval.java x: 12 # contributors y: 6 lines of code gobblin-api/src/main/java/gobblin/source/workunit/Extract.java x: 13 # contributors y: 26 lines of code gobblin-api/src/main/java/gobblin/source/workunit/ImmutableExtract.java x: 10 # contributors y: 17 lines of code gobblin-api/src/main/java/gobblin/source/workunit/ImmutableWorkUnit.java x: 17 # contributors y: 6 lines of code gobblin-api/src/main/java/gobblin/source/workunit/MultiWorkUnit.java x: 15 # contributors y: 7 lines of code gobblin-api/src/main/java/gobblin/source/workunit/WorkUnit.java x: 16 # contributors y: 24 lines of code gobblin-core/src/main/java/gobblin/state/ConstructState.java x: 8 # contributors y: 13 lines of code gobblin-hive-registration/src/main/java/gobblin/hive/HiveRegProps.java x: 13 # contributors y: 10 lines of code gobblin-runtime/src/main/java/gobblin/runtime/JobState.java x: 25 # contributors y: 30 lines of code gobblin-admin/src/main/java/org/apache/gobblin/cli/JobInfoPrintUtils.java x: 1 # contributors y: 179 lines of code gobblin-aws/src/main/java/org/apache/gobblin/aws/AWSSdkClient.java x: 1 # contributors y: 308 lines of code gobblin-config-management/gobblin-config-core/src/main/java/org/apache/gobblin/config/common/impl/InMemoryTopology.java x: 1 # contributors y: 117 lines of code gobblin-core/src/main/java/org/apache/gobblin/writer/http/AbstractHttpWriterBuilder.java x: 1 # contributors y: 126 lines of code gobblin-data-management/src/main/java/org/apache/gobblin/data/management/copy/replication/ConfigBasedDatasetsFinder.java x: 1 # contributors y: 199 lines of code gobblin-example/src/main/java/org/apache/gobblin/example/wikipedia/WikipediaExtractor.java x: 1 # contributors y: 332 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV100.java x: 1 # contributors y: 750 lines of code gobblin-metastore/src/main/java/org/apache/gobblin/metastore/database/DatabaseJobHistoryStoreV101.java x: 1 # contributors y: 878 lines of code gobblin-modules/gobblin-compliance/src/main/java/org/apache/gobblin/compliance/purger/HivePurgerSource.java x: 1 # contributors y: 251 lines of code gobblin-modules/gobblin-crypto/src/main/java/org/apache/gobblin/crypto/RotatingAESCodec.java x: 1 # contributors y: 236 lines of code gobblin-modules/gobblin-kafka-08/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaWrapper.java x: 1 # contributors y: 429 lines of code gobblin-modules/gobblin-kafka-09/src/main/java/org/apache/gobblin/source/extractor/extract/kafka/KafkaSimpleStreamingExtractor.java x: 1 # contributors y: 185 lines of code gobblin-modules/gobblin-metadata/src/main/java/org/apache/gobblin/metadata/types/GlobalMetadata.java x: 1 # contributors y: 234 lines of code gobblin-modules/gobblin-metrics-graphite/src/main/java/org/apache/gobblin/metrics/graphite/GraphiteReporter.java x: 1 # contributors y: 172 lines of code gobblin-modules/google-ingestion/src/main/java/org/apache/gobblin/source/extractor/extract/google/GoogleCommon.java x: 1 # contributors y: 162 lines of code gobblin-runtime/src/main/java/org/apache/gobblin/runtime/instance/StandardGobblinInstanceLauncher.java x: 1 # contributors y: 228 lines of code gobblin-metastore/src/main/resources/db/migration/V1_0_2__LauncherType_enum_expansion.sql x: 2 # contributors y: 1 lines of code gobblin-admin/src/main/resources/static/css/gobblin.css x: 9 # contributors y: 96 lines of code gobblin-admin/src/main/resources/static/css/tablesorter.theme.css x: 9 # contributors y: 171 lines of code gobblin-admin/src/main/resources/static/index.html x: 11 # contributors y: 234 lines of code gobblin-admin/src/main/resources/static/js/gobblin.js x: 9 # contributors y: 72 lines of code gobblin-admin/src/main/resources/static/js/router.js x: 9 # contributors y: 21 lines of code gobblin-admin/src/main/resources/static/js/views/job-execution-view.js x: 10 # contributors y: 169 lines of code gobblin-admin/src/main/resources/static/js/views/job-view.js x: 10 # contributors y: 200 lines of code gobblin-admin/src/main/resources/static/js/views/over-view.js x: 10 # contributors y: 73 lines of code gobblin-admin/src/main/resources/static/js/models/job-execution.js x: 10 # contributors y: 127 lines of code gobblin-admin/src/main/resources/static/js/models/task-execution.js x: 10 # contributors y: 48 lines of code gobblin-docs/developer-guide/files/codestyle-eclipse.xml x: 6 # contributors y: 291 lines of code gobblin-docs/js/extra.js x: 6 # contributors y: 30 lines of code gobblin-metastore/src/main/resources/db/migration/V1_0_1__Performance_improvements.sql x: 5 # contributors y: 14 lines of code
949.0
lines of code
  min: 1.0
  average: 71.96
  25th percentile: 15.0
  median: 37.0
  75th percentile: 85.5
  max: 949.0
0 32.0
# contributors
min: 1.0 | average: 2.21 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 32.0