Uber / uForwarder
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
4% | 3% | 39% | 22% | 30%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java4% | 4% | 39% | 21% | 30%
html0% | 0% | 51% | 48% | 0%
proto0% | 0% | 34% | 15% | 49%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
uforwarder9% | 0% | 44% | 19% | 26%
uforwarder-core0% | 8% | 32% | 28% | 30%
instrumentation0% | 0% | 87% | 0% | 12%
idl0% | 0% | 34% | 15% | 49%
uforwarder-container0% | 0% | 82% | 0% | 17%
uforwarder-client0% | 0% | 0% | 0% | 100%
uforwarder-sample-consumer0% | 0% | 0% | 0% | 100%
fievel-common0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1008 29
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 946 29
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 453 10
StateWorking.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 409 4
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 408 11
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 402 22
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 389 26
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 382 -
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 356 18
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 341 26
ControllerWorkerService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 326 9
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 322 25
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 311 13
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 276 10
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8
BlockingQueueStubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 258 15
JobManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager
 254 8
ArrayAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 248 15
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 241 16
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 235 4
masterJobs.html
in uforwarder-core/src/main/resources
 234 -
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 233 14
ControllerAdminService.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc
 231 7
workerJobs.html
in uforwarder-core/src/main/resources
 228 -
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 222 15
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 219 19
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 214 48
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 214 25
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16
LinkedAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 208 13
Instrument.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 204 11
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 200 14
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 -
BatchJobCreator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator
 192 6
LeaderSelector.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator
 186 10
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 172 9
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 172 -
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 169 7
RetryTopicKafkaFetcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher
 169 5
DispatcherImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 168 6
BatchRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 167 4
KafkaDispatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 165 6
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 160 10
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 156 5
StateRegistering.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 149 3
Files With Most Units (Top 50)
File# lines# units
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 214 48
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 146 33
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 946 29
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1008 29
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 341 26
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 389 26
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 322 25
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 214 25
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 86 22
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 402 22
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 219 19
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 356 18
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18
CoreInfra.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 101 17
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 127 17
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 241 16
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 69 16
KafkaDispatcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 89 16
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 222 15
StubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 145 15
BlockingQueueStubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 258 15
ArrayAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 248 15
PipelineImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 146 15
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 233 14
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 200 14
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14
RebalancingJobGroup.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 134 13
LoggingAndMetricsStoreDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 98 13
BufferedWriteDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 130 13
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13
AdminClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 75 13
AbstractInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 128 13
LinkedAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 208 13
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 311 13
StoreConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 49 12
ScaleWindow.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 102 12
ShutdownableThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils
 95 12
GrpcControllerConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 48 12
LocalStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 87 11
Instrument.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 204 11
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 408 11
KafkaAdminClientConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 81 11
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11
LongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 111 11
WindowedTokenLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 71 11
MetadataAdapter.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 80 11
Files With Long Lines (Top 7)

There are 7 files with lines longer than 120 characters. In total, there are 49 long lines.

File# lines# units# long lines
proto
master_worker_service.proto
in idl/src/main/proto/data/kafka/data-transfer
 93 - 22
workers.html
in uforwarder-core/src/main/resources
 123 - 6
masters.html
in uforwarder-core/src/main/resources
 107 - 5
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 - 5
masterJobs.html
in uforwarder-core/src/main/resources
 234 - 5
workerJobs.html
in uforwarder-core/src/main/resources
 228 - 5
proto
group_sub.proto
in idl/src/main/proto/data/kafka/messaging-consumer
 24 - 1
Correlations

File Size vs. Commits (all time): 272 points

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

File Size vs. Contributors (all time): 272 points

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

File Size vs. Commits (30 days): 39 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 3 commits (30d) y: 382 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 3 commits (30d) y: 172 lines of code idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 3 commits (30d) y: 53 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 3 commits (30d) y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 3 commits (30d) y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 3 commits (30d) y: 101 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 3 commits (30d) y: 49 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 3 commits (30d) y: 22 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 3 commits (30d) y: 69 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 3 commits (30d) y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 3 commits (30d) y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 3 commits (30d) y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 3 commits (30d) y: 946 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 3 commits (30d) y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 3 commits (30d) y: 84 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 3 commits (30d) y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 3 commits (30d) y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 3 commits (30d) y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 3 commits (30d) y: 41 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 3 commits (30d) y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 3 commits (30d) y: 276 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 3 commits (30d) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 3 commits (30d) y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 3 commits (30d) y: 169 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 3 commits (30d) y: 311 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 3 commits (30d) y: 214 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 3 commits (30d) y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 3 commits (30d) y: 1008 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 3 commits (30d) y: 341 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 3 commits (30d) y: 289 lines of code
1008.0
lines of code
  min: 10.0
  average: 198.95
  25th percentile: 68.0
  median: 128.0
  75th percentile: 276.0
  max: 1008.0
