uber / uForwarder
File Size

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

Intro
Learn more...
File Size Overall
8% | 2% | 37% | 21% | 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
java9% | 2% | 36% | 21% | 30%
html0% | 0% | 51% | 48% | 0%
proto0% | 0% | 35% | 15% | 48%
yaml0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
uforwarder-core9% | 0% | 30% | 28% | 31%
uforwarder9% | 4% | 40% | 18% | 26%
instrumentation0% | 0% | 87% | 0% | 12%
idl0% | 0% | 35% | 15% | 48%
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
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24
AbstractRpcUriRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 453 10
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 417 11
proto
job.proto
in idl/src/main/proto/data/kafka/data-transfer
 410 -
StateWorking.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 409 4
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 352 27
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 337 14
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
 323 25
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24
UforwarderContainerIntegrationTests.java
in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container
 264 8
KafkaPartitionExpansionWatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 264 5
RebalancerCommon.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 259 10
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
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29
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
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 -
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51
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
 222 19
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16
AsyncInflightLimiterAdapter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 212 18
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
TracedConsumerRecord.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common
 179 9
proto
job_group.proto
in idl/src/main/proto/data/kafka/data-transfer
 178 -
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13
UForwarderControllerFactory.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller
 169 8
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
StoreAutoConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 167 10
DispatcherMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher
 166 7
KafkaDispatcher.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 165 6
Rebalancer.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 162 5
Files With Most Units (Top 50)
File# lines# units
StructuredLogging.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 224 51
AutoScalarConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 146 33
ProcessorImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 1077 31
AbstractKafkaFetcherThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 1095 31
GrpcManagedChannelPool.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 248 29
SimpleOutboundMessageLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 433 27
ProcessorMessage.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 352 27
AbstractAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 323 25
RebalancerConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 102 24
UnprocessedMessageManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 289 24
RpcJobColocatingRebalancer.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer
 539 24
JobUtils.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 222 19
Instrumentation.java
in instrumentation/src/main/java/com/uber/data/kafka/instrumentation
 402 19
ProcessorConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 68 18
AsyncInflightLimiterAdapter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 212 18
KafkaPipelineStateManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 359 18
MessageStub.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 236 17
StructuredTags.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 73 17
CoreInfra.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 101 17
GrpcRequest.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 212 16
KafkaDispatcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka
 89 16
TTLDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 241 16
PipelineImpl.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker
 146 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
StubManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 145 15
MessageAckStatusManager.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 222 15
KafkaFetcherConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka
 120 15
GrpcDispatcher.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc
 337 14
PipelineManager.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines
 396 14
AutoScalar.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 200 14
ZKStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 233 14
LinkedAckTrackingQueue.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 208 13
AdminClient.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common
 75 13
ScaleState.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 178 13
RebalancingJobGroup.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer
 134 13
BufferedWriteDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 130 13
LoggingAndMetricsStoreDecorator.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 98 13
ShutdownableThread.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils
 96 12
GrpcControllerConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller
 48 12
ScaleWindow.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar
 102 12
StoreConfiguration.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config
 49 12
MetadataAdapter.java
in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc
 80 11
StructuredLogging.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common
 49 11
KafkaAdminClientConfiguration.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config
 81 11
LongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 113 11
BootstrapLongFixedInflightLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter
 106 11
WindowedTokenLimiter.java
in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor
 71 11
UforwarderIntegrationTests.java
in uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy
 417 11
LocalStore.java
in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage
 87 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
masterJobs.html
in uforwarder-core/src/main/resources
 234 - 5
masters.html
in uforwarder-core/src/main/resources
 107 - 5
workerJobStatus.html
in uforwarder-core/src/main/resources
 197 - 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): 291 points

uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 15 commits (all time) y: 1095 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/DelayProcessManager.java x: 6 commits (all time) y: 38 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java x: 5 commits (all time) y: 158 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 10 commits (all time) y: 86 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java x: 10 commits (all time) y: 89 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 10 commits (all time) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 10 commits (all time) y: 110 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java x: 14 commits (all time) y: 123 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 5 commits (all time) y: 254 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java x: 5 commits (all time) y: 102 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 17 commits (all time) y: 259 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 20 commits (all time) y: 539 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java x: 10 commits (all time) y: 68 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/DynamicConfiguration.java x: 3 commits (all time) y: 43 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/PodIsolationStatus.java x: 1 commits (all time) y: 5 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/JobPodPlacementProvider.java x: 2 commits (all time) y: 38 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 9 commits (all time) y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 14 commits (all time) y: 169 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 4 commits (all time) y: 224 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java x: 1 commits (all time) y: 101 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 9 commits (all time) y: 54 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 7 commits (all time) y: 417 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java x: 4 commits (all time) y: 51 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/ConsoleMatcher.java x: 1 commits (all time) y: 63 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarderAppType.java x: 3 commits (all time) y: 6 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/ApplicationReadyListener.java x: 1 commits (all time) y: 37 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java x: 13 commits (all time) y: 143 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilter.java x: 1 commits (all time) y: 39 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java x: 2 commits (all time) y: 11 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java x: 2 commits (all time) y: 22 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 12 commits (all time) y: 1077 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 5 commits (all time) y: 45 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactory.java x: 3 commits (all time) y: 46 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/SerializerType.java x: 3 commits (all time) y: 29 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 3 commits (all time) y: 167 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TypeRegistryAutoConfiguration.java x: 1 commits (all time) y: 13 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JobUtils.java x: 5 commits (all time) y: 222 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 5 commits (all time) y: 162 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 9 commits (all time) y: 337 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 6 commits (all time) y: 264 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 11 commits (all time) y: 433 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java x: 5 commits (all time) y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java x: 7 commits (all time) y: 75 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java x: 5 commits (all time) y: 212 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/BootstrapLongFixedInflightLimiter.java x: 4 commits (all time) y: 106 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/InflightLimiter.java x: 5 commits (all time) y: 55 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 3 commits (all time) y: 113 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilter.java x: 3 commits (all time) y: 20 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChain.java x: 3 commits (all time) y: 62 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java x: 3 commits (all time) y: 100 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThread.java x: 3 commits (all time) y: 96 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 8 commits (all time) y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 5 commits (all time) y: 323 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/PodAwareRebalanceGroup.java x: 1 commits (all time) y: 33 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 4 commits (all time) y: 179 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 10 commits (all time) y: 120 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 8 commits (all time) y: 352 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 3 commits (all time) y: 200 lines of code idl/src/main/proto/data/kafka/data-transfer/job.proto x: 8 commits (all time) y: 410 lines of code idl/src/main/proto/data/kafka/data-transfer/job_group.proto x: 6 commits (all time) y: 178 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 8 commits (all time) y: 166 lines of code uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapter.java x: 4 commits (all time) y: 80 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java x: 4 commits (all time) y: 212 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/KafkaPartitionExpansionWatcher.java x: 7 commits (all time) y: 264 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/WorkersJson.java x: 5 commits (all time) y: 86 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 7 commits (all time) y: 96 lines of code uforwarder/src/main/resources/application-uforwarder-worker.yaml x: 6 commits (all time) y: 55 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/PodUtils.java x: 1 commits (all time) y: 19 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterManagementAutoConfiguration.java x: 1 commits (all time) y: 52 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/NodeUrlResolver.java x: 1 commits (all time) y: 9 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 6 commits (all time) y: 359 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherResponse.java x: 4 commits (all time) y: 42 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/CheckpointInfo.java x: 3 commits (all time) y: 52 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 7 commits (all time) y: 24 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 7 commits (all time) y: 73 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java x: 3 commits (all time) y: 69 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 5 commits (all time) y: 25 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/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/InflightMessageTracker.java x: 3 commits (all time) y: 60 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/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/processor/MessageStub.java x: 7 commits (all time) y: 236 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/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-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/controller/config/ZookeeperConfiguration.java x: 4 commits (all time) y: 19 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/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/UForwarderUtils.java x: 4 commits (all time) y: 52 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/ArrayAckTrackingQueue.java x: 4 commits (all time) y: 248 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 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/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 uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/KafkaServerMethodDefinition.java x: 2 commits (all time) y: 33 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/Placement.java x: 2 commits (all time) y: 18 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/DataTransferMaster.java x: 2 commits (all time) y: 4 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/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/TTLDecorator.java x: 2 commits (all time) y: 241 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java x: 2 commits (all time) y: 233 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/fetchers/kafka/ThroughputTracker.java x: 2 commits (all time) y: 66 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/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/WindowedAggregator.java x: 2 commits (all time) y: 85 lines of code
1095.0
lines of code
  min: 2.0
  average: 88.96
  25th percentile: 20.0
  median: 48.0
  75th percentile: 102.0
  max: 1095.0
