Path	Lines of Code
common/src/main/java/org/apache/celeborn/common/client/MasterClient.java	170
common/src/main/java/org/apache/celeborn/common/client/MasterNotLeaderException.java	21
common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java	28
common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java	177
common/src/main/java/org/apache/celeborn/common/meta/FileManagedBuffers.java	36
common/src/main/java/org/apache/celeborn/common/network/TransportContext.java	115
common/src/main/java/org/apache/celeborn/common/network/buffer/FileSegmentManagedBuffer.java	119
common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java	12
common/src/main/java/org/apache/celeborn/common/network/buffer/NettyManagedBuffer.java	51
common/src/main/java/org/apache/celeborn/common/network/buffer/NioManagedBuffer.java	41
common/src/main/java/org/apache/celeborn/common/network/client/ChunkFetchFailureException.java	10
common/src/main/java/org/apache/celeborn/common/network/client/ChunkReceivedCallback.java	6
common/src/main/java/org/apache/celeborn/common/network/client/RpcResponseCallback.java	6
common/src/main/java/org/apache/celeborn/common/network/client/TransportClient.java	253
common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java	181
common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java	307
common/src/main/java/org/apache/celeborn/common/network/protocol/BacklogAnnouncement.java	35
common/src/main/java/org/apache/celeborn/common/network/protocol/BufferStreamEnd.java	27
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchFailure.java	48
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchRequest.java	40
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchSuccess.java	59
common/src/main/java/org/apache/celeborn/common/network/protocol/Encodable.java	6
common/src/main/java/org/apache/celeborn/common/network/protocol/Encoders.java	63
common/src/main/java/org/apache/celeborn/common/network/protocol/Heartbeat.java	20
common/src/main/java/org/apache/celeborn/common/network/protocol/Message.java	185
common/src/main/java/org/apache/celeborn/common/network/protocol/MessageDecoder.java	22
common/src/main/java/org/apache/celeborn/common/network/protocol/MessageEncoder.java	51
common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java	121
common/src/main/java/org/apache/celeborn/common/network/protocol/OneWayMessage.java	50
common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java	75
common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStreamWithCredit.java	60
common/src/main/java/org/apache/celeborn/common/network/protocol/PushData.java	82
common/src/main/java/org/apache/celeborn/common/network/protocol/PushDataHandShake.java	87
common/src/main/java/org/apache/celeborn/common/network/protocol/PushMergedData.java	96
common/src/main/java/org/apache/celeborn/common/network/protocol/ReadAddCredit.java	50
common/src/main/java/org/apache/celeborn/common/network/protocol/ReadData.java	41
common/src/main/java/org/apache/celeborn/common/network/protocol/RegionFinish.java	65
common/src/main/java/org/apache/celeborn/common/network/protocol/RegionStart.java	87
common/src/main/java/org/apache/celeborn/common/network/protocol/RequestMessage.java	10
common/src/main/java/org/apache/celeborn/common/network/protocol/ResponseMessage.java	13
common/src/main/java/org/apache/celeborn/common/network/protocol/RpcFailure.java	48
common/src/main/java/org/apache/celeborn/common/network/protocol/RpcRequest.java	54
common/src/main/java/org/apache/celeborn/common/network/protocol/RpcResponse.java	57
common/src/main/java/org/apache/celeborn/common/network/protocol/StreamChunkSlice.java	63
common/src/main/java/org/apache/celeborn/common/network/protocol/StreamHandle.java	47
common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java	65
common/src/main/java/org/apache/celeborn/common/network/protocol/TransportableError.java	44
common/src/main/java/org/apache/celeborn/common/network/server/BaseMessageHandler.java	14
common/src/main/java/org/apache/celeborn/common/network/server/MessageHandler.java	8
common/src/main/java/org/apache/celeborn/common/network/server/TransportChannelHandler.java	141
common/src/main/java/org/apache/celeborn/common/network/server/TransportRequestHandler.java	73
common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java	118
common/src/main/java/org/apache/celeborn/common/network/util/AbstractFileRegion.java	29
common/src/main/java/org/apache/celeborn/common/network/util/ByteUnit.java	53
common/src/main/java/org/apache/celeborn/common/network/util/ConfigProvider.java	26
common/src/main/java/org/apache/celeborn/common/network/util/FrameDecoder.java	5
common/src/main/java/org/apache/celeborn/common/network/util/IOMode.java	5
common/src/main/java/org/apache/celeborn/common/network/util/LimitedInputStream.java	76
common/src/main/java/org/apache/celeborn/common/network/util/NettyMemoryMetrics.java	118
common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java	123
common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java	76
common/src/main/java/org/apache/celeborn/common/network/util/TransportFrameDecoder.java	126
common/src/main/java/org/apache/celeborn/common/protocol/CompressionCodec.java	6
common/src/main/java/org/apache/celeborn/common/protocol/PartitionLocation.java	271
common/src/main/java/org/apache/celeborn/common/protocol/PartitionSplitMode.java	20
common/src/main/java/org/apache/celeborn/common/protocol/PartitionType.java	13
common/src/main/java/org/apache/celeborn/common/protocol/ReviveRequest.java	29
common/src/main/java/org/apache/celeborn/common/protocol/RpcNameConstants.java	9
common/src/main/java/org/apache/celeborn/common/protocol/ShuffleMode.java	5
common/src/main/java/org/apache/celeborn/common/protocol/SlotsAssignPolicy.java	5
common/src/main/java/org/apache/celeborn/common/protocol/StorageInfo.java	110
common/src/main/java/org/apache/celeborn/common/protocol/TransportModuleConstants.java	8
common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java	59
common/src/main/java/org/apache/celeborn/common/read/FetchRequestInfo.java	15
common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java	235
common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java	38
common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java	322
common/src/main/java/org/apache/celeborn/common/util/ShuffleBlockInfoUtils.java	64
common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java	194
common/src/main/java/org/apache/celeborn/common/write/DataBatches.java	46
common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java	140
common/src/main/java/org/apache/celeborn/common/write/PushRequestInfo.java	15
common/src/main/java/org/apache/celeborn/common/write/PushState.java	55
common/src/main/java/org/apache/celeborn/common/write/PushStrategy.java	26
common/src/main/java/org/apache/celeborn/common/write/SimplePushStrategy.java	26
common/src/main/java/org/apache/celeborn/common/write/SlowStartPushStrategy.java	118
common/src/main/java/org/apache/celeborn/reflect/DynClasses.java	51
common/src/main/java/org/apache/celeborn/reflect/DynConstructors.java	233
common/src/main/java/org/apache/celeborn/reflect/DynFields.java	225
common/src/main/java/org/apache/celeborn/reflect/DynMethods.java	262
common/src/main/proto/TransportMessages.proto	407
common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala	3090
common/src/main/scala/org/apache/celeborn/common/exception/AlreadyClosedException.scala	6
common/src/main/scala/org/apache/celeborn/common/exception/CelebornException.scala	5
common/src/main/scala/org/apache/celeborn/common/exception/CelebornIOException.scala	10
common/src/main/scala/org/apache/celeborn/common/exception/CelebornRuntimeException.scala	5
common/src/main/scala/org/apache/celeborn/common/exception/DriverChangedException.scala	5
common/src/main/scala/org/apache/celeborn/common/exception/FileCorruptedException.scala	6
common/src/main/scala/org/apache/celeborn/common/exception/PartitionUnRetryAbleException.scala	6
common/src/main/scala/org/apache/celeborn/common/identity/DefaultIdentityProvider.scala	10
common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala	9
common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala	27
common/src/main/scala/org/apache/celeborn/common/identity/UserIdentifier.scala	30
common/src/main/scala/org/apache/celeborn/common/internal/Logging.scala	51
common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigBuilder.scala	240
common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala	185
common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigProvider.scala	24
common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigReader.scala	55
common/src/main/scala/org/apache/celeborn/common/meta/AppDiskUsageMetric.scala	142
common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala	225
common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala	84
common/src/main/scala/org/apache/celeborn/common/meta/TimeWindow.scala	34
common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala	219
common/src/main/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfo.scala	138
common/src/main/scala/org/apache/celeborn/common/metrics/CelebornHistogram.scala	3
common/src/main/scala/org/apache/celeborn/common/metrics/CelebornTimer.scala	3
common/src/main/scala/org/apache/celeborn/common/metrics/MetricLabels.scala	10
common/src/main/scala/org/apache/celeborn/common/metrics/MetricsConfig.scala	71
common/src/main/scala/org/apache/celeborn/common/metrics/MetricsSystem.scala	134
common/src/main/scala/org/apache/celeborn/common/metrics/ResettableSlidingWindowReservoir.scala	35
common/src/main/scala/org/apache/celeborn/common/metrics/sink/CsvSink.scala	41
common/src/main/scala/org/apache/celeborn/common/metrics/sink/GraphiteSink.scala	55
common/src/main/scala/org/apache/celeborn/common/metrics/sink/PrometheusServlet.scala	35
common/src/main/scala/org/apache/celeborn/common/metrics/sink/PrometheusSink.scala	8
common/src/main/scala/org/apache/celeborn/common/metrics/sink/Sink.scala	6
common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala	339
common/src/main/scala/org/apache/celeborn/common/metrics/source/JVMCPUSource.scala	27
common/src/main/scala/org/apache/celeborn/common/metrics/source/JVMSource.scala	20
common/src/main/scala/org/apache/celeborn/common/metrics/source/ResourceConsumptionSource.scala	8
common/src/main/scala/org/apache/celeborn/common/metrics/source/Source.scala	12
common/src/main/scala/org/apache/celeborn/common/metrics/source/SystemMiscSource.scala	27
common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala	842
common/src/main/scala/org/apache/celeborn/common/quota/DefaultQuotaManager.scala	38
common/src/main/scala/org/apache/celeborn/common/quota/Quota.scala	81
common/src/main/scala/org/apache/celeborn/common/quota/QuotaManager.scala	35
common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala	21
common/src/main/scala/org/apache/celeborn/common/rpc/RpcAddress.scala	21
common/src/main/scala/org/apache/celeborn/common/rpc/RpcCallContext.scala	6
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpoint.scala	39
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointAddress.scala	24
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointNotFoundException.scala	4
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala	19
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnv.scala	60
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnvStoppedException.scala	3
common/src/main/scala/org/apache/celeborn/common/rpc/RpcTimeout.scala	45
common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala	164
common/src/main/scala/org/apache/celeborn/common/rpc/netty/Inbox.scala	156
common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcCallContext.scala	33
common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala	475
common/src/main/scala/org/apache/celeborn/common/rpc/netty/Outbox.scala	186
common/src/main/scala/org/apache/celeborn/common/rpc/netty/RpcEndpointVerifier.scala	12
common/src/main/scala/org/apache/celeborn/common/serializer/JavaSerializer.scala	105
common/src/main/scala/org/apache/celeborn/common/serializer/SerializationDebugger.scala	266
common/src/main/scala/org/apache/celeborn/common/serializer/Serializer.scala	70
common/src/main/scala/org/apache/celeborn/common/util/ByteBufferInputStream.scala	44
common/src/main/scala/org/apache/celeborn/common/util/ByteBufferOutputStream.scala	30
common/src/main/scala/org/apache/celeborn/common/util/CelebornExitKind.scala	6
common/src/main/scala/org/apache/celeborn/common/util/CelebornHadoopUtils.scala	49
common/src/main/scala/org/apache/celeborn/common/util/CollectionUtils.java	17
common/src/main/scala/org/apache/celeborn/common/util/FunctionConverter.scala	16
common/src/main/scala/org/apache/celeborn/common/util/IntParam.scala	10
common/src/main/scala/org/apache/celeborn/common/util/NextIterator.scala	34
common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala	350
common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala	168
common/src/main/scala/org/apache/celeborn/common/util/Utils.scala	882