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