Path	Lines of Code
build/release/append_notice.py	27
build/sbt-launch-lib.bash	151
charts/celeborn/Chart.yaml	8
charts/celeborn/templates/_helpers.tpl	70
charts/celeborn/templates/configmap.yaml	102
charts/celeborn/templates/master-service.yaml	24
charts/celeborn/templates/master-statefulset.yaml	123
charts/celeborn/templates/prometheus-podmonitor.yaml	53
charts/celeborn/templates/worker-service.yaml	19
charts/celeborn/templates/worker-statefulset.yaml	129
charts/celeborn/values.yaml	110
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleEnvironment.java	132
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java	78
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java	145
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/FlinkResultPartitionInfo.java	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java	118
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleDescriptor.java	56
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java	445
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java	191
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java	176
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java	41
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java	261
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ResultPartitionAdapter.java	5
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResource.java	5
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceDescriptor.java	37
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java	159
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfo.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/Buffer.java	19
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferHeader.java	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java	254
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferRecycler.java	5
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/CreditListener.java	21
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/PartitionSortedBuffer.java	272
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java	32
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java	154
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java	59
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java	65
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java	101
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java	182
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java	51
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/CelebornBufferStream.java	154
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java	485
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java	80
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java	49
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/ThreadUtils.java	26
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/Utils.java	35
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	197
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	156
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	34
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	212
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	157
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	34
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	219
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	169
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	38
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/OpenByteArrayOutputStream.java	10
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/PackedRecordPointer.java	30
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java	80
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorter.java	103
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java	341
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/TaskInterruptedHelper.java	12
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java	316
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java	342
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java	202
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java	100
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala	32
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala	13
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala	94
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java	416
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java	359
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java	287
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java	132
client-spark/spark-3/src/main/java/org/apache/spark/sql/execution/columnar/CelebornColumnDictionary.java	36
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala	38
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala	13
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala	111
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornBatchBuilder.scala	28
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala	105
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala	299
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala	233
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala	485
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala	102
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala	271
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala	138
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala	18
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala	67
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala	48
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala	355
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala	46
client-spark/spark-3/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala	49
client/src/main/java/org/apache/celeborn/client/ReviveManager.java	92
client/src/main/java/org/apache/celeborn/client/ShuffleClient.java	103
client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java	1513
client/src/main/java/org/apache/celeborn/client/compress/Compressor.java	28
client/src/main/java/org/apache/celeborn/client/compress/Decompressor.java	35
client/src/main/java/org/apache/celeborn/client/compress/Lz4Compressor.java	55
client/src/main/java/org/apache/celeborn/client/compress/Lz4Decompressor.java	48
client/src/main/java/org/apache/celeborn/client/compress/Lz4Trait.java	14
client/src/main/java/org/apache/celeborn/client/compress/ZstdCompressor.java	62
client/src/main/java/org/apache/celeborn/client/compress/ZstdDecompressor.java	50
client/src/main/java/org/apache/celeborn/client/compress/ZstdTrait.java	13
client/src/main/java/org/apache/celeborn/client/listener/WorkerStatusListener.java	4
client/src/main/java/org/apache/celeborn/client/listener/WorkersStatus.java	11
client/src/main/java/org/apache/celeborn/client/read/CelebornInputStream.java	497
client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java	228
client/src/main/java/org/apache/celeborn/client/read/MetricsCallback.java	5
client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java	10
client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java	166
client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java	108
client/src/main/java/org/apache/celeborn/client/write/DataPusher.java	193
client/src/main/java/org/apache/celeborn/client/write/PushTask.java	27
client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala	77
client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala	267
client/src/main/scala/org/apache/celeborn/client/CommitManager.scala	265
client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala	884
client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala	124
client/src/main/scala/org/apache/celeborn/client/RequestLocationCallContext.scala	53
client/src/main/scala/org/apache/celeborn/client/ShuffleClientHelper.scala	45
client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala	188
client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala	386
client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala	172
client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala	236
codecov.yml	11
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
dev/merge_pr.py	406
master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java	411
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java	267
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java	44
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java	93
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java	98
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java	91
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java	257
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java	394
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java	213
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java	334
master/src/main/java/org/apache/ratis/statemachine/impl/SimpleStateMachineStorageUtil.java	13
master/src/main/proto/Resource.proto	146
master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala	783
master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala	57
master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala	21
master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterClusterInfo.scala	50
master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala	69
master/src/main/scala/org/apache/celeborn/service/deploy/master/network/CelebornRackResolver.scala	64
mkdocs.yml	75
project/CelebornBuild.scala	588
project/plugins.sbt	2
service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala	73
service/src/main/scala/org/apache/celeborn/server/common/Service.scala	20
service/src/main/scala/org/apache/celeborn/server/common/http/HttpRequestHandler.scala	73
service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala	64
service/src/main/scala/org/apache/celeborn/server/common/http/HttpServerInitializer.scala	13
toolkit/scripts/check.py	36
toolkit/scripts/genConfs.py	135
toolkit/scripts/genSkewData.scala	40
version.sbt	1
worker/src/main/java/org/apache/celeborn/service/deploy/worker/LevelDBProvider.java	110
worker/src/main/java/org/apache/celeborn/service/deploy/worker/ShuffleRecoverHelper.java	15
worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkingPartition.java	13
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java	53
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java	190
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java	87
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/BufferQueue.java	115
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/BufferRecycler.java	12
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ChannelsLimiter.java	114
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java	340
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java	87
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferListener.java	6
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferRequest.java	22
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/RecyclableBuffer.java	13
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java	119
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java	260
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileChannelUtils.java	14
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FileWriter.java	364
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/FlushNotifier.java	20
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartition.java	217
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapDataPartitionReader.java	380
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionFileWriter.java	246
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java	608
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ReducePartitionFileWriter.java	76
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/CommitInfo.scala	8
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Controller.scala	587
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala	319
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala	953
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala	595
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala	51
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala	83
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala	248
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceObserver.scala	8
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/FlushTask.scala	32
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala	163
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/ObservedDevice.scala	139
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala	713