0 3.0
commits (30d)
min: 3.0 | average: 3.0 | 25th percentile: 3.0 | median: 3.0 | 75th percentile: 3.0 | max: 3.0

File Size vs. Contributors (30 days): 39 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 2 contributors (30d) y: 382 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 2 contributors (30d) y: 172 lines of code idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 2 contributors (30d) y: 53 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 2 contributors (30d) y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 2 contributors (30d) y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 2 contributors (30d) y: 101 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 2 contributors (30d) y: 49 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 2 contributors (30d) y: 22 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 2 contributors (30d) y: 69 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 2 contributors (30d) y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 2 contributors (30d) y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 2 contributors (30d) y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 2 contributors (30d) y: 946 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 contributors (30d) y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 2 contributors (30d) y: 84 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 2 contributors (30d) y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 2 contributors (30d) y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 contributors (30d) y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 2 contributors (30d) y: 41 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 2 contributors (30d) y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 2 contributors (30d) y: 276 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 2 contributors (30d) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 2 contributors (30d) y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 2 contributors (30d) y: 169 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 2 contributors (30d) y: 311 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 2 contributors (30d) y: 214 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 2 contributors (30d) y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 2 contributors (30d) y: 1008 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 2 contributors (30d) y: 341 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 2 contributors (30d) y: 289 lines of code
1008.0
lines of code
  min: 10.0
  average: 198.95
  25th percentile: 68.0
  median: 128.0
  75th percentile: 276.0
  max: 1008.0
0 2.0
contributors (30d)
min: 2.0 | average: 2.0 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 2.0

File Size vs. Commits (90 days): 75 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 3 commits (90d) y: 382 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 3 commits (90d) y: 172 lines of code idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 3 commits (90d) y: 53 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 5 commits (90d) y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 3 commits (90d) y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 3 commits (90d) y: 101 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 3 commits (90d) y: 49 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 3 commits (90d) y: 22 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 3 commits (90d) y: 69 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 3 commits (90d) y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 3 commits (90d) y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 3 commits (90d) y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 3 commits (90d) y: 946 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 3 commits (90d) y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 4 commits (90d) y: 127 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 3 commits (90d) y: 84 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 3 commits (90d) y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 3 commits (90d) y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 5 commits (90d) y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 5 commits (90d) y: 41 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 3 commits (90d) y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 7 commits (90d) y: 276 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 7 commits (90d) y: 402 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 5 commits (90d) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 3 commits (90d) y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 3 commits (90d) y: 169 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 3 commits (90d) y: 311 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 3 commits (90d) y: 214 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 3 commits (90d) y: 106 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 3 commits (90d) y: 95 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 5 commits (90d) y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 3 commits (90d) y: 1008 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 3 commits (90d) y: 341 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 5 commits (90d) y: 289 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 4 commits (90d) y: 75 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 4 commits (90d) y: 192 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 4 commits (90d) y: 149 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/BatchRpcUriRebalancer.java x: 2 commits (90d) y: 167 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java x: 4 commits (90d) y: 30 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 2 commits (90d) y: 41 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 1 commits (90d) y: 264 lines of code uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 1 commits (90d) y: 16 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java x: 2 commits (90d) y: 235 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java x: 2 commits (90d) y: 19 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 2 commits (90d) y: 254 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 2 commits (90d) y: 356 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java x: 2 commits (90d) y: 12 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerAutoConfiguration.java x: 2 commits (90d) y: 94 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 2 commits (90d) y: 23 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 2 commits (90d) y: 47 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/Utils.java x: 2 commits (90d) y: 51 lines of code uforwarder-sample-consumer/src/main/resources/application.yaml x: 2 commits (90d) y: 5 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 1 commits (90d) y: 51 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderUtils.java x: 2 commits (90d) y: 52 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java x: 2 commits (90d) y: 86 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 1 commits (90d) y: 453 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 2 commits (90d) y: 58 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 2 commits (90d) y: 322 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 2 commits (90d) y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 2 commits (90d) y: 25 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 2 commits (90d) y: 258 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 2 commits (90d) y: 208 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 2 commits (90d) y: 222 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 2 commits (90d) y: 96 lines of code fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 1 commits (90d) y: 2 lines of code
1008.0
lines of code
  min: 2.0
  average: 163.33
  25th percentile: 49.0
  median: 101.0
  75th percentile: 235.0
  max: 1008.0
