Path	Lines of Code
cli/src/main/java/org/apache/uniffle/AbstractCustomCommandLine.java	52
cli/src/main/java/org/apache/uniffle/CustomCommandLine.java	6
cli/src/main/java/org/apache/uniffle/UniffleCliArgsException.java	10
cli/src/main/java/org/apache/uniffle/api/AdminRestApi.java	19
cli/src/main/java/org/apache/uniffle/cli/CLIContentUtils.java	160
cli/src/main/java/org/apache/uniffle/cli/UniffleAdminCLI.java	114
cli/src/main/java/org/apache/uniffle/cli/UniffleCLI.java	73
cli/src/main/java/org/apache/uniffle/client/HttpClientFactory.java	36
cli/src/main/java/org/apache/uniffle/client/RestClient.java	5
cli/src/main/java/org/apache/uniffle/client/RestClientConf.java	31
cli/src/main/java/org/apache/uniffle/client/RestClientImpl.java	93
cli/src/main/java/org/apache/uniffle/client/UniffleRestClient.java	62
cli/src/main/java/org/apache/uniffle/client/exception/UniffleRestException.java	6
client-mr/core/src/main/java/org/apache/hadoop/mapred/RssMapOutputCollector.java	208
client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java	274
client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBufferManager.java	364
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/MRIdHelper.java	8
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java	172
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRUtils.java	295
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssBypassWriter.java	39
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssEventFetcher.java	127
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssFetcher.java	242
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssInMemoryRemoteMerger.java	172
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssRemoteMergeManagerImpl.java	250
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssShuffle.java	250
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java	454
client-mr/hadoop2.8/src/main/java/org/apache/uniffle/hadoop/shim/HadoopShimImpl.java	40
client-mr/hadoop3.2/src/main/java/org/apache/uniffle/hadoop/shim/HadoopShimImpl.java	28
client-spark/common/src/main/java/org/apache/spark/shuffle/RssShuffleHandle.java	47
client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java	353
client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkShuffleUtils.java	303
client-spark/common/src/main/java/org/apache/spark/shuffle/ShuffleHandleInfo.java	41
client-spark/common/src/main/java/org/apache/spark/shuffle/SparkVersionUtils.java	27
client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssFetchFailedIterator.java	111
client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java	159
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/AddBlockEvent.java	37
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/BufferManagerOptions.java	96
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java	103
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WrappedByteArrayOutputStream.java	10
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java	469
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriterBuffer.java	82
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java	122
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerInterface.java	9
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java	145
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerServerFactory.java	39
client-spark/spark2/src/main/java/org/apache/spark/network/util/NettyUtils.java	88
client-spark/spark2/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java	192
client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java	570
client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java	218
client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java	363
client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java	268
client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java	854
client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java	273
client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java	380
client-tez/src/main/java/org/apache/tez/common/GetShuffleServerRequest.java	68
client-tez/src/main/java/org/apache/tez/common/GetShuffleServerResponse.java	50
client-tez/src/main/java/org/apache/tez/common/IdUtils.java	12
client-tez/src/main/java/org/apache/tez/common/InputContextUtils.java	11
client-tez/src/main/java/org/apache/tez/common/RssTezConfig.java	178
client-tez/src/main/java/org/apache/tez/common/RssTezUtils.java	432
client-tez/src/main/java/org/apache/tez/common/ShuffleAssignmentsInfoWritable.java	130
client-tez/src/main/java/org/apache/tez/common/TezClassLoader.java	48
client-tez/src/main/java/org/apache/tez/common/TezIdHelper.java	8
client-tez/src/main/java/org/apache/tez/common/TezRemoteShuffleUmbilicalProtocol.java	17
client-tez/src/main/java/org/apache/tez/common/UmbilicalUtils.java	89
client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java	474
client-tez/src/main/java/org/apache/tez/dag/app/TezRemoteShuffleManager.java	252
client-tez/src/main/java/org/apache/tez/dag/app/security/authorize/RssTezAMPolicyProvider.java	17
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssShuffleManager.java	1206
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssSimpleFetchedInputAllocator.java	189
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcher.java	176
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java	206
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffle.java	379
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleScheduler.java	1609
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezBypassWriter.java	52
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezShuffleDataFetcher.java	223
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java	279
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManager.java	390
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssSorter.java	186
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssTezPerPartitionRecord.java	51
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssUnSorter.java	186
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssConcatenatedMergedKeyValueInput.java	79
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssConcatenatedMergedKeyValuesInput.java	79
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedInputLegacy.java	57
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedKVInput.java	345
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedMergedKVInput.java	193
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssUnorderedKVInput.java	316
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssOrderedPartitionedKVOutput.java	274
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutput.java	278
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutput.java	275
client/src/main/java/org/apache/uniffle/client/api/ShuffleReadClient.java	8
client/src/main/java/org/apache/uniffle/client/api/ShuffleWriteClient.java	63
client/src/main/java/org/apache/uniffle/client/factory/ShuffleClientFactory.java	144
client/src/main/java/org/apache/uniffle/client/impl/ShuffleReadClientImpl.java	336
client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java	929
client/src/main/java/org/apache/uniffle/client/request/CreateShuffleReadClientRequest.java	181
client/src/main/java/org/apache/uniffle/client/response/CompressedShuffleBlock.java	16
client/src/main/java/org/apache/uniffle/client/response/SendShuffleDataResult.java	16
client/src/main/java/org/apache/uniffle/client/util/ClientUtils.java	111
client/src/main/java/org/apache/uniffle/client/util/DefaultIdHelper.java	9
client/src/main/java/org/apache/uniffle/client/util/RssClientConfig.java	67
common/src/main/java/org/apache/uniffle/common/Arguments.java	11
common/src/main/java/org/apache/uniffle/common/BufferSegment.java	73
common/src/main/java/org/apache/uniffle/common/ClientType.java	5
common/src/main/java/org/apache/uniffle/common/PartitionRange.java	45
common/src/main/java/org/apache/uniffle/common/RemoteStorageInfo.java	103
common/src/main/java/org/apache/uniffle/common/ServerStatus.java	33
common/src/main/java/org/apache/uniffle/common/ShuffleAssignmentsInfo.java	19
common/src/main/java/org/apache/uniffle/common/ShuffleBlockInfo.java	119
common/src/main/java/org/apache/uniffle/common/ShuffleDataDistributionType.java	5
common/src/main/java/org/apache/uniffle/common/ShuffleDataResult.java	62
common/src/main/java/org/apache/uniffle/common/ShuffleDataSegment.java	21
common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java	43
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedBlock.java	98
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java	40
common/src/main/java/org/apache/uniffle/common/ShuffleRegisterInfo.java	36
common/src/main/java/org/apache/uniffle/common/ShuffleServerInfo.java	74
common/src/main/java/org/apache/uniffle/common/StorageType.java	10
common/src/main/java/org/apache/uniffle/common/UnionKey.java	20
common/src/main/java/org/apache/uniffle/common/compression/Codec.java	32
common/src/main/java/org/apache/uniffle/common/compression/Lz4Codec.java	40
common/src/main/java/org/apache/uniffle/common/compression/NoOpCodec.java	32
common/src/main/java/org/apache/uniffle/common/compression/SnappyCodec.java	87
common/src/main/java/org/apache/uniffle/common/compression/ZstdCodec.java	76
common/src/main/java/org/apache/uniffle/common/config/ConfigOption.java	94
common/src/main/java/org/apache/uniffle/common/config/ConfigOptions.java	135
common/src/main/java/org/apache/uniffle/common/config/ConfigUtils.java	159
common/src/main/java/org/apache/uniffle/common/config/FallbackKey.java	25
common/src/main/java/org/apache/uniffle/common/config/Reconfigurable.java	5
common/src/main/java/org/apache/uniffle/common/config/ReconfigurableBase.java	52
common/src/main/java/org/apache/uniffle/common/config/RssBaseConf.java	205
common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java	100
common/src/main/java/org/apache/uniffle/common/config/RssConf.java	284
common/src/main/java/org/apache/uniffle/common/exception/FileNotFoundException.java	9
common/src/main/java/org/apache/uniffle/common/exception/InvalidRequestException.java	9
common/src/main/java/org/apache/uniffle/common/exception/NotRetryException.java	9
common/src/main/java/org/apache/uniffle/common/exception/RssException.java	12
common/src/main/java/org/apache/uniffle/common/exception/RssFetchFailedException.java	9
common/src/main/java/org/apache/uniffle/common/filesystem/HadoopFilesystemProvider.java	38
common/src/main/java/org/apache/uniffle/common/metrics/AbstractMetricReporter.java	18
common/src/main/java/org/apache/uniffle/common/metrics/EmptyGRPCMetrics.java	8
common/src/main/java/org/apache/uniffle/common/metrics/GRPCMetrics.java	60
common/src/main/java/org/apache/uniffle/common/metrics/JvmMetrics.java	52
common/src/main/java/org/apache/uniffle/common/metrics/MetricReporter.java	7
common/src/main/java/org/apache/uniffle/common/metrics/MetricReporterFactory.java	15
common/src/main/java/org/apache/uniffle/common/metrics/MetricsManager.java	78
common/src/main/java/org/apache/uniffle/common/metrics/NettyMetrics.java	23
common/src/main/java/org/apache/uniffle/common/metrics/RPCMetrics.java	110
common/src/main/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporter.java	95
common/src/main/java/org/apache/uniffle/common/netty/DecodeException.java	13
common/src/main/java/org/apache/uniffle/common/netty/EncodeException.java	13
common/src/main/java/org/apache/uniffle/common/netty/FrameDecoder.java	5
common/src/main/java/org/apache/uniffle/common/netty/IOMode.java	5
common/src/main/java/org/apache/uniffle/common/netty/MessageEncoder.java	35
common/src/main/java/org/apache/uniffle/common/netty/TransportFrameDecoder.java	120
common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java	79
common/src/main/java/org/apache/uniffle/common/netty/buffer/ManagedBuffer.java	10
common/src/main/java/org/apache/uniffle/common/netty/buffer/NettyManagedBuffer.java	31
common/src/main/java/org/apache/uniffle/common/netty/client/RpcResponseCallback.java	6
common/src/main/java/org/apache/uniffle/common/netty/client/TransportClient.java	129
common/src/main/java/org/apache/uniffle/common/netty/client/TransportClientFactory.java	173
common/src/main/java/org/apache/uniffle/common/netty/client/TransportConf.java	34
common/src/main/java/org/apache/uniffle/common/netty/client/TransportContext.java	62
common/src/main/java/org/apache/uniffle/common/netty/handle/BaseMessageHandler.java	7
common/src/main/java/org/apache/uniffle/common/netty/handle/MessageHandler.java	8
common/src/main/java/org/apache/uniffle/common/netty/handle/TransportChannelHandler.java	108
common/src/main/java/org/apache/uniffle/common/netty/handle/TransportRequestHandler.java	30
common/src/main/java/org/apache/uniffle/common/netty/handle/TransportResponseHandler.java	86
common/src/main/java/org/apache/uniffle/common/netty/protocol/Decoders.java	76
common/src/main/java/org/apache/uniffle/common/netty/protocol/Encodable.java	7
common/src/main/java/org/apache/uniffle/common/netty/protocol/Encoders.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataRequest.java	101
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataResponse.java	53
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexRequest.java	66
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexResponse.java	79
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataRequest.java	112
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataResponse.java	66
common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java	107
common/src/main/java/org/apache/uniffle/common/netty/protocol/RequestMessage.java	12
common/src/main/java/org/apache/uniffle/common/netty/protocol/RpcResponse.java	58
common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequest.java	107
common/src/main/java/org/apache/uniffle/common/netty/protocol/Transferable.java	5
common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java	179
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerCall.java	25
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerCallListener.java	13
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerInterceptor.java	26
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerTransportFilter.java	21
common/src/main/java/org/apache/uniffle/common/rpc/ServerInterface.java	8
common/src/main/java/org/apache/uniffle/common/rpc/ServerType.java	5
common/src/main/java/org/apache/uniffle/common/rpc/StatusCode.java	38
common/src/main/java/org/apache/uniffle/common/security/HadoopSecurityContext.java	95
common/src/main/java/org/apache/uniffle/common/security/NoOpSecurityContext.java	16
common/src/main/java/org/apache/uniffle/common/security/SecurityConfig.java	49
common/src/main/java/org/apache/uniffle/common/security/SecurityContext.java	7
common/src/main/java/org/apache/uniffle/common/security/SecurityContextFactory.java	33
common/src/main/java/org/apache/uniffle/common/segment/FixedSizeSegmentSplitter.java	78
common/src/main/java/org/apache/uniffle/common/segment/LocalOrderSegmentSplitter.java	104
common/src/main/java/org/apache/uniffle/common/segment/SegmentSplitter.java	7
common/src/main/java/org/apache/uniffle/common/segment/SegmentSplitterFactory.java	25
common/src/main/java/org/apache/uniffle/common/storage/StorageInfo.java	103
common/src/main/java/org/apache/uniffle/common/storage/StorageInfoUtils.java	27
common/src/main/java/org/apache/uniffle/common/storage/StorageMedia.java	44
common/src/main/java/org/apache/uniffle/common/storage/StorageStatus.java	42
common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java	57
common/src/main/java/org/apache/uniffle/common/util/ByteUnit.java	53
common/src/main/java/org/apache/uniffle/common/util/ChecksumUtils.java	33
common/src/main/java/org/apache/uniffle/common/util/Constants.java	54
common/src/main/java/org/apache/uniffle/common/util/ExitUtils.java	33
common/src/main/java/org/apache/uniffle/common/util/IdHelper.java	4
common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java	38
common/src/main/java/org/apache/uniffle/common/util/NettyUtils.java	83
common/src/main/java/org/apache/uniffle/common/util/RetryUtils.java	61
common/src/main/java/org/apache/uniffle/common/util/RssUtils.java	348
common/src/main/java/org/apache/uniffle/common/util/ThreadUtils.java	49
common/src/main/java/org/apache/uniffle/common/util/TripleFunction.java	5
common/src/main/java/org/apache/uniffle/common/util/UnitConverter.java	101
common/src/main/java/org/apache/uniffle/common/web/CoalescedCollectorRegistry.java	62
common/src/main/java/org/apache/uniffle/common/web/JerseyAutoDiscoverable.java	15
common/src/main/java/org/apache/uniffle/common/web/JettyServer.java	136
common/src/main/java/org/apache/uniffle/common/web/JsonConverter.java	61
common/src/main/java/org/apache/uniffle/common/web/resource/BaseMetricResource.java	18
common/src/main/java/org/apache/uniffle/common/web/resource/MetricResource.java	51
common/src/main/java/org/apache/uniffle/common/web/resource/PrometheusMetricResource.java	34
coordinator/src/main/java/org/apache/uniffle/coordinator/AccessManager.java	95
coordinator/src/main/java/org/apache/uniffle/coordinator/ApplicationManager.java	314
coordinator/src/main/java/org/apache/uniffle/coordinator/ClientConfManager.java	125
coordinator/src/main/java/org/apache/uniffle/coordinator/ClusterManager.java	18
coordinator/src/main/java/org/apache/uniffle/coordinator/ClusterManagerFactory.java	13
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorConf.java	212
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorFactory.java	24
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java	354
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorServer.java	227
coordinator/src/main/java/org/apache/uniffle/coordinator/QuotaManager.java	134
coordinator/src/main/java/org/apache/uniffle/coordinator/ServerNode.java	217
coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java	320
coordinator/src/main/java/org/apache/uniffle/coordinator/access/AccessCheckResult.java	25
coordinator/src/main/java/org/apache/uniffle/coordinator/access/AccessInfo.java	49
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AbstractAccessChecker.java	7
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessCandidatesChecker.java	129
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessChecker.java	8
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessClusterLoadChecker.java	99
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessQuotaChecker.java	51
coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorGrpcMetrics.java	27
coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorMetrics.java	88
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AbstractAssignmentStrategy.java	73
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AssignmentStrategy.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AssignmentStrategyFactory.java	25
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/BasicAssignmentStrategy.java	51
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionBalanceAssignmentStrategy.java	135
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionRangeAssignment.java	58
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/BasicHostAssignmentStrategy.java	9
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/HostAssignmentStrategy.java	6
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/MustDiffHostAssignmentStrategy.java	24
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/PreferDiffHostAssignmentStrategy.java	28
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/ContinuousSelectPartitionStrategy.java	36
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/RoundSelectPartitionStrategy.java	32
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/SelectPartitionStrategy.java	13
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AbstractSelectStorageStrategy.java	149
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategy.java	49
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategy.java	53
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/RankValue.java	48
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/SelectStorageStrategy.java	6
coordinator/src/main/java/org/apache/uniffle/coordinator/util/CoordinatorUtils.java	124
coordinator/src/main/java/org/apache/uniffle/coordinator/web/Response.java	41
coordinator/src/main/java/org/apache/uniffle/coordinator/web/request/CancelDecommissionRequest.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/web/request/DecommissionRequest.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/APIResource.java	16
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/AdminResource.java	35
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/BaseResource.java	12
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ServerResource.java	99
deploy/kubernetes/operator/api/uniffle/v1alpha1/doc.go	1
deploy/kubernetes/operator/api/uniffle/v1alpha1/groupversion_info.go	16
deploy/kubernetes/operator/api/uniffle/v1alpha1/remoteshuffleservice_types.go	114
deploy/kubernetes/operator/api/uniffle/v1alpha1/zz_generated.deepcopy.go	406
deploy/kubernetes/operator/cmd/controller/main.go	27
deploy/kubernetes/operator/cmd/webhook/main.go	19
deploy/kubernetes/operator/config/crd/bases/uniffle.apache.org_remoteshuffleservices.yaml	9661
deploy/kubernetes/operator/config/manager/rss-controller.yaml	114
deploy/kubernetes/operator/config/manager/rss-webhook.yaml	137
deploy/kubernetes/operator/hack/revive.toml	59
deploy/kubernetes/operator/hack/tools.go	4
deploy/kubernetes/operator/pkg/constants/constants.go	20
deploy/kubernetes/operator/pkg/controller/config/config.go	41
deploy/kubernetes/operator/pkg/controller/constants/constants.go	28
deploy/kubernetes/operator/pkg/controller/controller/rss.go	772
deploy/kubernetes/operator/pkg/controller/controller/test.go	13
deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator.go	308
deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver.go	264
deploy/kubernetes/operator/pkg/controller/util/kubernetes/configmap.go	59
deploy/kubernetes/operator/pkg/controller/util/kubernetes/deployment.go	69
deploy/kubernetes/operator/pkg/controller/util/kubernetes/hpa.go	74
deploy/kubernetes/operator/pkg/controller/util/kubernetes/service.go	78
deploy/kubernetes/operator/pkg/controller/util/kubernetes/serviceaccount.go	59
deploy/kubernetes/operator/pkg/controller/util/kubernetes/statefulset.go	83
deploy/kubernetes/operator/pkg/controller/util/properties/properties.go	33
deploy/kubernetes/operator/pkg/controller/util/util.go	197
deploy/kubernetes/operator/pkg/utils/certs.go	185
deploy/kubernetes/operator/pkg/utils/config.go	44
deploy/kubernetes/operator/pkg/utils/coordinator.go	25
deploy/kubernetes/operator/pkg/utils/rss.go	76
deploy/kubernetes/operator/pkg/utils/shufflerserver.go	61
deploy/kubernetes/operator/pkg/utils/util.go	57
deploy/kubernetes/operator/pkg/webhook/config/config.go	82
deploy/kubernetes/operator/pkg/webhook/constants/constants.go	11
deploy/kubernetes/operator/pkg/webhook/inspector/inspector.go	104
deploy/kubernetes/operator/pkg/webhook/inspector/pod.go	140
deploy/kubernetes/operator/pkg/webhook/inspector/rss.go	156
deploy/kubernetes/operator/pkg/webhook/manager.go	179
deploy/kubernetes/operator/pkg/webhook/syncer/syncer.go	204
deploy/kubernetes/operator/pkg/webhook/util/patch.go	6
deploy/kubernetes/operator/pkg/webhook/util/util.go	178
internal-client/src/main/java/org/apache/uniffle/client/api/CoordinatorClient.java	26
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleManagerClient.java	8
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerClient.java	43
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerInternalClient.java	11
internal-client/src/main/java/org/apache/uniffle/client/factory/CoordinatorClientFactory.java	54
internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleManagerClientFactory.java	20
internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleServerClientFactory.java	54
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java	375
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/GrpcClient.java	39
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleManagerGrpcClient.java	49
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java	855
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java	299
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerInternalGrpcClient.java	50
internal-client/src/main/java/org/apache/uniffle/client/request/RssAccessClusterRequest.java	45
internal-client/src/main/java/org/apache/uniffle/client/request/RssAppHeartBeatRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssApplicationInfoRequest.java	20
internal-client/src/main/java/org/apache/uniffle/client/request/RssCancelDecommissionRequest.java	2
internal-client/src/main/java/org/apache/uniffle/client/request/RssDecommissionRequest.java	2
internal-client/src/main/java/org/apache/uniffle/client/request/RssFetchClientConfRequest.java	10
internal-client/src/main/java/org/apache/uniffle/client/request/RssFetchRemoteStorageRequest.java	10
internal-client/src/main/java/org/apache/uniffle/client/request/RssFinishShuffleRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetInMemoryShuffleDataRequest.java	42
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleAssignmentsRequest.java	65
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleDataRequest.java	47
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleIndexRequest.java	31
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleResultForMultiPartRequest.java	22
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleResultRequest.java	20
internal-client/src/main/java/org/apache/uniffle/client/request/RssRegisterShuffleRequest.java	80
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleFetchFailureRequest.java	30
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleResultRequest.java	37
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendCommitRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendHeartBeatRequest.java	81
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendShuffleDataRequest.java	32
internal-client/src/main/java/org/apache/uniffle/client/request/RssUnregisterShuffleRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/response/ClientResponse.java	20
internal-client/src/main/java/org/apache/uniffle/client/response/RssAccessClusterResponse.java	15
internal-client/src/main/java/org/apache/uniffle/client/response/RssAppHeartBeatResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssApplicationInfoResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssCancelDecommissionResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssDecommissionResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssFetchClientConfResponse.java	18
internal-client/src/main/java/org/apache/uniffle/client/response/RssFetchRemoteStorageResponse.java	13
internal-client/src/main/java/org/apache/uniffle/client/response/RssFinishShuffleResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetInMemoryShuffleDataResponse.java	21
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleAssignmentsResponse.java	29
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleDataResponse.java	13
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleIndexResponse.java	14
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleResultResponse.java	16
internal-client/src/main/java/org/apache/uniffle/client/response/RssRegisterShuffleResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleFetchFailureResponse.java	29
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleResultResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendCommitResponse.java	14
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendHeartBeatResponse.java	15
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendShuffleDataResponse.java	22
internal-client/src/main/java/org/apache/uniffle/client/response/RssUnregisterShuffleResponse.java	7
proto/src/main/proto/Rss.proto	437
server/src/main/java/org/apache/uniffle/server/Checker.java	5
server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java	126
server/src/main/java/org/apache/uniffle/server/FlushEventHandler.java	6
server/src/main/java/org/apache/uniffle/server/HealthCheck.java	79
server/src/main/java/org/apache/uniffle/server/LocalStorageChecker.java	221
server/src/main/java/org/apache/uniffle/server/RegisterHeartBeat.java	124
server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java	143
server/src/main/java/org/apache/uniffle/server/ShuffleDataReadEvent.java	26
server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java	254
server/src/main/java/org/apache/uniffle/server/ShuffleServer.java	427
server/src/main/java/org/apache/uniffle/server/ShuffleServerConf.java	437
server/src/main/java/org/apache/uniffle/server/ShuffleServerFactory.java	31
server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java	121
server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java	842
server/src/main/java/org/apache/uniffle/server/ShuffleServerInternalGrpcService.java	62
server/src/main/java/org/apache/uniffle/server/ShuffleServerMetrics.java	272
server/src/main/java/org/apache/uniffle/server/ShuffleServerNettyMetrics.java	73
server/src/main/java/org/apache/uniffle/server/ShuffleSpecification.java	32
server/src/main/java/org/apache/uniffle/server/ShuffleTaskInfo.java	116
server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java	677
server/src/main/java/org/apache/uniffle/server/buffer/PreAllocatedBufferInfo.java	20
server/src/main/java/org/apache/uniffle/server/buffer/RequireBufferStatusCode.java	12
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBuffer.java	295
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java	563
server/src/main/java/org/apache/uniffle/server/event/AppPurgeEvent.java	10
server/src/main/java/org/apache/uniffle/server/event/PurgeEvent.java	35
server/src/main/java/org/apache/uniffle/server/event/ShufflePurgeEvent.java	7
server/src/main/java/org/apache/uniffle/server/netty/ShuffleServerNettyHandler.java	448
server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java	137
server/src/main/java/org/apache/uniffle/server/netty/StreamServerMetricHandler.java	27
server/src/main/java/org/apache/uniffle/server/storage/AbstractStorageManagerFallbackStrategy.java	45
server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManager.java	148
server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManagerFallbackStrategy.java	22
server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManager.java	319
server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManagerFallbackStrategy.java	22
server/src/main/java/org/apache/uniffle/server/storage/MultiStorageManager.java	142
server/src/main/java/org/apache/uniffle/server/storage/RotateStorageManagerFallbackStrategy.java	19
server/src/main/java/org/apache/uniffle/server/storage/SingleStorageManager.java	115
server/src/main/java/org/apache/uniffle/server/storage/StorageManager.java	25
server/src/main/java/org/apache/uniffle/server/storage/StorageManagerFactory.java	24
server/src/main/java/org/apache/uniffle/server/storage/StorageMediaFromEnvProvider.java	52
server/src/main/java/org/apache/uniffle/server/storage/multi/DefaultStorageManagerSelector.java	25
server/src/main/java/org/apache/uniffle/server/storage/multi/FallbackBasedStorageManagerSelector.java	31
server/src/main/java/org/apache/uniffle/server/storage/multi/HugePartitionSensitiveStorageManagerSelector.java	23
server/src/main/java/org/apache/uniffle/server/storage/multi/StorageManagerSelector.java	10
spotbugs-exclude.xml	9
storage/src/main/java/org/apache/uniffle/storage/api/FileReader.java	8
storage/src/main/java/org/apache/uniffle/storage/api/FileWriter.java	7
storage/src/main/java/org/apache/uniffle/storage/common/AbstractStorage.java	62
storage/src/main/java/org/apache/uniffle/storage/common/DefaultStorageMediaProvider.java	80
storage/src/main/java/org/apache/uniffle/storage/common/FileBasedShuffleSegment.java	94
storage/src/main/java/org/apache/uniffle/storage/common/HadoopStorage.java	88
storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java	229
storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java	92
storage/src/main/java/org/apache/uniffle/storage/common/ShuffleFileInfo.java	69
storage/src/main/java/org/apache/uniffle/storage/common/ShuffleInfo.java	15
storage/src/main/java/org/apache/uniffle/storage/common/ShuffleSegment.java	2
storage/src/main/java/org/apache/uniffle/storage/common/Storage.java	18
storage/src/main/java/org/apache/uniffle/storage/common/StorageMediaProvider.java	7
storage/src/main/java/org/apache/uniffle/storage/common/StorageReadMetrics.java	20
storage/src/main/java/org/apache/uniffle/storage/common/StorageWriteMetrics.java	48
storage/src/main/java/org/apache/uniffle/storage/factory/ShuffleHandlerFactory.java	159
storage/src/main/java/org/apache/uniffle/storage/handler/ClientReadHandlerMetric.java	72
storage/src/main/java/org/apache/uniffle/storage/handler/api/ClientReadHandler.java	9
storage/src/main/java/org/apache/uniffle/storage/handler/api/ServerReadHandler.java	7
storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleDeleteHandler.java	4
storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleWriteHandler.java	6
storage/src/main/java/org/apache/uniffle/storage/handler/impl/AbstractClientReadHandler.java	62
storage/src/main/java/org/apache/uniffle/storage/handler/impl/ComposedClientReadHandler.java	167
storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataFileSegment.java	22
storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataSkippableReadHandler.java	71
storage/src/main/java/org/apache/uniffle/storage/handler/impl/FileSegment.java	20
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandler.java	200
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileReader.java	119
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileWriter.java	95
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleDeleteHandler.java	65
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleReadHandler.java	194
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleWriteHandler.java	142
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileClientReadHandler.java	140
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileDeleteHandler.java	30
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java	84
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileServerReadHandler.java	118
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriteHandler.java	101
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriter.java	42
storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java	57
storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java	74
storage/src/main/java/org/apache/uniffle/storage/handler/impl/PooledHadoopShuffleWriteHandler.java	94
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleDeleteHandlerRequest.java	16
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleReadHandlerRequest.java	152
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleWriteHandlerRequest.java	99
storage/src/main/java/org/apache/uniffle/storage/util/ShuffleStorageUtils.java	185
storage/src/main/java/org/apache/uniffle/storage/util/StorageType.java	29