Path	Lines of Code
build/release/append_notice.py	27
build/release/asf-settings.xml	17
build/sbt-launch-lib.bash	151
charts/celeborn/Chart.yaml	13
charts/celeborn/ci/values.yaml	99
charts/celeborn/files/conf/log4j2.xml	57
charts/celeborn/templates/_helpers.tpl	106
charts/celeborn/templates/configmap.yaml	46
charts/celeborn/templates/master/_helpers.tpl	81
charts/celeborn/templates/master/podmonitor.yaml	37
charts/celeborn/templates/master/priorityclass.yaml	23
charts/celeborn/templates/master/service.yaml	63
charts/celeborn/templates/master/statefulset.yaml	151
charts/celeborn/templates/role.yaml	23
charts/celeborn/templates/rolebinding.yaml	29
charts/celeborn/templates/serviceaccount.yaml	22
charts/celeborn/templates/worker/_helpers.tpl	103
charts/celeborn/templates/worker/podmonitor.yaml	37
charts/celeborn/templates/worker/priorityclass.yaml	23
charts/celeborn/templates/worker/service.yaml	28
charts/celeborn/templates/worker/statefulset.yaml	154
charts/celeborn/values.yaml	158
cli/src/main/scala/org/apache/celeborn/cli/CelebornCli.scala	28
cli/src/main/scala/org/apache/celeborn/cli/common/CliLogging.scala	16
cli/src/main/scala/org/apache/celeborn/cli/common/CliVersionProvider.scala	27
cli/src/main/scala/org/apache/celeborn/cli/common/CommonOptions.scala	49
cli/src/main/scala/org/apache/celeborn/cli/config/CliConfigManager.scala	59
cli/src/main/scala/org/apache/celeborn/cli/master/MasterOptions.scala	80
cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommand.scala	68
cli/src/main/scala/org/apache/celeborn/cli/master/MasterSubcommandImpl.scala	208
cli/src/main/scala/org/apache/celeborn/cli/master/ReviseLostShuffleOptions.scala	8
cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerOptions.scala	43
cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerSubcommand.scala	46
cli/src/main/scala/org/apache/celeborn/cli/worker/WorkerSubcommandImpl.scala	46
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java	132
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java	71
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartition.java	175
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java	133
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java	82
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/FlinkResultPartitionInfo.java	51
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java	131
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/RemoteShuffleEnvironment.java	197
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java	455
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java	280
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java	226
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/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	46
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java	291
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/BufferWithSubpartition.java	17
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/DataBuffer.java	20
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java	44
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/ReceivedNoHeaderBufferPacker.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBasedDataBuffer.java	273
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java	156
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/CelebornBufferStream.java	288
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java	618
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ForceFallbackPolicy.java	25
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/QuotaFallbackPolicy.java	29
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicy.java	10
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyFactory.java	21
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyRunner.java	31
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/WorkersAvailableFallbackPolicy.java	27
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RemoteShuffleMetricFactory.java	41
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RequestedMemoryUsageMetric.java	18
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/netty/NettyShuffleEnvironmentWrapper.java	63
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java	40
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java	73
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java	136
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java	228
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/protocol/SubPartitionReadData.java	49
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java	105
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java	53
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/Utils.java	35
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	134
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	43
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	134
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	137
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	33
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	64
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	37
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java	123
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java	269
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java	464
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java	83
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java	172
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java	386
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java	41
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	33
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	64
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	37
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java	123
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java	269
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java	464
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java	90
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java	172
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java	386
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java	41
client-mr/mr/src/main/java/org/apache/celeborn/mapreduce/v2/app/MRAppMasterWithCeleborn.java	177
client-mr/mr/src/main/java/org/apache/celeborn/util/HadoopUtils.java	22
client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornMapOutputCollector.java	101
client-mr/mr/src/main/java/org/apache/hadoop/mapred/CelebornSortBasedPusher.java	281
client-mr/mr/src/main/java/org/apache/hadoop/mapreduce/task/reduce/CelebornShuffleConsumer.java	149
client-mr/mr/src/main/java/org/apache/hadoop/mapreduce/task/reduce/CelebornShuffleFetcher.java	183
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ExecutorShuffleIdTracker.java	23
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ForceFallbackPolicy.java	25
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/QuotaFallbackPolicy.java	29
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SendBufferPool.java	83
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleFallbackPolicy.java	10
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleFallbackPolicyFactory.java	23
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShuffleInMemorySorter.java	102
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/ShufflePartitionsFallbackPolicy.java	27
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedPusher.java	399
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/SparkCommonUtils.java	56
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/TaskInterruptedHelper.java	12
client-spark/common/src/main/java/org/apache/spark/shuffle/celeborn/WorkersAvailableFallbackPolicy.java	27
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java	333
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java	298
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java	243
client-spark/spark-2/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java	402
client-spark/spark-2/src/main/scala/org/apache/spark/celeborn/ExceptionMakerHelper.scala	21
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala	39
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala	34
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala	219
client-spark/spark-2/src/main/scala/org/apache/spark/shuffle/celeborn/ShuffleFetchFailureReportTaskCleanListener.scala	9
client-spark/spark-3-columnar-common/src/main/java/org/apache/spark/shuffle/celeborn/CustomShuffleDependencyUtils.java	25
client-spark/spark-3-columnar-common/src/main/java/org/apache/spark/sql/execution/columnar/CelebornColumnDictionary.java	45
client-spark/spark-3-columnar-common/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornBatchBuilder.scala	28
client-spark/spark-3-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java	129
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala	41
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala	101
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala	294
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala	205
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala	461
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala	86
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala	256
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala	133
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala	18
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala	67
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala	43
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala	353
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala	46
client-spark/spark-3-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala	49
client-spark/spark-3.5-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java	129
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala	41
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala	102
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala	295
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala	205
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala	463
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala	87
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala	256
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala	133
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala	18
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala	67
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala	43
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala	356
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala	46
client-spark/spark-3.5-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala	49
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/CelebornPartitionUtil.java	45
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/CelebornShuffleDataIO.java	38
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/HashBasedShuffleWriter.java	344
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SortBasedShuffleWriter.java	349
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkShuffleManager.java	393
client-spark/spark-3/src/main/java/org/apache/spark/shuffle/celeborn/SparkUtils.java	523
client-spark/spark-3/src/main/scala/org/apache/spark/SparkVersionUtil.scala	12
client-spark/spark-3/src/main/scala/org/apache/spark/celeborn/ExceptionMakerHelper.scala	22
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleFallbackPolicyRunner.scala	36
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleHandle.scala	34
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornShuffleReader.scala	400
client-spark/spark-3/src/main/scala/org/apache/spark/shuffle/celeborn/ShuffleFetchFailureReportTaskCleanListener.scala	9
client-spark/spark-4-columnar-shuffle/src/main/java/org/apache/spark/shuffle/celeborn/ColumnarHashBasedShuffleWriter.java	129
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/shuffle/celeborn/CelebornColumnarShuffleReader.scala	41
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnAccessor.scala	102
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnBuilder.scala	295
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnStats.scala	205
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnType.scala	466
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchBuilder.scala	87
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchCodeGenBuild.scala	256
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornColumnarBatchSerializer.scala	133
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnAccessor.scala	18
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressibleColumnBuilder.scala	67
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionScheme.scala	43
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornCompressionSchemes.scala	356
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnAccessor.scala	46
client-spark/spark-4-columnar-shuffle/src/main/scala/org/apache/spark/sql/execution/columnar/CelebornNullableColumnBuilder.scala	49
client-tez/tez/src/main/java/org/apache/celeborn/client/CelebornTezReader.java	62
client-tez/tez/src/main/java/org/apache/celeborn/client/CelebornTezWriter.java	99
client-tez/tez/src/main/java/org/apache/celeborn/tez/plugin/util/CelebornTezUtils.java	70
client-tez/tez/src/main/java/org/apache/celeborn/tez/plugin/util/ChecksumUtils.java	17
client-tez/tez/src/main/java/org/apache/tez/dag/app/CelebornDagAppMaster.java	394
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornFetcher.java	149
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/CelebornShuffleManager.java	427
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornScheduler.java	308
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornShuffle.java	63
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornTezBypassWriter.java	51
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/CelebornTezShuffleDataFetcher.java	183
client-tez/tez/src/main/java/org/apache/tez/runtime/library/common/writers/CelebornUnorderedPartitionedKVWriter.java	149
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornConcatenatedMergedKeyValueInput.java	75
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornConcatenatedMergedKeyValuesInput.java	75
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedInputLegacy.java	56
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedKVInput.java	263
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornOrderedGroupedMergedKVInput.java	185
client-tez/tez/src/main/java/org/apache/tez/runtime/library/input/CelebornUnorderedKVInput.java	259
client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornOrderedPartitionedKVOutput.java	135
client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedKVOutput.java	210
client-tez/tez/src/main/java/org/apache/tez/runtime/library/output/CelebornUnorderedPartitionedKVOutput.java	177
client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornSortBasedPusher.java	289
client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornSorter.java	92
client-tez/tez/src/main/java/org/apache/tez/runtime/library/sort/CelebornTezPerPartitionRecord.java	43
client/src/main/java/org/apache/celeborn/client/DummyShuffleClient.java	175
client/src/main/java/org/apache/celeborn/client/ReviveManager.java	95
client/src/main/java/org/apache/celeborn/client/ShuffleClient.java	211
client/src/main/java/org/apache/celeborn/client/ShuffleClientImpl.java	1889
client/src/main/java/org/apache/celeborn/client/compress/Compressor.java	28
client/src/main/java/org/apache/celeborn/client/compress/Decompressor.java	37
client/src/main/java/org/apache/celeborn/client/compress/Lz4Compressor.java	55
client/src/main/java/org/apache/celeborn/client/compress/Lz4Decompressor.java	65
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	780
client/src/main/java/org/apache/celeborn/client/read/DfsPartitionReader.java	313
client/src/main/java/org/apache/celeborn/client/read/LocalPartitionReader.java	249
client/src/main/java/org/apache/celeborn/client/read/MetricsCallback.java	6
client/src/main/java/org/apache/celeborn/client/read/PartitionReader.java	13
client/src/main/java/org/apache/celeborn/client/read/WorkerPartitionReader.java	254
client/src/main/java/org/apache/celeborn/client/read/checkpoint/PartitionReaderCheckpointMetadata.java	18
client/src/main/java/org/apache/celeborn/client/write/DataPushQueue.java	106
client/src/main/java/org/apache/celeborn/client/write/DataPusher.java	211
client/src/main/java/org/apache/celeborn/client/write/PushTask.java	27
client/src/main/scala/org/apache/celeborn/client/ApplicationHeartbeater.scala	142
client/src/main/scala/org/apache/celeborn/client/ChangePartitionManager.scala	350
client/src/main/scala/org/apache/celeborn/client/ClientUtils.scala	20
client/src/main/scala/org/apache/celeborn/client/CommitManager.scala	278
client/src/main/scala/org/apache/celeborn/client/LifecycleManager.scala	1622
client/src/main/scala/org/apache/celeborn/client/ReleasePartitionManager.scala	121
client/src/main/scala/org/apache/celeborn/client/RequestLocationCallContext.scala	54
client/src/main/scala/org/apache/celeborn/client/WorkerStatusTracker.scala	209
client/src/main/scala/org/apache/celeborn/client/commit/CommitHandler.scala	462
client/src/main/scala/org/apache/celeborn/client/commit/MapPartitionCommitHandler.scala	192
client/src/main/scala/org/apache/celeborn/client/commit/ReducePartitionCommitHandler.scala	340
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
cpp/celeborn/client/ShuffleClient.cpp	111
cpp/celeborn/client/ShuffleClient.h	53
cpp/celeborn/client/reader/CelebornInputStream.cpp	165
cpp/celeborn/client/reader/CelebornInputStream.h	48
cpp/celeborn/client/reader/WorkerPartitionReader.cpp	116
cpp/celeborn/client/reader/WorkerPartitionReader.h	54
cpp/celeborn/conf/BaseConf.cpp	183
cpp/celeborn/conf/BaseConf.h	173
cpp/celeborn/conf/CelebornConf.cpp	155
cpp/celeborn/conf/CelebornConf.h	39
cpp/celeborn/memory/ByteBuffer.cpp	55
cpp/celeborn/memory/ByteBuffer.h	128
cpp/celeborn/network/FrameDecoder.h	45
cpp/celeborn/network/Message.cpp	126
cpp/celeborn/network/Message.h	172
cpp/celeborn/network/MessageDispatcher.cpp	223
cpp/celeborn/network/MessageDispatcher.h	62
cpp/celeborn/network/NettyRpcEndpointRef.cpp	50
cpp/celeborn/network/NettyRpcEndpointRef.h	31
cpp/celeborn/network/TransportClient.cpp	160
cpp/celeborn/network/TransportClient.h	92
cpp/celeborn/proto/TransportMessagesCpp.proto	784
cpp/celeborn/protocol/ControlMessages.cpp	150
cpp/celeborn/protocol/ControlMessages.h	69
cpp/celeborn/protocol/PartitionLocation.cpp	97
cpp/celeborn/protocol/PartitionLocation.h	62
cpp/celeborn/protocol/StatusCode.h	62
cpp/celeborn/protocol/TransportMessage.cpp	30
cpp/celeborn/protocol/TransportMessage.h	25
cpp/celeborn/utils/CelebornException.cpp	211
cpp/celeborn/utils/CelebornException.h	272
cpp/celeborn/utils/CelebornUtils.cpp	55
cpp/celeborn/utils/CelebornUtils.h	71
cpp/celeborn/utils/Exceptions.cpp	9
cpp/celeborn/utils/Exceptions.h	330
cpp/celeborn/utils/ProcessBase.cpp	52
cpp/celeborn/utils/ProcessBase.h	17
cpp/celeborn/utils/StackTrace.cpp	145
cpp/celeborn/utils/StackTrace.h	31
cpp/celeborn/utils/flags.cpp	21
cpp/cmake/FindSodium.cmake	265
cpp/cmake/celeborn-config.cmake.in	24
dev/merge_pr.py	461
master/src/main/java/org/apache/celeborn/service/deploy/master/MasterSecretRegistryImpl.java	38
master/src/main/java/org/apache/celeborn/service/deploy/master/SlotsAllocator.java	579
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/AbstractMetaManager.java	532
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/IMetadataHandler.java	62
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/MetaUtil.java	137
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/SingleMasterMetaManager.java	136
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAHelper.java	98
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HAMasterMetaManager.java	397
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/HARaftServer.java	504
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/MetaHandler.java	278
master/src/main/java/org/apache/celeborn/service/deploy/master/clustermeta/ha/StateMachine.java	256
master/src/main/proto/Resource.proto	227
master/src/main/scala/org/apache/celeborn/service/deploy/master/InternalRpcEndpoint.scala	25
master/src/main/scala/org/apache/celeborn/service/deploy/master/Master.scala	1315
master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterArguments.scala	67
master/src/main/scala/org/apache/celeborn/service/deploy/master/MasterSource.scala	31
master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterClusterInfo.scala	54
master/src/main/scala/org/apache/celeborn/service/deploy/master/clustermeta/ha/MasterNode.scala	82
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/ApiMasterResource.scala	117
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/MasterHttpResourceUtils.scala	19
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApiV1MasterResource.scala	16
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ApplicationResource.scala	72
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/MasterResource.scala	78
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/RatisResource.scala	328
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/ShuffleResource.scala	36
master/src/main/scala/org/apache/celeborn/service/deploy/master/http/api/v1/WorkerResource.scala	156
master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaManager.scala	353
master/src/main/scala/org/apache/celeborn/service/deploy/master/quota/QuotaStatus.scala	12
master/src/main/scala/org/apache/celeborn/service/deploy/master/tags/TagsManager.scala	93
multipart-uploader/multipart-uploader-oss/src/main/java/org/apache/celeborn/OssMultipartUploadHandler.java	111
multipart-uploader/multipart-uploader-s3/src/main/java/org/apache/celeborn/S3MultipartUploadHandler.java	160
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ApplicationApi.java	220
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ConfApi.java	139
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/DefaultApi.java	136
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/LoggerApi.java	141
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/MasterApi.java	96
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/RatisApi.java	459
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/ShuffleApi.java	96
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/WorkerApi.java	301
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiClient.java	610
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ApiException.java	58
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/BaseApi.java	39
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/Configuration.java	12
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/JavaTimeFormatter.java	24
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/Pair.java	34
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/RFC3339DateFormat.java	37
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ServerConfiguration.java	32
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/ServerVariable.java	13
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/StringUtil.java	40
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/ApiKeyAuth.java	52
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/Authentication.java	7
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/HttpBasicAuth.java	31
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/master/invoker/auth/HttpBearerAuth.java	34
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationHeartbeatData.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationsHeartbeatResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ApplicationsResponse.java	74
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ConfResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ConfigData.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ContainerInfo.java	214
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DeleteAppsRequest.java	74
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DynamicConfig.java	141
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/DynamicConfigResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ExcludeWorkerRequest.java	102
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/HandleResponse.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/HostnamesResponse.java	74
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/LoggerInfo.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/LoggerInfos.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterCommitData.java	164
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterInfoResponse.java	137
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/MasterLeader.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/PartitionLocationData.java	218
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisElectionTransferRequest.java	64
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLocalRaftMetaConfRequest.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLogInfo.java	125
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisLogTermIndex.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeer.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerAddRequest.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerRemoveRequest.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RatisPeerSetPriorityRequest.java	73
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/RemoveWorkersUnavailableInfoRequest.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ReviseLostShufflesRequest.java	94
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/SendWorkerEventRequest.java	124
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ShufflePartitionsResponse.java	101
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ShufflesResponse.java	74
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ThreadStack.java	335
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/ThreadStackResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/TopologyInfo.java	94
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/TopologyResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/UnAvailablePeersResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerData.java	361
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventData.java	86
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventInfoData.java	84
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerEventsResponse.java	75
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerExitRequest.java	91
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerId.java	144
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerInfoResponse.java	401
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerResourceConsumption.java	153
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkerTimestampData.java	85
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/model/WorkersResponse.java	211
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ApplicationApi.java	96
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ConfApi.java	139
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/DefaultApi.java	136
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/LoggerApi.java	141
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/ShuffleApi.java	136
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/WorkerApi.java	179
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ApiClient.java	610
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ApiException.java	58
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/BaseApi.java	39
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/Configuration.java	12
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/JavaTimeFormatter.java	24
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/Pair.java	34
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/RFC3339DateFormat.java	37
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ServerConfiguration.java	32
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/ServerVariable.java	13
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/StringUtil.java	40
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/ApiKeyAuth.java	52
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/Authentication.java	7
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/HttpBasicAuth.java	31
openapi/openapi-client/src/main/java/org/apache/celeborn/rest/v1/worker/invoker/auth/HttpBearerAuth.java	34
openapi/openapi-client/src/main/openapi3/master_rest_v1.yaml	1110
openapi/openapi-client/src/main/openapi3/templates/licenseInfo.mustache	16
openapi/openapi-client/src/main/openapi3/worker_rest_v1.yaml	687
project/AddMetaInfLicenseFiles.scala	230
project/BuildTools.scala	33
project/CelebornBuild.scala	1459
project/JDKTools.scala	36
project/plugins.sbt	5
service/src/main/java/org/apache/celeborn/server/common/service/config/BaseConfigServiceImpl.java	85
service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigLevel.java	6
service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigService.java	31
service/src/main/java/org/apache/celeborn/server/common/service/config/ConfigStore.java	5
service/src/main/java/org/apache/celeborn/server/common/service/config/DbConfigServiceImpl.java	40
service/src/main/java/org/apache/celeborn/server/common/service/config/DbConfigStoreImpl.java	11
service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfig.java	254
service/src/main/java/org/apache/celeborn/server/common/service/config/DynamicConfigServiceFactory.java	35
service/src/main/java/org/apache/celeborn/server/common/service/config/FsConfigServiceImpl.java	95
service/src/main/java/org/apache/celeborn/server/common/service/config/FsConfigStoreImpl.java	11
service/src/main/java/org/apache/celeborn/server/common/service/config/SystemConfig.java	53
service/src/main/java/org/apache/celeborn/server/common/service/config/TenantConfig.java	40
service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterInfo.java	46
service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterSystemConfig.java	53
service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterTag.java	46
service/src/main/java/org/apache/celeborn/server/common/service/model/ClusterTenantConfig.java	95
service/src/main/java/org/apache/celeborn/server/common/service/mpu/MultipartUploadHandler.java	10
service/src/main/java/org/apache/celeborn/server/common/service/store/IServiceManager.java	14
service/src/main/java/org/apache/celeborn/server/common/service/store/db/DBSessionFactory.java	68
service/src/main/java/org/apache/celeborn/server/common/service/store/db/DbServiceManagerImpl.java	141
service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterInfoMapper.java	13
service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterSystemConfigMapper.java	10
service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterTagsMapper.java	10
service/src/main/java/org/apache/celeborn/server/common/service/store/db/mapper/ClusterTenantConfigMapper.java	19
service/src/main/java/org/apache/celeborn/server/common/service/utils/JsonUtils.java	28
service/src/main/resources/org/apache/celeborn/swagger/index.html	52
service/src/main/resources/sql/mysql/001-CELEBORN-1618-mysql.sql	11
service/src/main/resources/sql/mysql/celeborn-0.5.0-mysql.sql	38
service/src/main/resources/sql/mysql/celeborn-0.6.0-mysql.sql	49
service/src/main/resources/sql/mysql/upgrade-0.5.0-to-0.6.0-mysql.sql	3
service/src/main/scala/org/apache/celeborn/common/metrics/MetricsSystem.scala	152
service/src/main/scala/org/apache/celeborn/common/metrics/sink/AbstractServlet.scala	18
service/src/main/scala/org/apache/celeborn/common/metrics/sink/JsonServlet.scala	313
service/src/main/scala/org/apache/celeborn/common/metrics/sink/PrometheusServlet.scala	18
service/src/main/scala/org/apache/celeborn/server/common/HttpService.scala	289
service/src/main/scala/org/apache/celeborn/server/common/Service.scala	22
service/src/main/scala/org/apache/celeborn/server/common/container/ContainerInfoProvider.scala	19
service/src/main/scala/org/apache/celeborn/server/common/container/DefaultContainerInfoProvider.scala	16
service/src/main/scala/org/apache/celeborn/server/common/http/HttpAuthUtils.scala	15
service/src/main/scala/org/apache/celeborn/server/common/http/HttpServer.scala	152
service/src/main/scala/org/apache/celeborn/server/common/http/HttpUtils.scala	88
service/src/main/scala/org/apache/celeborn/server/common/http/RestAuditLogger.scala	22
service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiBaseResource.scala	90
service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiRequestContext.scala	44
service/src/main/scala/org/apache/celeborn/server/common/http/api/ApiRootResource.scala	16
service/src/main/scala/org/apache/celeborn/server/common/http/api/CelebornOpenApiResource.scala	88
service/src/main/scala/org/apache/celeborn/server/common/http/api/CelebornScalaObjectMapper.scala	10
service/src/main/scala/org/apache/celeborn/server/common/http/api/OpenAPIConfig.scala	18
service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ApiUtils.scala	133
service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ApiV1BaseResource.scala	60
service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/ConfResource.scala	111
service/src/main/scala/org/apache/celeborn/server/common/http/api/v1/LoggerResource.scala	64
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/AuthenticationFilter.scala	176
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/AuthenticationHandler.scala	35
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/BasicAuthenticationHandler.scala	73
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/BearerAuthenticationHandler.scala	62
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/HttpAuthenticationFactory.scala	64
service/src/main/scala/org/apache/celeborn/server/common/http/authentication/SpnegoAuthenticationHandler.scala	131
spi/src/main/java/org/apache/celeborn/spi/authentication/BasicPrincipal.java	29
spi/src/main/java/org/apache/celeborn/spi/authentication/Credential.java	4
spi/src/main/java/org/apache/celeborn/spi/authentication/PasswdAuthenticationProvider.java	6
spi/src/main/java/org/apache/celeborn/spi/authentication/PasswordCredential.java	7
spi/src/main/java/org/apache/celeborn/spi/authentication/TokenAuthenticationProvider.java	6
spi/src/main/java/org/apache/celeborn/spi/authentication/TokenCredential.java	6
toolkit/scripts/check.py	36
toolkit/scripts/genConfs.py	135
toolkit/scripts/genSkewData.scala	40
version.sbt	1
web/index.html	13
web/src/App.vue	7
web/src/api/index.ts	6
web/src/api/models/application/index.ts	10
web/src/api/models/application/types/application.ts	26
web/src/api/models/application/types/index.ts	1
web/src/api/models/cluster/index.ts	6
web/src/api/models/cluster/types/cluster.ts	4
web/src/api/models/cluster/types/index.ts	1
web/src/api/models/master/index.ts	13
web/src/api/models/master/types/detail.ts	15
web/src/api/models/master/types/index.ts	2
web/src/api/models/master/types/master.ts	14
web/src/api/models/storage/index.ts	6
web/src/api/models/storage/types/index.ts	1
web/src/api/models/storage/types/storage.ts	5
web/src/api/models/tenant/index.ts	13
web/src/api/models/tenant/types/detail.ts	5
web/src/api/models/tenant/types/index.ts	2
web/src/api/models/tenant/types/tenant.ts	9
web/src/api/models/worker/index.ts	13
web/src/api/models/worker/types/detail.ts	36
web/src/api/models/worker/types/index.ts	2
web/src/api/models/worker/types/worker.ts	24
web/src/api/request.ts	53
web/src/api/types.ts	10
web/src/assets/styles/base.scss	1
web/src/assets/styles/index.scss	11
web/src/components/configuration-service/index.vue	45
web/src/components/log-files-service/index.vue	31
web/src/composables/form.ts	16
web/src/composables/index.ts	2
web/src/composables/pagination.ts	77
web/src/layouts/components/menus/index.vue	23
web/src/layouts/layoutPage.vue	48
web/src/main.ts	9
web/src/router/index.ts	18
web/src/router/modules/application.ts	6
web/src/router/modules/master.ts	19
web/src/router/modules/overview.ts	6
web/src/router/modules/tenant.ts	19
web/src/router/modules/worker.ts	19
web/src/router/routes.ts	23
web/src/utils/index.ts	1
web/src/utils/transform.ts	9
web/src/views/application/components/ApplicationForm.vue	45
web/src/views/application/components/ApplicationTable.vue	49
web/src/views/application/components/index.ts	3
web/src/views/application/index.vue	31
web/src/views/master/components/MasterDetailContent.vue	42
web/src/views/master/components/MasterDetailOverview.vue	22
web/src/views/master/components/MasterLeader.vue	24
web/src/views/master/components/MasterTable.vue	92
web/src/views/master/components/index.ts	10
web/src/views/master/detail.vue	63
web/src/views/master/index.vue	27
web/src/views/overview/components/ApplicationOverview.vue	23
web/src/views/overview/components/ClusterOverview.vue	21
web/src/views/overview/components/MasterOverview.vue	21
web/src/views/overview/components/StorageOverview.vue	27
web/src/views/overview/components/WorkerOverview.vue	24
web/src/views/overview/components/index.ts	12
web/src/views/overview/index.vue	53
web/src/views/tenant/components/TenantDetailOverview.vue	26
web/src/views/tenant/components/TenantDetailTable.vue	33
web/src/views/tenant/components/TenantForm.vue	32
web/src/views/tenant/components/TenantOverview.vue	27
web/src/views/tenant/components/TenantTable.vue	59
web/src/views/tenant/components/index.ts	12
web/src/views/tenant/detail.vue	38
web/src/views/tenant/index.vue	28
web/src/views/worker/components/WorkerDetailContent.vue	41
web/src/views/worker/components/WorkerDetailOverview.vue	23
web/src/views/worker/components/WorkerForm.vue	36
web/src/views/worker/components/WorkerTable.vue	100
web/src/views/worker/components/detail/WorkerDetailMemory.vue	29
web/src/views/worker/components/detail/WorkerDetailStorage.vue	43
web/src/views/worker/components/detail/index.ts	3
web/src/views/worker/components/index.ts	11
web/src/views/worker/detail.vue	40
web/src/views/worker/index.vue	29
web/vite.config.ts	51
worker/src/main/java/org/apache/celeborn/service/deploy/worker/ShuffleRecoverHelper.java	16
worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkerSecretRegistryImpl.java	75
worker/src/main/java/org/apache/celeborn/service/deploy/worker/WorkingPartition.java	14
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/BufferStatusHub.java	59
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/CongestionController.java	275
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/TimeSlidingHub.java	95
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/UserBufferInfo.java	19
worker/src/main/java/org/apache/celeborn/service/deploy/worker/congestcontrol/UserCongestionControlContext.java	55
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	118
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/MemoryManager.java	554
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/ReadBufferDispatcher.java	134
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	21
worker/src/main/java/org/apache/celeborn/service/deploy/worker/memory/RecyclableSegmentIdBuffer.java	15
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DB.java	9
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBBackend.java	16
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBIterator.java	11
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/DBProvider.java	25
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDB.java	38
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDBIterator.java	58
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/LevelDBProvider.java	104
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDB.java	56
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDBIterator.java	61
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/RocksDBProvider.java	133
worker/src/main/java/org/apache/celeborn/service/deploy/worker/shuffledb/StoreVersion.java	28
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/ChunkStreamManager.java	136
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/CreditStreamManager.java	324
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/MapPartitionData.java	217
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/MapPartitionDataReader.java	448
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriter.java	221
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionDataWriterContext.java	126
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/PartitionFilesSorter.java	866
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/TierWriterHelper.java	39
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionData.java	80
worker/src/main/java/org/apache/celeborn/service/deploy/worker/storage/segment/SegmentMapPartitionDataReader.java	252
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	740
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/FetchHandler.scala	576
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/InternalRpcEndpoint.scala	24
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/PushDataHandler.scala	1404
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/Worker.scala	947
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerArguments.scala	58
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerSource.scala	168
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/WorkerStatusManager.scala	126
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/ApiWorkerResource.scala	64
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApiV1WorkerResource.scala	12
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ApplicationResource.scala	29
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/ShuffleResource.scala	55
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/http/api/v1/WorkerResource.scala	63
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/monitor/JVMQuake.scala	143
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/profiler/JVMProfiler.scala	41
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/DeviceMonitor.scala	278
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	76
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/Flusher.scala	185
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/PartitionMetaHandler.scala	340
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StorageManager.scala	1094
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/StoragePolicy.scala	170
worker/src/main/scala/org/apache/celeborn/service/deploy/worker/storage/TierWriter.scala	586