Uber / uForwarder
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 272 files with 24,384 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 0 files changed 21-50 times (0 lines of code)
    • 0 files changed 6-20 times (0 lines of code)
    • 272 files changed 1-5 times (24,384 lines of code)
0% | 0% | 0% | 0% | 100%
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 272 files with 24,384 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 0 files changed by 6-10 contributors (0 lines of code)
    • 272 files changed by 2-5 contributors (24,384 lines of code)
    • 0 files changed by 1 contributor (0 lines of code)
0% | 0% | 0% | 100% | 0%
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, proto, json, yaml, html, sh, md, yml, properties, gitignore, py, gitattributes, txt, bat, xml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 0% | 0% | 100%
proto0% | 0% | 0% | 0% | 100%
html0% | 0% | 0% | 0% | 100%
yaml0% | 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
uforwarder-core0% | 0% | 0% | 0% | 100%
uforwarder0% | 0% | 0% | 0% | 100%
idl0% | 0% | 0% | 0% | 100%
instrumentation0% | 0% | 0% | 0% | 100%
uforwarder-container0% | 0% | 0% | 0% | 100%
uforwarder-client0% | 0% | 0% | 0% | 100%
uforwarder-sample-consumer0% | 0% | 0% | 0% | 100%
fievel-common0% | 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
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 276 10 2023-12-01 2024-03-06 5 3 43356004+yangy0000@users.no... chenz@uber.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 402 22 2023-12-01 2024-03-06 5 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 127 17 2023-12-01 2024-03-06 4 3 43356004+yangy0000@users.no... chenz@uber.com
FievelTestBase.java
in fievel-common/src/main/java/com/uber/fievel/testing/base
 2 - 2023-12-01 2024-01-08 3 2 43356004+yangy0000@users.no... chenz@uber.com
UForwarderControllerContainer.java
in uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container
 16 2 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
StructuredLogging.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 41 9 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
NetworkUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 51 5 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
proto
master_worker_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 93 - 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
PipelineFactoryImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 107 2 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 149 7 2023-12-01 2024-01-26 3 3 43356004+yangy0000@users.no... chenz@uber.com
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 192 6 2023-12-01 2024-01-26 3 3 43356004+yangy0000@users.no... chenz@uber.com
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 453 10 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
PipelineFactory.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 10 1 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
ZookeeperConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 19 4 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredFields.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 22 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
NestedPermit.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 30 1 2024-01-08 2024-01-26 2 2 67832317+ericzhifengchen@us... chenz@uber.com
MetricsUtils.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 31 3 2024-01-08 2024-03-06 2 2 67832317+ericzhifengchen@us... chenz@uber.com
GrpcDispatcherConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 33 8 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoordinatorAutoConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg
 40 1 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 41 2 2023-12-01 2024-01-26 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredTags.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 48 9 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoreInfraAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 49 5 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
UForwarderUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 52 2 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job_status.proto
in idl/src/main/proto/data/kafka/data-transfer
 53 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
AckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 55 - 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancingWorkerWithSortedJobs.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 58 9 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 69 16 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
AdminClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 75 13 2024-01-08 2024-01-26 2 2 67832317+ericzhifengchen@us... chenz@uber.com
KafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 84 2 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 86 22 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
DlqTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 87 3 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
OriginalTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 95 3 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
DlqDispatchManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 95 9 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
application-uforwarder-controller.yaml
in uforwarder/src/main/resources
 96 - 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoreInfra.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 101 17 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaFetcherFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 106 3 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
UForwarderWorkerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 128 7 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
State.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 129 6 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
PipelineImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 146 15 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
StateRegistering.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 149 3 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
BatchRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 167 4 2023-12-01 2024-01-26 2 3 43356004+yangy0000@users.no... chenz@uber.com
DispatcherImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 168 6 2023-12-01 2024-01-26 2 3 43356004+yangy0000@users.no... chenz@uber.com
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 169 5 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 169 7 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 172 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.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
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 276 10 2023-12-01 2024-03-06 5 3 43356004+yangy0000@users.no... chenz@uber.com
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 402 22 2023-12-01 2024-03-06 5 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 127 17 2023-12-01 2024-03-06 4 3 43356004+yangy0000@users.no... chenz@uber.com
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 192 6 2023-12-01 2024-01-26 3 3 43356004+yangy0000@users.no... chenz@uber.com
proto
master_worker_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 93 - 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
UForwarderControllerContainer.java
in uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container
 16 2 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
NetworkUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 51 5 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 453 10 2023-12-01 2024-01-08 3 3 43356004+yangy0000@users.no... 67832317+ericzhifengchen@us...
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 149 7 2023-12-01 2024-01-26 3 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredLogging.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 41 9 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
PipelineFactoryImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 107 2 2023-12-01 2024-03-06 3 3 43356004+yangy0000@users.no... chenz@uber.com
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
ZookeeperConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 19 4 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 254 8 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoreInfra.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 101 17 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredFields.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 22 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoreInfraAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 49 5 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 69 16 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 235 4 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 946 29 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 84 2 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
PipelineFactory.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 10 1 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 356 18 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
StateRegistering.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 149 3 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
StateWorking.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 409 4 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
State.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 129 6 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job_status.proto
in idl/src/main/proto/data/kafka/data-transfer
 53 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 382 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 172 - 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
UForwarderUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 52 2 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
application-uforwarder-controller.yaml
in uforwarder/src/main/resources
 96 - 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 86 22 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
GrpcDispatcherConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 33 8 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
RebalancingWorkerWithSortedJobs.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 58 9 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
BatchRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 167 4 2023-12-01 2024-01-26 2 3 43356004+yangy0000@users.no... chenz@uber.com
CoordinatorAutoConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg
 40 1 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
StructuredTags.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 48 9 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 222 15 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 341 26 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1008 29 2023-12-01 2024-03-06 2 3 43356004+yangy0000@users.no... chenz@uber.com
LinkedAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 208 13 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
ProcessorFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 41 2 2023-12-01 2024-01-26 2 3 43356004+yangy0000@users.no... chenz@uber.com
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 322 25 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
DlqDispatchManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 95 9 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.com
AckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 55 - 2023-12-01 2024-01-08 2 3 43356004+yangy0000@users.no... chenz@uber.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
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 408 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 389 26 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerWorkerService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 326 9 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 241 16 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
masterJobs.html
in uforwarder-core/src/main/resources
 234 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 233 14 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerAdminService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 231 7 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
workerJobs.html
in uforwarder-core/src/main/resources
 228 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 219 19 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 214 48 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Instrument.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 204 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 200 14 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LeaderSelector.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator
 186 10 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 172 9 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaDispatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 165 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 160 10 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 156 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 146 33 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
StubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 145 15 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
HibernatingJobRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 142 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
RebalancingJobGroup.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 134 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
BufferedWriteDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 130 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ControllerClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 130 9 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AbstractInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 128 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
workers.html
in uforwarder-core/src/main/resources
 123 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaCheckpointManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 114 6 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 111 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
masters.html
in uforwarder-core/src/main/resources
 107 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
JobThroughputMonitor.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 104 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ScaleWindow.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 102 12 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
MockConsumerServiceStarter.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 101 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LoggingAndMetricsStoreDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 98 13 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ShutdownableThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils
 95 12 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
SampleConsumerAutoConfiguration.java
in uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder
 94 4 2024-01-08 2024-01-08 1 2 67832317+ericzhifengchen@us... chenz@uber.com
WorkersJson.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management
 89 1 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaDispatcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 89 16 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
ShadowRebalancerDelegateImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 89 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
LocalStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 87 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
WindowedAggregator.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 85 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
proto
master_admin_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 81 - 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaAdminClientConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 81 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AdaptiveInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 81 8 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
MetadataAdapter.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 80 11 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
AckManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 78 7 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
KafkaUtils.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils
 77 4 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
GrpcController.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 76 5 2023-12-01 2023-12-01 1 2 43356004+yangy0000@users.no... chenz@uber.com
Correlations