0 7.0
commits (90d)
min: 1.0 | average: 2.84 | 25th percentile: 2.0 | median: 3.0 | 75th percentile: 3.0 | max: 7.0

File Size vs. Contributors (90 days): 75 points

idl/src/main/proto/data/kafka/data-transfer/job.proto x: 2 contributors (90d) y: 382 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 2 contributors (90d) y: 172 lines of code idl/src/main/proto/data/kafka/data-transfer/job_status.proto x: 2 contributors (90d) y: 53 lines of code idl/src/main/proto/data/kafka/data-transfer/master_worker_service.proto x: 2 contributors (90d) y: 93 lines of code instrumentation/src/main/java/com/uber/data/kafka/instrumentation/Instrumentation.java x: 2 contributors (90d) y: 402 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfra.java x: 2 contributors (90d) y: 101 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/CoreInfraAutoConfiguration.java x: 2 contributors (90d) y: 49 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 2 contributors (90d) y: 22 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 2 contributors (90d) y: 69 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/State.java x: 2 contributors (90d) y: 129 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateRegistering.java x: 2 contributors (90d) y: 149 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller/StateWorking.java x: 2 contributors (90d) y: 409 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 2 contributors (90d) y: 946 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/InflightMessageTracker.java x: 2 contributors (90d) y: 60 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 2 contributors (90d) y: 84 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/PipelineFactory.java x: 2 contributors (90d) y: 10 lines of code uforwarder-core/src/main/resources/workerJobStatus.html x: 2 contributors (90d) y: 197 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/MetricsUtils.java x: 2 contributors (90d) y: 31 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 2 contributors (90d) y: 41 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/GrpcDispatcherConfiguration.java x: 2 contributors (90d) y: 33 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 2 contributors (90d) y: 276 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineFactoryImpl.java x: 2 contributors (90d) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/PipelineImpl.java x: 2 contributors (90d) y: 146 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 2 contributors (90d) y: 169 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 2 contributors (90d) y: 311 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 2 contributors (90d) y: 214 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageStub.java x: 2 contributors (90d) y: 236 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 2 contributors (90d) y: 1008 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 2 contributors (90d) y: 341 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/UnprocessedMessageManager.java x: 2 contributors (90d) y: 289 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/AdminClient.java x: 2 contributors (90d) y: 75 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator/BatchJobCreator.java x: 2 contributors (90d) y: 192 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 1 contributors (90d) y: 264 lines of code uforwarder-container/src/main/java/com/uber/data/kafka/consumerproxy/container/UForwarderControllerContainer.java x: 1 contributors (90d) y: 16 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config/ZookeeperConfiguration.java x: 2 contributors (90d) y: 19 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 2 contributors (90d) y: 254 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 2 contributors (90d) y: 356 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumer.java x: 2 contributors (90d) y: 12 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerProducer.java x: 2 contributors (90d) y: 47 lines of code uforwarder-sample-consumer/src/main/resources/application.yaml x: 2 contributors (90d) y: 5 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 1 contributors (90d) y: 51 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/AbstractRpcUriRebalancer.java x: 1 contributors (90d) y: 453 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancingWorkerWithSortedJobs.java x: 2 contributors (90d) y: 58 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 2 contributors (90d) y: 322 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ArrayAckTrackingQueue.java x: 2 contributors (90d) y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/Attribute.java x: 2 contributors (90d) y: 25 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/BlockingQueueStubManager.java x: 2 contributors (90d) y: 258 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/LinkedAckTrackingQueue.java x: 2 contributors (90d) y: 208 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/MessageAckStatusManager.java x: 2 contributors (90d) y: 222 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 2 contributors (90d) y: 96 lines of code fievel-common/src/main/java/com/uber/fievel/testing/base/FievelTestBase.java x: 1 contributors (90d) y: 2 lines of code
1008.0
lines of code
  min: 2.0
  average: 163.33
  25th percentile: 49.0
  median: 101.0
  75th percentile: 235.0
  max: 1008.0
0 2.0
contributors (90d)
min: 1.0 | average: 1.93 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 2.0 | max: 2.0