0 20.0
commits (all time)
min: 1.0 | average: 3.38 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 4.0 | max: 20.0

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

uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/AbstractKafkaFetcherThread.java x: 5 contributors (all time) y: 1095 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/DelayProcessManager.java x: 1 contributors (all time) y: 38 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaDelayProcessManager.java x: 1 contributors (all time) y: 158 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherThread.java x: 4 contributors (all time) y: 86 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/DlqTopicKafkaFetcher.java x: 4 contributors (all time) y: 89 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/KafkaFetcherFactory.java x: 4 contributors (all time) y: 107 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/OriginalTopicKafkaFetcher.java x: 4 contributors (all time) y: 110 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/fetcher/RetryTopicKafkaFetcher.java x: 4 contributors (all time) y: 123 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager/JobManager.java x: 4 contributors (all time) y: 254 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/RebalancerConfiguration.java x: 4 contributors (all time) y: 102 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RebalancerCommon.java x: 5 contributors (all time) y: 259 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/RpcJobColocatingRebalancer.java x: 5 contributors (all time) y: 539 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config/ProcessorConfiguration.java x: 4 contributors (all time) y: 68 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/DynamicConfiguration.java x: 3 contributors (all time) y: 43 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/PodIsolationStatus.java x: 1 contributors (all time) y: 5 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common/StructuredLogging.java x: 5 contributors (all time) y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/UForwarderControllerFactory.java x: 5 contributors (all time) y: 169 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredLogging.java x: 4 contributors (all time) y: 224 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/JobGroupAndWorkerPodifier.java x: 1 contributors (all time) y: 101 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/NetworkUtils.java x: 4 contributors (all time) y: 54 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/UforwarderIntegrationTests.java x: 3 contributors (all time) y: 417 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/UForwarderStarter.java x: 3 contributors (all time) y: 51 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/ConsoleMatcher.java x: 1 contributors (all time) y: 63 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/UForwarderAppType.java x: 3 contributors (all time) y: 6 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/UForwarderWorkerFactory.java x: 5 contributors (all time) y: 143 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/CompositeFilter.java x: 1 contributors (all time) y: 39 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/Filter.java x: 1 contributors (all time) y: 11 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/filter/OriginalClusterFilter.java x: 1 contributors (all time) y: 22 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorImpl.java x: 5 contributors (all time) y: 1077 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorFactory.java x: 4 contributors (all time) y: 45 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/JsonSerializationFactory.java x: 3 contributors (all time) y: 46 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/SerializerType.java x: 3 contributors (all time) y: 29 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/StoreAutoConfiguration.java x: 3 contributors (all time) y: 167 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/TypeRegistryAutoConfiguration.java x: 1 contributors (all time) y: 13 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer/Rebalancer.java x: 4 contributors (all time) y: 162 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcDispatcher.java x: 5 contributors (all time) y: 337 lines of code uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container/UforwarderContainerIntegrationTests.java x: 4 contributors (all time) y: 264 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/SimpleOutboundMessageLimiter.java x: 4 contributors (all time) y: 433 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AbstractInflightLimiter.java x: 4 contributors (all time) y: 49 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AdaptiveInflightLimiter.java x: 4 contributors (all time) y: 75 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/AsyncInflightLimiterAdapter.java x: 2 contributors (all time) y: 212 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/LongFixedInflightLimiter.java x: 3 contributors (all time) y: 113 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilter.java x: 3 contributors (all time) y: 20 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcFilterChain.java x: 3 contributors (all time) y: 62 lines of code uforwarder/src/integrationTest/java/com/uber/data/kafka/consumerproxy/testutils/MockConsumerServiceStarter.java x: 3 contributors (all time) y: 100 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils/ShutdownableThread.java x: 3 contributors (all time) y: 96 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcManagedChannelPool.java x: 5 contributors (all time) y: 248 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/AbstractAckTrackingQueue.java x: 4 contributors (all time) y: 323 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer/PodAwareRebalanceGroup.java x: 1 contributors (all time) y: 33 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common/TracedConsumerRecord.java x: 4 contributors (all time) y: 179 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka/KafkaFetcherConfiguration.java x: 5 contributors (all time) y: 120 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/ProcessorMessage.java x: 4 contributors (all time) y: 352 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar/AutoScalar.java x: 3 contributors (all time) y: 200 lines of code idl/src/main/proto/data/kafka/data-transfer/job.proto x: 5 contributors (all time) y: 410 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/DispatcherMessage.java x: 5 contributors (all time) y: 166 lines of code uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc/MetadataAdapter.java x: 3 contributors (all time) y: 80 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc/GrpcRequest.java x: 4 contributors (all time) y: 212 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter/VegasAdaptiveInflightLimiter.java x: 3 contributors (all time) y: 54 lines of code uforwarder/src/main/resources/application-uforwarder-controller.yaml x: 5 contributors (all time) y: 96 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/PodUtils.java x: 1 contributors (all time) y: 19 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/management/MasterManagementAutoConfiguration.java x: 1 contributors (all time) y: 52 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines/KafkaPipelineStateManager.java x: 4 contributors (all time) y: 359 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredFields.java x: 4 contributors (all time) y: 24 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/StructuredTags.java x: 4 contributors (all time) y: 73 lines of code uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/HeadBlockingDetector.java x: 3 contributors (all time) y: 69 lines of code uforwarder-sample-consumer/src/main/java/com/uber/data/kafka/uforwarder/SampleConsumerHandler.java x: 3 contributors (all time) y: 25 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/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/InflightMessageTracker.java x: 2 contributors (all time) y: 60 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/config/GrpcDispatcherConfiguration.java x: 3 contributors (all time) y: 33 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/processor/MessageStub.java x: 3 contributors (all time) y: 236 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/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor/NestedPermit.java x: 2 contributors (all time) y: 30 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-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/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/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 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/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/offset_mapping.proto x: 2 contributors (all time) y: 72 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 uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/Placement.java x: 2 contributors (all time) y: 18 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/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/TTLDecorator.java x: 2 contributors (all time) y: 241 lines of code uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage/ZKStore.java x: 2 contributors (all time) y: 233 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/fetchers/kafka/ThroughputTracker.java x: 2 contributors (all time) y: 66 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/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/WindowedAggregator.java x: 2 contributors (all time) y: 85 lines of code
1095.0
lines of code
  min: 2.0
  average: 88.96
  25th percentile: 20.0
  median: 48.0
  75th percentile: 102.0
  max: 1095.0
0 5.0
contributors (all time)
min: 1.0 | average: 2.46 | 25th percentile: 2.0 | median: 2.0 | 75th percentile: 3.0 | max: 5.0

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

No data for "commits (30d)" vs. "lines of code".

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

No data for "contributors (30d)" vs. "lines of code".

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

No data for "commits (90d)" vs. "lines of code".

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

No data for "contributors (90d)" vs. "lines of code".