File Size vs. Number of Changes: 272 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 382 lines of code y: 2 # changes idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 172 lines of code y: 2 # changes idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 53 lines of code y: 2 # changes idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 93 lines of code y: 3 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 402 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 101 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 49 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 22 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 69 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 129 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 149 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 409 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 946 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 60 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 127 lines of code y: 4 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 84 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 10 lines of code y: 2 # changes uforwarder-core/src/main/resources/workerJobStatus.html x: 197 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 31 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 41 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 33 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 276 lines of code y: 5 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 402 lines of code y: 5 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 107 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 146 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 169 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 311 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 214 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java x: 87 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 106 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 95 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 236 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 1008 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 341 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 289 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 75 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 192 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 149 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java x: 167 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java x: 30 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 41 lines of code y: 2 # changes uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 264 lines of code y: 3 # changes uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 16 lines of code y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java x: 235 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java x: 19 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 254 lines of code y: 2 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 356 lines of code y: 2 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java x: 12 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java x: 94 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 23 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 47 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java x: 51 lines of code y: 1 # changes uforwarder-sample-consumer/src/main/resources/application.yaml x: 5 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 51 lines of code y: 3 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java x: 52 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/confg/CoordinatorAutoConfiguration.java x: 40 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 453 lines of code y: 3 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 58 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 322 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AckTrackingQueue.java x: 55 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 248 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 25 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 258 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 208 lines of code y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 222 lines of code y: 2 # changes fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 2 lines of code y: 3 # changes idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto x: 16 lines of code y: 1 # changes idl/src/main/proto/data/kafka/data-transfer/master_admin_service.proto x: 81 lines of code y: 1 # changes idl/src/main/proto/data/kafka/data-transfer/worker.proto x: 41 lines of code y: 1 # changes idl/src/main/proto/data/kafka/messaging-consumer/dlq_metadata.proto x: 35 lines of code y: 1 # changes idl/src/main/proto/data/kafka/messaging-consumer/offset_mapping.proto x: 72 lines of code y: 1 # changes idl/src/main/proto/data/kafka/messaging-consumer/offsets.proto x: 55 lines of code y: 1 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java x: 204 lines of code y: 1 # changes instrumentation/src/main/java/com/uber/data/kafka/instrumentation/NoopClosable.java x: 9 lines of code y: 1 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinition.java x: 37 lines of code y: 1 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerResponse.java x: 48 lines of code y: 1 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/KafkaServerMethodDefinition.java x: 33 lines of code y: 1 # changes uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapter.java x: 80 lines of code y: 1 # changes uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderContainer.java x: 28 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/HostResolver.java x: 7 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JobUtils.java x: 219 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactory.java x: 42 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaUtils.java x: 31 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/NodeUtils.java x: 14 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/Placement.java x: 18 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/ProtoSerializationFactory.java x: 26 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StaticResolver.java x: 19 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 214 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/ZKStringSerializer.java x: 39 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/context/ContextManager.java x: 45 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThread.java x: 95 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 200 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarConfiguration.java x: 146 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobThroughputMonitor.java x: 104 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleComputer.java x: 10 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleState.java x: 178 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleWindow.java x: 102 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/WorkerStoreConfiguration.java x: 54 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java x: 186 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorWithOffsets.java x: 64 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 156 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancingJobGroup.java x: 134 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java x: 231 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java x: 326 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java x: 130 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java x: 87 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java x: 98 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 160 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java x: 241 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java x: 233 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/JobStatusHtml.java x: 21 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/WorkersJson.java x: 89 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 172 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcController.java x: 76 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java x: 165 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java x: 114 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/ThroughputTracker.java x: 66 lines of code y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java x: 396 lines of code y: 1 # changes uforwarder-core/src/main/resources/masters.html x: 107 lines of code y: 1 # changes uforwarder-core/src/main/resources/workerJobs.html x: 228 lines of code y: 1 # changes uforwarder-core/src/main/resources/workers.html x: 123 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 408 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/KafkaUtils.java x: 77 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java x: 101 lines of code y: 1 # changes uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java x: 50 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java x: 142 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/utils/RetryUtils.java x: 70 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/DedupHeaderInterceptor.java x: 62 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java x: 212 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcUtils.java x: 69 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java x: 128 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 111 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/WindowedAggregator.java x: 85 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 389 lines of code y: 1 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/StubManager.java x: 145 lines of code y: 1 # changes
5.0
# changes
  min: 1.0
  average: 1.32
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 5.0
0 1008.0
lines of code
min: 2.0 | average: 89.65 | 25th percentile: 20.0 | median: 48.0 | 75th percentile: 106.0 | max: 1008.0

Number of Contributors vs. Number of Changes: 272 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 3 # contributors y: 2 # changes idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 3 # contributors y: 3 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 # contributors y: 1 # changes uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 3 # contributors y: 4 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 # contributors y: 2 # changes uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 3 # contributors y: 5 # changes fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 2 # contributors y: 3 # changes
5.0
# changes
  min: 1.0
  average: 1.32
  25th percentile: 1.0
  median: 1.0
  75th percentile: 1.0
  max: 5.0
0 3.0
# contributors
min: 2.0 | average: 2.23 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 3.0

