Path	Lines of Code
common/src/main/java/org/apache/celeborn/common/client/MasterClient.java	188
common/src/main/java/org/apache/celeborn/common/client/MasterNotLeaderException.java	49
common/src/main/java/org/apache/celeborn/common/meta/DiskFileInfo.java	121
common/src/main/java/org/apache/celeborn/common/meta/DiskStatus.java	28
common/src/main/java/org/apache/celeborn/common/meta/FileInfo.java	76
common/src/main/java/org/apache/celeborn/common/meta/FileMeta.java	2
common/src/main/java/org/apache/celeborn/common/meta/MapFileMeta.java	123
common/src/main/java/org/apache/celeborn/common/meta/MemoryFileInfo.java	56
common/src/main/java/org/apache/celeborn/common/meta/ReduceFileMeta.java	59
common/src/main/java/org/apache/celeborn/common/meta/WorkerEventInfo.java	48
common/src/main/java/org/apache/celeborn/common/meta/WorkerStatus.java	47
common/src/main/java/org/apache/celeborn/common/network/TransportContext.java	201
common/src/main/java/org/apache/celeborn/common/network/buffer/ChunkBuffers.java	32
common/src/main/java/org/apache/celeborn/common/network/buffer/FileChunkBuffers.java	19
common/src/main/java/org/apache/celeborn/common/network/buffer/FileSegmentManagedBuffer.java	125
common/src/main/java/org/apache/celeborn/common/network/buffer/ManagedBuffer.java	13
common/src/main/java/org/apache/celeborn/common/network/buffer/MemoryChunkBuffers.java	18
common/src/main/java/org/apache/celeborn/common/network/buffer/NettyManagedBuffer.java	58
common/src/main/java/org/apache/celeborn/common/network/buffer/NioManagedBuffer.java	48
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	320
common/src/main/java/org/apache/celeborn/common/network/client/TransportClientBootstrap.java	4
common/src/main/java/org/apache/celeborn/common/network/client/TransportClientFactory.java	297
common/src/main/java/org/apache/celeborn/common/network/client/TransportResponseHandler.java	397
common/src/main/java/org/apache/celeborn/common/network/protocol/BacklogAnnouncement.java	39
common/src/main/java/org/apache/celeborn/common/network/protocol/BufferStreamEnd.java	32
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchFailure.java	51
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchRequest.java	44
common/src/main/java/org/apache/celeborn/common/network/protocol/ChunkFetchSuccess.java	62
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/EncryptedMessageWithHeader.java	100
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	195
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	56
common/src/main/java/org/apache/celeborn/common/network/protocol/MessageWithHeader.java	146
common/src/main/java/org/apache/celeborn/common/network/protocol/OneWayMessage.java	54
common/src/main/java/org/apache/celeborn/common/network/protocol/OpenStream.java	78
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	84
common/src/main/java/org/apache/celeborn/common/network/protocol/PushDataHandShake.java	89
common/src/main/java/org/apache/celeborn/common/network/protocol/PushMergedData.java	98
common/src/main/java/org/apache/celeborn/common/network/protocol/ReadAddCredit.java	51
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	68
common/src/main/java/org/apache/celeborn/common/network/protocol/RegionStart.java	90
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	50
common/src/main/java/org/apache/celeborn/common/network/protocol/RpcRequest.java	59
common/src/main/java/org/apache/celeborn/common/network/protocol/RpcResponse.java	62
common/src/main/java/org/apache/celeborn/common/network/protocol/SerdeVersion.java	12
common/src/main/java/org/apache/celeborn/common/network/protocol/SslMessageEncoder.java	61
common/src/main/java/org/apache/celeborn/common/network/protocol/StreamChunkSlice.java	78
common/src/main/java/org/apache/celeborn/common/network/protocol/StreamHandle.java	49
common/src/main/java/org/apache/celeborn/common/network/protocol/SubPartitionReadData.java	48
common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessage.java	128
common/src/main/java/org/apache/celeborn/common/network/protocol/TransportMessagesHelper.java	22
common/src/main/java/org/apache/celeborn/common/network/protocol/TransportableError.java	49
common/src/main/java/org/apache/celeborn/common/network/sasl/CelebornSaslClient.java	105
common/src/main/java/org/apache/celeborn/common/network/sasl/CelebornSaslServer.java	105
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslClientBootstrap.java	73
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslCredentials.java	16
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslRpcHandler.java	88
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslServerBootstrap.java	17
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslTimeoutException.java	12
common/src/main/java/org/apache/celeborn/common/network/sasl/SaslUtils.java	41
common/src/main/java/org/apache/celeborn/common/network/sasl/SecretRegistry.java	7
common/src/main/java/org/apache/celeborn/common/network/sasl/SecretRegistryImpl.java	29
common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslClientFactory.java	70
common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslProvider.java	19
common/src/main/java/org/apache/celeborn/common/network/sasl/anonymous/AnonymousSaslServerFactory.java	64
common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationClientBootstrap.java	213
common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationInfo.java	17
common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationRpcHandler.java	218
common/src/main/java/org/apache/celeborn/common/network/sasl/registration/RegistrationServerBootstrap.java	18
common/src/main/java/org/apache/celeborn/common/network/server/AbstractAuthRpcHandler.java	49
common/src/main/java/org/apache/celeborn/common/network/server/BaseMessageHandler.java	25
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	148
common/src/main/java/org/apache/celeborn/common/network/server/TransportRequestHandler.java	145
common/src/main/java/org/apache/celeborn/common/network/server/TransportServer.java	136
common/src/main/java/org/apache/celeborn/common/network/server/TransportServerBootstrap.java	5
common/src/main/java/org/apache/celeborn/common/network/ssl/ReloadingX509TrustManager.java	160
common/src/main/java/org/apache/celeborn/common/network/ssl/SSLFactory.java	334
common/src/main/java/org/apache/celeborn/common/network/ssl/SSLUtils.java	58
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/ConflictAvoidEventExecutorChooserFactory.java	28
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/NettyLogger.java	48
common/src/main/java/org/apache/celeborn/common/network/util/NettyMemoryMetrics.java	158
common/src/main/java/org/apache/celeborn/common/network/util/NettyUtils.java	174
common/src/main/java/org/apache/celeborn/common/network/util/TransportConf.java	148
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/FallbackPolicy.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	16
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	243
common/src/main/java/org/apache/celeborn/common/protocol/TransportModuleConstants.java	13
common/src/main/java/org/apache/celeborn/common/protocol/message/StatusCode.java	84
common/src/main/java/org/apache/celeborn/common/read/FetchRequestInfo.java	15
common/src/main/java/org/apache/celeborn/common/unsafe/Platform.java	238
common/src/main/java/org/apache/celeborn/common/util/CollectionUtils.java	17
common/src/main/java/org/apache/celeborn/common/util/ExceptionMaker.java	5
common/src/main/java/org/apache/celeborn/common/util/ExceptionUtils.java	50
common/src/main/java/org/apache/celeborn/common/util/FileChannelUtils.java	14
common/src/main/java/org/apache/celeborn/common/util/JavaUtils.java	351
common/src/main/java/org/apache/celeborn/common/util/ShuffleBlockInfoUtils.java	128
common/src/main/java/org/apache/celeborn/common/util/ShutdownHookManager.java	194
common/src/main/java/org/apache/celeborn/common/util/WorkerStatusUtils.java	22
common/src/main/java/org/apache/celeborn/common/write/DataBatches.java	46
common/src/main/java/org/apache/celeborn/common/write/InFlightRequestTracker.java	159
common/src/main/java/org/apache/celeborn/common/write/PushFailedBatch.java	53
common/src/main/java/org/apache/celeborn/common/write/PushRequestInfo.java	15
common/src/main/java/org/apache/celeborn/common/write/PushState.java	68
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	784
common/src/main/scala/org/apache/celeborn/common/CelebornConf.scala	5367
common/src/main/scala/org/apache/celeborn/common/authentication/AnonymousAuthenticationProviderImpl.scala	12
common/src/main/scala/org/apache/celeborn/common/authentication/Credential.scala	12
common/src/main/scala/org/apache/celeborn/common/authentication/HttpAuthSchemes.scala	5
common/src/main/scala/org/apache/celeborn/common/client/MasterEndpointResolver.scala	27
common/src/main/scala/org/apache/celeborn/common/client/StaticMasterEndpointResolver.scala	26
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	9
common/src/main/scala/org/apache/celeborn/common/identity/HadoopBasedIdentityProvider.scala	10
common/src/main/scala/org/apache/celeborn/common/identity/IdentityProvider.scala	16
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	250
common/src/main/scala/org/apache/celeborn/common/internal/config/ConfigEntry.scala	196
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/ApplicationMeta.scala	2
common/src/main/scala/org/apache/celeborn/common/meta/DeviceInfo.scala	265
common/src/main/scala/org/apache/celeborn/common/meta/ShufflePartitionLocationInfo.scala	98
common/src/main/scala/org/apache/celeborn/common/meta/TimeWindow.scala	34
common/src/main/scala/org/apache/celeborn/common/meta/WorkerInfo.scala	279
common/src/main/scala/org/apache/celeborn/common/meta/WorkerPartitionLocationInfo.scala	161
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/MetricsUtils.scala	13
common/src/main/scala/org/apache/celeborn/common/metrics/ResettableSlidingWindowReservoir.scala	37
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/Sink.scala	6
common/src/main/scala/org/apache/celeborn/common/metrics/source/AbstractSource.scala	619
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	69
common/src/main/scala/org/apache/celeborn/common/metrics/source/ResourceConsumptionSource.scala	13
common/src/main/scala/org/apache/celeborn/common/metrics/source/Role.scala	6
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/metrics/source/ThreadPoolSource.scala	151
common/src/main/scala/org/apache/celeborn/common/network/CelebornRackResolver.scala	122
common/src/main/scala/org/apache/celeborn/common/protocol/message/ControlMessages.scala	1212
common/src/main/scala/org/apache/celeborn/common/quota/ResourceConsumption.scala	73
common/src/main/scala/org/apache/celeborn/common/quota/StorageQuota.scala	20
common/src/main/scala/org/apache/celeborn/common/quota/UserTrafficQuota.scala	4
common/src/main/scala/org/apache/celeborn/common/quota/WorkerTrafficQuota.scala	6
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	53
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointAddress.scala	23
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointNotFoundException.scala	4
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEndpointRef.scala	55
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnv.scala	154
common/src/main/scala/org/apache/celeborn/common/rpc/RpcEnvStoppedException.scala	3
common/src/main/scala/org/apache/celeborn/common/rpc/RpcMetricsTracker.scala	128
common/src/main/scala/org/apache/celeborn/common/rpc/RpcSecurityContext.scala	96
common/src/main/scala/org/apache/celeborn/common/rpc/RpcSource.scala	12
common/src/main/scala/org/apache/celeborn/common/rpc/RpcTimeout.scala	49
common/src/main/scala/org/apache/celeborn/common/rpc/netty/Dispatcher.scala	177
common/src/main/scala/org/apache/celeborn/common/rpc/netty/Inbox.scala	285
common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcCallContext.scala	34
common/src/main/scala/org/apache/celeborn/common/rpc/netty/NettyRpcEnv.scala	509
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	132
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/tags/WorkerTagsMeta.scala	12
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	113
common/src/main/scala/org/apache/celeborn/common/util/DiskUtils.scala	21
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/KeyLock.scala	33
common/src/main/scala/org/apache/celeborn/common/util/NextIterator.scala	34
common/src/main/scala/org/apache/celeborn/common/util/PbSerDeUtils.scala	643
common/src/main/scala/org/apache/celeborn/common/util/SignalUtils.scala	62
common/src/main/scala/org/apache/celeborn/common/util/ThreadUtils.scala	298
common/src/main/scala/org/apache/celeborn/common/util/Utils.scala	990