uber / uForwarder File Size

Intro

File size measurements show the distribution of size of files.
Files are classified in four categories based on their size (lines of code): 1-100 (very small files), 101-200 (small files), 201-500 (medium size files), 501-1000 (long files), 1001+(very long files).
It is a good practice to keep files small. Long files may become "bloaters", code that have increased to such gargantuan proportions that they are hard to work with.

Learn more...

File Size Overall

There are 309 files with 27,490 lines of code.

2 very long files (2,210 lines of code)
1 long files (522 lines of code)
38 medium size files (11,023 lines of codeclsfd_ftr_w_mp_ins)
39 small files (5,268 lines of code)
229 very small files (8,467 lines of code)

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

File Size per Logical Decomposition

primary

1001+

501-1000

201-500

101-200

1-100

Longest Files (Top 50)

File	# lines	# units
ProcessorImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	1108	31
AbstractKafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	1102	31
RpcJobColocatingRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	522	24
SimpleOutboundMessageLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	483	33
AbstractRpcUriRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	470	12
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	412	-
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
KafkaPipelineStateManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	392	20
PipelineManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	389	14
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	348	14
ControllerWorkerService.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc	327	9
ControllerAdminService.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rpc	321	9
AbstractAckTrackingQueue.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	318	25
ScaleState.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	303	21
UnprocessedMessageManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	289	24
AutoScalar.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	278	18
RebalancerCommon.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	265	10
UforwarderContainerIntegrationTests.java in uforwarder-container/src/integrationTest/java/com/uber/data/kafka/consumerproxy/container	265	8
TTLDecorator.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	259	16
BlockingQueueStubManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	258	15
KafkaPartitionExpansionWatcher.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	253	4
JobManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/manager	249	8
GrpcManagedChannelPool.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	248	29
AutoScalarConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	240	53
BatchJobCreator.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/creator	238	9
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	-
workerJobs.html in uforwarder-core/src/main/resources	228	-
DispatcherImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	227	8
ZKStore.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	227	14
JobUtils.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	222	19
MessageAckStatusManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	217	15
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
StructuredLogging.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	210	50
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
proto job_group.proto in idl/src/main/proto/data/kafka/data-transfer	201	-
workerJobStatus.html in uforwarder-core/src/main/resources	197	-
UForwarderControllerFactory.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller	186	8
LeaderSelector.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/coordinator	184	10
TracedConsumerRecord.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/common	179	9
BatchRpcUriRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	168	4
DispatcherMessage.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	166	7
StoreAutoConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	166	10
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	158	5

Files With Most Units (Top 50)

File	# lines	# units
AutoScalarConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	240	53
StructuredLogging.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	210	50
SimpleOutboundMessageLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	483	33
ProcessorImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	1108	31
AbstractKafkaFetcherThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/fetchers/kafka	1102	31
GrpcManagedChannelPool.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	248	29
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	318	25
RpcJobColocatingRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	522	24
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	102	24
CoreInfra.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	125	21
ScaleState.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	303	21
KafkaPipelineStateManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	392	20
Instrumentation.java in instrumentation/src/main/java/com/uber/data/kafka/instrumentation	402	19
JobUtils.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	222	19
AsyncInflightLimiterAdapter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/limiter	212	18
ProcessorConfiguration.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/config	68	18
StructuredTags.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common	77	18
AutoScalar.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	278	18
MessageStub.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	236	17
LatencyTracker.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher	140	17
GrpcRequest.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/dispatcher/grpc	212	16
TTLDecorator.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	259	16
KafkaDispatcherConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/dispatchers/kafka	89	16
PipelineImpl.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker	147	15
MessageAckStatusManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	217	15
StubManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	143	15
BlockingQueueStubManager.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	258	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	348	14
ZKStore.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/storage	227	14
RebalancingJobGroup.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/rebalancer	145	14
PipelineManager.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/pipelines	389	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	72	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
ScaleWindow.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/autoscalar	119	13
AbstractRpcUriRebalancer.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/controller/rebalancer	470	12
ShutdownableThread.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/common/utils	96	12
StoreConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/controller/config	49	12
GrpcControllerConfiguration.java in uforwarder-core/src/main/java/com/uber/data/kafka/datatransfer/worker/controller	48	12
MetadataAdapter.java in uforwarder-client/src/main/java/com/uber/data/kafka/consumerproxy/client/grpc	80	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	417	11
StructuredLogging.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/common	49	11
WindowedTokenLimiter.java in uforwarder/src/main/java/com/uber/data/kafka/consumerproxy/worker/processor	71	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

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
workerJobs.html in uforwarder-core/src/main/resources	228	-	5
masterJobs.html in uforwarder-core/src/main/resources	234	-	5
proto group_sub.proto in idl/src/main/proto/data/kafka/messaging-consumer	24	-	1