Number of Contributors vs. File Size: 272 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 3 # contributors y: 382 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 3 # contributors y: 172 lines of code idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 3 # contributors y: 53 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 3 # contributors y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 3 # contributors y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 3 # contributors y: 101 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 3 # contributors y: 49 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 3 # contributors y: 22 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 3 # contributors y: 69 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 3 # contributors y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 3 # contributors y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 3 # contributors y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 3 # contributors y: 946 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 # contributors y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 3 # contributors y: 84 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 3 # contributors y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 3 # contributors y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 # contributors y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 3 # contributors y: 41 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 3 # contributors y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 3 # contributors y: 276 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 3 # contributors y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 3 # contributors y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 3 # contributors y: 169 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 3 # contributors y: 311 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 3 # contributors y: 214 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 3 # contributors y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 3 # contributors y: 1008 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 3 # contributors y: 341 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 3 # contributors y: 289 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 2 # contributors y: 75 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 3 # contributors y: 192 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 3 # contributors y: 264 lines of code uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 3 # contributors y: 16 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 3 # contributors y: 254 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 3 # contributors y: 356 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java x: 2 # contributors y: 12 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java x: 2 # contributors y: 94 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 2 # contributors y: 23 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 2 # contributors y: 47 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java x: 2 # contributors y: 51 lines of code uforwarder-sample-consumer/src/main/resources/application.yaml x: 2 # contributors y: 5 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 3 # contributors y: 453 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 3 # contributors y: 58 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 3 # contributors y: 322 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 3 # contributors y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 2 # contributors y: 25 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 3 # contributors y: 258 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 3 # contributors y: 208 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 3 # contributors y: 222 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 3 # contributors y: 96 lines of code fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 2 # contributors y: 2 lines of code idl/src/main/proto/data/kafka/data-transfer/debug.proto x: 2 # contributors y: 59 lines of code idl/src/main/proto/data/kafka/data-transfer/job_snapshot.proto x: 2 # contributors y: 16 lines of code idl/src/main/proto/data/kafka/data-transfer/master_admin_service.proto x: 2 # contributors y: 81 lines of code idl/src/main/proto/data/kafka/data-transfer/worker.proto x: 2 # contributors y: 41 lines of code idl/src/main/proto/data/kafka/messaging-consumer/dlq_metadata.proto x: 2 # contributors y: 35 lines of code idl/src/main/proto/data/kafka/messaging-consumer/offsets.proto x: 2 # contributors y: 55 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrument.java x: 2 # contributors y: 204 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/NoopClosable.java x: 2 # contributors y: 9 lines of code uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/ConsumerBytesServerMethodDefinition.java x: 2 # contributors y: 37 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JobUtils.java x: 2 # contributors y: 219 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 2 # contributors y: 214 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 2 # contributors y: 200 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalarConfiguration.java x: 2 # contributors y: 146 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/JobThroughputMonitor.java x: 2 # contributors y: 104 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleState.java x: 2 # contributors y: 178 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/ScaleWindow.java x: 2 # contributors y: 102 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator/LeaderSelector.java x: 2 # contributors y: 186 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/JobCreatorWithOffsets.java x: 2 # contributors y: 64 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/WorkerManager.java x: 2 # contributors y: 71 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 2 # contributors y: 156 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/RebalancingJobGroup.java x: 2 # contributors y: 134 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerAdminService.java x: 2 # contributors y: 231 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc/ControllerWorkerService.java x: 2 # contributors y: 326 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/BufferedWriteDecorator.java x: 2 # contributors y: 130 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LocalStore.java x: 2 # contributors y: 87 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/LoggingAndMetricsStoreDecorator.java x: 2 # contributors y: 98 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 2 # contributors y: 160 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TTLDecorator.java x: 2 # contributors y: 241 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/WorkersJson.java x: 2 # contributors y: 89 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 2 # contributors y: 172 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/GrpcController.java x: 2 # contributors y: 76 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka/KafkaDispatcher.java x: 2 # contributors y: 165 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaCheckpointManager.java x: 2 # contributors y: 114 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineManager.java x: 2 # contributors y: 396 lines of code uforwarder-core/src/main/resources/workerJobs.html x: 2 # contributors y: 228 lines of code uforwarder-core/src/main/resources/workers.html x: 2 # contributors y: 123 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 2 # contributors y: 408 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/HibernatingJobRebalancer.java x: 2 # contributors y: 142 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 2 # contributors y: 111 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 2 # contributors y: 389 lines of code
1008.0
lines of code
  min: 2.0
  average: 89.65
  25th percentile: 20.0
  median: 48.0
  75th percentile: 106.0
  max: 1008.0
0 3.0
# contributors
min: 2.0 | average: 2.23 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 3.0