path	# lines of code
conf/log4j2.xml	54
release/asf-settings.xml	17
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/RssOrderedGroupedKVInput.java	349
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	321
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/RMRssOrderedGroupedKVInput.java	248
client-tez/src/main/java/org/apache/tez/runtime/library/input/RssOrderedGroupedInputLegacy.java	57
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssMergeManager.java	497
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RMRssShuffle.java	225
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezShuffleDataFetcher.java	230
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffle.java	431
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssInMemoryMerger.java	173
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssShuffleScheduler.java	1647
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RssTezBypassWriter.java	51
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/orderedgrouped/RMRssShuffleScheduler.java	56
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/RemoteFetchedInput.java	108
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssSimpleFetchedInputAllocator.java	271
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcherTask.java	238
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssShuffleManager.java	1211
client-tez/src/main/java/org/apache/tez/runtime/library/common/shuffle/impl/RssTezFetcher.java	183
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBufferManager.java	433
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/buffer/WriteBuffer.java	303
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/RssSorter.java	193
client-tez/src/main/java/org/apache/tez/runtime/library/common/sort/impl/RssUnSorter.java	189
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssOrderedPartitionedKVOutput.java	300
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedKVOutput.java	285
client-tez/src/main/java/org/apache/tez/runtime/library/output/RssUnorderedPartitionedKVOutput.java	282
client-tez/src/main/java/org/apache/tez/common/TezIdHelper.java	8
client-tez/src/main/java/org/apache/tez/common/RssTezConfig.java	202
client-tez/src/main/java/org/apache/tez/common/GetShuffleServerResponse.java	50
client-tez/src/main/java/org/apache/tez/common/TezRemoteShuffleUmbilicalProtocol.java	17
client-tez/src/main/java/org/apache/tez/common/RssTezUtils.java	429
client-tez/src/main/java/org/apache/tez/common/GetShuffleServerRequest.java	100
client-tez/src/main/java/org/apache/tez/common/InputContextUtils.java	11
client-tez/src/main/java/org/apache/tez/common/UmbilicalUtils.java	89
client-tez/src/main/java/org/apache/tez/common/TezClassLoader.java	50
client-tez/src/main/java/org/apache/tez/common/ShuffleAssignmentsInfoWritable.java	133
client-tez/src/main/java/org/apache/tez/common/IdUtils.java	12
client-tez/src/main/java/org/apache/tez/dag/app/RssDAGAppMaster.java	567
client-tez/src/main/java/org/apache/tez/dag/app/security/authorize/RssTezAMPolicyProvider.java	17
client-tez/src/main/java/org/apache/tez/dag/app/TezRemoteShuffleManager.java	329
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/Utils.java	67
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/NMCallBackHandler.java	48
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/Constants.java	25
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnClient.java	173
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleTask.java	159
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/UniffleClientSimOnYarnAppMaster.java	249
tools/client-simulation-yarn/src/main/java/org/apache/uniffle/client/simulator/HadoopConfigApp.java	106
common/src/main/java/io/netty/util/CompositeFileRegion.java	106
common/src/main/java/org/apache/uniffle/common/metrics/CommonMetrics.java	49
common/src/main/java/org/apache/uniffle/common/metrics/EmptyGRPCMetrics.java	9
common/src/main/java/org/apache/uniffle/common/metrics/MetricReporterFactory.java	15
common/src/main/java/org/apache/uniffle/common/metrics/SupplierGauge.java	65
common/src/main/java/org/apache/uniffle/common/metrics/NettyMetrics.java	40
common/src/main/java/org/apache/uniffle/common/metrics/MetricsManager.java	120
common/src/main/java/org/apache/uniffle/common/metrics/JvmMetrics.java	52
common/src/main/java/org/apache/uniffle/common/metrics/RPCMetrics.java	148
common/src/main/java/org/apache/uniffle/common/metrics/MetricReporter.java	7
common/src/main/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporter.java	120
common/src/main/java/org/apache/uniffle/common/metrics/GRPCMetrics.java	64
common/src/main/java/org/apache/uniffle/common/metrics/AbstractMetricReporter.java	18
common/src/main/java/org/apache/uniffle/common/compression/SnappyCodec.java	87
common/src/main/java/org/apache/uniffle/common/compression/NoOpCodec.java	32
common/src/main/java/org/apache/uniffle/common/compression/ZstdCodec.java	91
common/src/main/java/org/apache/uniffle/common/compression/Lz4Codec.java	40
common/src/main/java/org/apache/uniffle/common/compression/Codec.java	35
common/src/main/java/org/apache/uniffle/common/records/RecordsReader.java	49
common/src/main/java/org/apache/uniffle/common/records/RecordsWriter.java	42
common/src/main/java/org/apache/uniffle/common/PartitionRange.java	45
common/src/main/java/org/apache/uniffle/common/serializer/Serializer.java	5
common/src/main/java/org/apache/uniffle/common/serializer/SerializationStream.java	9
common/src/main/java/org/apache/uniffle/common/serializer/FileSerOutputStream.java	33
common/src/main/java/org/apache/uniffle/common/serializer/FileSerInputStream.java	95
common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoDeserializationStream.java	78
common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializationStream.java	57
common/src/main/java/org/apache/uniffle/common/serializer/kryo/PoolWrapper.java	40
common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializer.java	18
common/src/main/java/org/apache/uniffle/common/serializer/kryo/KryoSerializerInstance.java	88
common/src/main/java/org/apache/uniffle/common/serializer/DeserializationStream.java	9
common/src/main/java/org/apache/uniffle/common/serializer/SerializerFactory.java	42
common/src/main/java/org/apache/uniffle/common/serializer/SerOutputStream.java	12
common/src/main/java/org/apache/uniffle/common/serializer/writable/BufferedRawWritableSerializationStream.java	53
common/src/main/java/org/apache/uniffle/common/serializer/writable/WritableDeserializationStream.java	67
common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableDeserializationStream.java	59
common/src/main/java/org/apache/uniffle/common/serializer/writable/WritableSerializerInstance.java	50
common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableSerializationStream.java	53
common/src/main/java/org/apache/uniffle/common/serializer/writable/WritableSerializationStream.java	58
common/src/main/java/org/apache/uniffle/common/serializer/writable/WritableSerializer.java	19
common/src/main/java/org/apache/uniffle/common/serializer/writable/BufferedRawWritableDeserializationStream.java	74
common/src/main/java/org/apache/uniffle/common/serializer/writable/ComparativeOutputBuffer.java	20
common/src/main/java/org/apache/uniffle/common/serializer/SerInputStream.java	31
common/src/main/java/org/apache/uniffle/common/serializer/BufferSerInputStream.java	40
common/src/main/java/org/apache/uniffle/common/serializer/WrappedByteArrayOutputStream.java	13
common/src/main/java/org/apache/uniffle/common/serializer/SerializerInstance.java	12
common/src/main/java/org/apache/uniffle/common/serializer/DynBufferSerOutputStream.java	36
common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java	85
common/src/main/java/org/apache/uniffle/common/Arguments.java	11
common/src/main/java/org/apache/uniffle/common/ReconfigurableConfManager.java	165
common/src/main/java/org/apache/uniffle/common/segment/AbstractSegmentSplitter.java	101
common/src/main/java/org/apache/uniffle/common/segment/FixedSizeSegmentSplitter.java	13
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/segment/LocalOrderSegmentSplitter.java	16
common/src/main/java/org/apache/uniffle/common/ReconfigurableRegistry.java	90
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/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/TransportConf.java	43
common/src/main/java/org/apache/uniffle/common/netty/client/TransportClientFactory.java	202
common/src/main/java/org/apache/uniffle/common/netty/client/TransportContext.java	62
common/src/main/java/org/apache/uniffle/common/netty/MessageEncoder.java	58
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexRequest.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/AbstractFileRegion.java	29
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetSortedShuffleDataRequest.java	79
common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequestV1.java	108
common/src/main/java/org/apache/uniffle/common/netty/protocol/RpcResponse.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexResponse.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV2Request.java	68
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataResponse.java	28
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetSortedShuffleDataResponse.java	65
common/src/main/java/org/apache/uniffle/common/netty/protocol/Decoders.java	99
common/src/main/java/org/apache/uniffle/common/netty/protocol/RequestMessage.java	17
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexV2Response.java	87
common/src/main/java/org/apache/uniffle/common/netty/protocol/Encodable.java	7
common/src/main/java/org/apache/uniffle/common/netty/protocol/ResponseMessage.java	13
common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java	154
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataRequest.java	133
common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequest.java	141
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataResponse.java	71
common/src/main/java/org/apache/uniffle/common/netty/protocol/MessageWithHeader.java	120
common/src/main/java/org/apache/uniffle/common/netty/protocol/Encoders.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataRequest.java	122
common/src/main/java/org/apache/uniffle/common/netty/IOMode.java	5
common/src/main/java/org/apache/uniffle/common/netty/buffer/NettyManagedBuffer.java	38
common/src/main/java/org/apache/uniffle/common/netty/buffer/MultiFileSegmentManagedBuffer.java	54
common/src/main/java/org/apache/uniffle/common/netty/buffer/ManagedBuffer.java	11
common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java	95
common/src/main/java/org/apache/uniffle/common/netty/handle/TransportResponseHandler.java	88
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	34
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/TransportFrameDecoder.java	142
common/src/main/java/org/apache/uniffle/common/ShuffleDataSegment.java	27
common/src/main/java/org/apache/uniffle/common/ReceivingFailureServer.java	58
common/src/main/java/org/apache/uniffle/common/config/RssBaseConf.java	301
common/src/main/java/org/apache/uniffle/common/config/ConfigUtils.java	169
common/src/main/java/org/apache/uniffle/common/config/FallbackKey.java	25
common/src/main/java/org/apache/uniffle/common/config/RssConf.java	307
common/src/main/java/org/apache/uniffle/common/config/ConfigOptions.java	135
common/src/main/java/org/apache/uniffle/common/config/ConfigOption.java	94
common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java	289
common/src/main/java/org/apache/uniffle/common/security/SecurityContextFactory.java	34
common/src/main/java/org/apache/uniffle/common/security/SecurityConfig.java	57
common/src/main/java/org/apache/uniffle/common/security/NoOpSecurityContext.java	16
common/src/main/java/org/apache/uniffle/common/security/SecurityContext.java	7
common/src/main/java/org/apache/uniffle/common/security/HadoopSecurityContext.java	106
common/src/main/java/org/apache/uniffle/common/merger/MergeState.java	14
common/src/main/java/org/apache/uniffle/common/merger/Segment.java	17
common/src/main/java/org/apache/uniffle/common/merger/Merger.java	188
common/src/main/java/org/apache/uniffle/common/merger/StreamedSegment.java	47
common/src/main/java/org/apache/uniffle/common/merger/KeyValueIterator.java	8
common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java	58
common/src/main/java/org/apache/uniffle/common/util/UnitConverter.java	116
common/src/main/java/org/apache/uniffle/common/util/IdHelper.java	4
common/src/main/java/org/apache/uniffle/common/util/BlockIdLayout.java	147
common/src/main/java/org/apache/uniffle/common/util/ByteBufferUtils.java	15
common/src/main/java/org/apache/uniffle/common/util/NettyUtils.java	129
common/src/main/java/org/apache/uniffle/common/util/RetryUtils.java	86
common/src/main/java/org/apache/uniffle/common/util/ByteUnit.java	56
common/src/main/java/org/apache/uniffle/common/util/Constants.java	59
common/src/main/java/org/apache/uniffle/common/util/JvmPauseMonitor.java	154
common/src/main/java/org/apache/uniffle/common/util/BlockId.java	44
common/src/main/java/org/apache/uniffle/common/util/ThreadUtils.java	150
common/src/main/java/org/apache/uniffle/common/util/ChecksumUtils.java	33
common/src/main/java/org/apache/uniffle/common/util/OutputUtils.java	51
common/src/main/java/org/apache/uniffle/common/util/ExitUtils.java	33
common/src/main/java/org/apache/uniffle/common/util/ExpiringCloseableSupplier.java	74
common/src/main/java/org/apache/uniffle/common/util/GrpcNettyUtils.java	55
common/src/main/java/org/apache/uniffle/common/util/TripleFunction.java	5
common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java	67
common/src/main/java/org/apache/uniffle/common/util/StatefulCloseable.java	5
common/src/main/java/org/apache/uniffle/common/util/RssUtils.java	373
common/src/main/java/org/apache/uniffle/common/BlockCompletionCallback.java	4
common/src/main/java/org/apache/uniffle/common/exception/RssException.java	12
common/src/main/java/org/apache/uniffle/common/exception/RssWaitFailedException.java	12
common/src/main/java/org/apache/uniffle/common/exception/RssFetchFailedException.java	9
common/src/main/java/org/apache/uniffle/common/exception/FileNotFoundException.java	9
common/src/main/java/org/apache/uniffle/common/exception/NotRetryException.java	12
common/src/main/java/org/apache/uniffle/common/exception/InvalidRequestException.java	9
common/src/main/java/org/apache/uniffle/common/exception/NoRegisterException.java	12
common/src/main/java/org/apache/uniffle/common/exception/NoBufferForHugePartitionException.java	12
common/src/main/java/org/apache/uniffle/common/exception/ExceedHugePartitionHardLimitException.java	12
common/src/main/java/org/apache/uniffle/common/exception/RssSendFailedException.java	12
common/src/main/java/org/apache/uniffle/common/exception/NoBufferException.java	12
common/src/main/java/org/apache/uniffle/common/function/ConsumerWithException.java	5
common/src/main/java/org/apache/uniffle/common/function/TupleConsumer.java	5
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedBlock.java	108
common/src/main/java/org/apache/uniffle/common/ShuffleAssignmentsInfo.java	19
common/src/main/java/org/apache/uniffle/common/rpc/ServerInterface.java	8
common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java	211
common/src/main/java/org/apache/uniffle/common/rpc/ClientContextServerInterceptor.java	31
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerTransportFilter.java	21
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/StatusCode.java	43
common/src/main/java/org/apache/uniffle/common/rpc/ServerType.java	5
common/src/main/java/org/apache/uniffle/common/rpc/MonitoringServerCall.java	25
common/src/main/java/org/apache/uniffle/common/Application.java	131
common/src/main/java/org/apache/uniffle/common/PartitionSplitMode.java	5
common/src/main/java/org/apache/uniffle/common/ShuffleDataResult.java	76
common/src/main/java/org/apache/uniffle/common/audit/RpcAuditContext.java	80
common/src/main/java/org/apache/uniffle/common/AuditType.java	12
common/src/main/java/org/apache/uniffle/common/future/CompletableFutureUtils.java	48
common/src/main/java/org/apache/uniffle/common/future/CompletableFutureExtension.java	58
common/src/main/java/org/apache/uniffle/common/ClientType.java	5
common/src/main/java/org/apache/uniffle/common/UnionKey.java	20
common/src/main/java/org/apache/uniffle/common/BufferSegment.java	73
common/src/main/java/org/apache/uniffle/common/ShuffleDataDistributionType.java	5
common/src/main/java/org/apache/uniffle/common/ServerStatus.java	34
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java	54
common/src/main/java/org/apache/uniffle/common/RemoteStorageInfo.java	108
common/src/main/java/org/apache/uniffle/common/storage/StorageMedia.java	47
common/src/main/java/org/apache/uniffle/common/storage/ApplicationStorageInfo.java	30
common/src/main/java/org/apache/uniffle/common/storage/StorageStatus.java	45
common/src/main/java/org/apache/uniffle/common/storage/StorageInfo.java	106
common/src/main/java/org/apache/uniffle/common/storage/StorageInfoUtils.java	27
common/src/main/java/org/apache/uniffle/common/filesystem/HadoopFilesystemProvider.java	40
common/src/main/java/org/apache/uniffle/common/ShuffleBlockInfo.java	139
common/src/main/java/org/apache/uniffle/common/executor/MeasurableRejectedExecutionHandler.java	21
common/src/main/java/org/apache/uniffle/common/executor/ThreadPoolManager.java	265
common/src/main/java/org/apache/uniffle/common/web/CoalescedCollectorRegistry.java	62
common/src/main/java/org/apache/uniffle/common/web/JettyServer.java	146
common/src/main/java/org/apache/uniffle/common/web/resource/MetricResource.java	50
common/src/main/java/org/apache/uniffle/common/web/resource/BaseResource.java	11
common/src/main/java/org/apache/uniffle/common/web/resource/ConfVO.java	24
common/src/main/java/org/apache/uniffle/common/web/resource/BaseMetricResource.java	18
common/src/main/java/org/apache/uniffle/common/web/resource/AuthorizationRequestFilter.java	33
common/src/main/java/org/apache/uniffle/common/web/resource/Response.java	41
common/src/main/java/org/apache/uniffle/common/web/resource/Authorization.java	10
common/src/main/java/org/apache/uniffle/common/web/resource/ConfOpsResource.java	46
common/src/main/java/org/apache/uniffle/common/web/resource/PrometheusMetricResource.java	34
common/src/main/java/org/apache/uniffle/common/web/JsonConverter.java	61
common/src/main/java/org/apache/uniffle/common/web/JerseyAutoDiscoverable.java	15
common/src/main/java/org/apache/uniffle/common/ShuffleRegisterInfo.java	36
common/src/main/java/org/apache/uniffle/common/StorageType.java	10
common/src/main/java/org/apache/uniffle/common/ShuffleServerInfo.java	110
common/src/main/java/org/apache/uniffle/common/PartitionInfo.java	38
common/src/main/java-templates/org/apache/uniffle/common/ProjectConstants.java	12
deploy/kubernetes/operator/api/uniffle/v1alpha1/groupversion_info.go	16
deploy/kubernetes/operator/api/uniffle/v1alpha1/doc.go	1
deploy/kubernetes/operator/api/uniffle/v1alpha1/remoteshuffleservice_types.go	124
deploy/kubernetes/operator/api/uniffle/v1alpha1/zz_generated.deepcopy.go	463
deploy/kubernetes/operator/hack/revive.toml	59
deploy/kubernetes/operator/hack/tools.go	4
deploy/kubernetes/operator/config/manager/rss-controller.yaml	114
deploy/kubernetes/operator/config/manager/rss-webhook.yaml	137
deploy/kubernetes/operator/pkg/constants/constants.go	20
deploy/kubernetes/operator/pkg/utils/certs.go	185
deploy/kubernetes/operator/pkg/utils/shufflerserver.go	61
deploy/kubernetes/operator/pkg/utils/util.go	57
deploy/kubernetes/operator/pkg/utils/rss.go	76
deploy/kubernetes/operator/pkg/utils/coordinator.go	25
deploy/kubernetes/operator/pkg/utils/config.go	44
deploy/kubernetes/operator/pkg/controller/constants/constants.go	29
deploy/kubernetes/operator/pkg/controller/sync/shuffleserver/shuffleserver.go	285
deploy/kubernetes/operator/pkg/controller/sync/coordinator/coordinator.go	327
deploy/kubernetes/operator/pkg/controller/config/config.go	41
deploy/kubernetes/operator/pkg/controller/util/util.go	198
deploy/kubernetes/operator/pkg/controller/util/properties/properties.go	33
deploy/kubernetes/operator/pkg/controller/util/kubernetes/deployment.go	69
deploy/kubernetes/operator/pkg/controller/util/kubernetes/service.go	78
deploy/kubernetes/operator/pkg/controller/util/kubernetes/statefulset.go	83
deploy/kubernetes/operator/pkg/controller/util/kubernetes/configmap.go	59
deploy/kubernetes/operator/pkg/controller/util/kubernetes/hpa.go	74
deploy/kubernetes/operator/pkg/controller/util/kubernetes/serviceaccount.go	59
deploy/kubernetes/operator/pkg/controller/controller/rss.go	772
deploy/kubernetes/operator/pkg/webhook/constants/constants.go	11
deploy/kubernetes/operator/pkg/webhook/syncer/syncer.go	204
deploy/kubernetes/operator/pkg/webhook/inspector/pod.go	140
deploy/kubernetes/operator/pkg/webhook/inspector/rss.go	156
deploy/kubernetes/operator/pkg/webhook/inspector/inspector.go	104
deploy/kubernetes/operator/pkg/webhook/config/config.go	85
deploy/kubernetes/operator/pkg/webhook/util/util.go	200
deploy/kubernetes/operator/pkg/webhook/util/patch.go	6
deploy/kubernetes/operator/pkg/webhook/manager.go	180
deploy/kubernetes/operator/cmd/controller/main.go	27
deploy/kubernetes/operator/cmd/webhook/main.go	19
dashboard/src/main/java/org/apache/uniffle/dashboard/web/utils/DashboardUtils.java	35
dashboard/src/main/java/org/apache/uniffle/dashboard/web/Dashboard.java	135
dashboard/src/main/java/org/apache/uniffle/dashboard/web/config/DashboardConf.java	47
dashboard/src/main/java/org/apache/uniffle/dashboard/web/vo/DashboardConfVO.java	9
dashboard/src/main/java/org/apache/uniffle/dashboard/web/proxy/WebProxyServlet.java	62
dashboard/src/main/java/org/apache/uniffle/dashboard/web/resource/WebResource.java	16
dashboard/src/main/java/org/apache/uniffle/dashboard/web/resource/CoordinatorResource.java	26
dashboard/src/main/java/org/apache/uniffle/dashboard/web/resource/DashboardResource.java	53
dashboard/src/main/webapp/packagescript/cleanfile.js	11
dashboard/src/main/webapp/packagescript/fileutils.js	63
dashboard/src/main/webapp/packagescript/filecopy.js	5
dashboard/src/main/webapp/public/index.html	19
dashboard/src/main/webapp/vue.config.js	13
dashboard/src/main/webapp/src/api/api.js	76
dashboard/src/main/webapp/src/components/LayoutPage.vue	137
dashboard/src/main/webapp/src/utils/common.js	20
dashboard/src/main/webapp/src/utils/request.js	44
dashboard/src/main/webapp/src/utils/http.js	51
dashboard/src/main/webapp/src/main.js	13
dashboard/src/main/webapp/src/store/useCurrentServerStore.js	9
dashboard/src/main/webapp/src/router/index.js	74
dashboard/src/main/webapp/src/mock/applicationpage.js	79
dashboard/src/main/webapp/src/mock/nodelistpage.js	406
dashboard/src/main/webapp/src/mock/layoutpage.js	13
dashboard/src/main/webapp/src/mock/shuffleserverpage.js	16
dashboard/src/main/webapp/src/mock/index.js	6
dashboard/src/main/webapp/src/mock/excludenodelist.js	25
dashboard/src/main/webapp/src/pages/CoordinatorServerPage.vue	246
dashboard/src/main/webapp/src/pages/ApplicationPage.vue	182
dashboard/src/main/webapp/src/pages/DashboardPage.vue	129
dashboard/src/main/webapp/src/pages/serverstatus/NodeListPage.vue	473
dashboard/src/main/webapp/src/pages/ShuffleServerPage.vue	209
dashboard/src/main/webapp/src/App.vue	12
dashboard/src/main/webapp/babel.config.js	3
client/src/main/java/org/apache/uniffle/client/api/ShuffleReadClient.java	8
client/src/main/java/org/apache/uniffle/client/api/ShuffleWriteClient.java	208
client/src/main/java/org/apache/uniffle/client/response/CompressedShuffleBlock.java	16
client/src/main/java/org/apache/uniffle/client/response/SendShuffleDataResult.java	33
client/src/main/java/org/apache/uniffle/client/util/ClientUtils.java	94
client/src/main/java/org/apache/uniffle/client/util/RssClientConfig.java	71
client/src/main/java/org/apache/uniffle/client/util/DefaultIdHelper.java	13
client/src/main/java/org/apache/uniffle/client/record/metrics/MetricsReporter.java	4
client/src/main/java/org/apache/uniffle/client/record/Record.java	41
client/src/main/java/org/apache/uniffle/client/record/RecordBlob.java	71
client/src/main/java/org/apache/uniffle/client/record/reader/BufferedSegment.java	39
client/src/main/java/org/apache/uniffle/client/record/reader/KeyValueReader.java	7
client/src/main/java/org/apache/uniffle/client/record/reader/KeyValuesReader.java	7
client/src/main/java/org/apache/uniffle/client/record/reader/RMRecordsReader.java	594
client/src/main/java/org/apache/uniffle/client/record/writer/Combiner.java	10
client/src/main/java/org/apache/uniffle/client/record/RecordBuffer.java	72
client/src/main/java/org/apache/uniffle/client/record/RecordCollection.java	8
client/src/main/java/org/apache/uniffle/client/factory/ShuffleClientFactory.java	339
client/src/main/java/org/apache/uniffle/client/impl/TrackingBlockStatus.java	26
client/src/main/java/org/apache/uniffle/client/impl/ShuffleServerPushCost.java	50
client/src/main/java/org/apache/uniffle/client/impl/ShuffleReadClientImpl.java	287
client/src/main/java/org/apache/uniffle/client/impl/ShuffleServerPushCostTracker.java	72
client/src/main/java/org/apache/uniffle/client/impl/TrackingPartitionStatus.java	16
client/src/main/java/org/apache/uniffle/client/impl/FailedBlockSendTracker.java	83
client/src/main/java/org/apache/uniffle/client/impl/ShuffleWriteClientImpl.java	1108
client/src/main/java/org/apache/uniffle/client/PartitionDataReplicaRequirementTracking.java	83
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleManagerClient.java	39
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerInternalClient.java	11
internal-client/src/main/java/org/apache/uniffle/client/api/CoordinatorClient.java	26
internal-client/src/main/java/org/apache/uniffle/client/api/ClientInfo.java	26
internal-client/src/main/java/org/apache/uniffle/client/api/ShuffleServerClient.java	52
internal-client/src/main/java/org/apache/uniffle/client/response/RssFetchClientConfResponse.java	18
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/ClientResponse.java	20
internal-client/src/main/java/org/apache/uniffle/client/response/RssUnregisterShuffleResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssReassignOnStageRetryResponse.java	23
internal-client/src/main/java/org/apache/uniffle/client/response/RssAppHeartBeatResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendHeartBeatResponse.java	15
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleIndexResponse.java	19
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleDataResponse.java	19
internal-client/src/main/java/org/apache/uniffle/client/response/RssReassignOnBlockSendFailureResponse.java	19
internal-client/src/main/java/org/apache/uniffle/client/response/RssAccessClusterResponse.java	15
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetSortedShuffleDataResponse.java	36
internal-client/src/main/java/org/apache/uniffle/client/response/RssFinishShuffleResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssStartSortMergeResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendShuffleDataResponse.java	30
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleAssignmentsResponse.java	29
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleFetchFailureResponse.java	29
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetShuffleResultResponse.java	38
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleResultResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssRegisterShuffleResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/response/RssFetchRemoteStorageResponse.java	13
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleReadMetricResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleWriteMetricResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssReportShuffleWriteFailureResponse.java	29
internal-client/src/main/java/org/apache/uniffle/client/response/RssDecommissionResponse.java	12
internal-client/src/main/java/org/apache/uniffle/client/response/RssSendCommitResponse.java	14
internal-client/src/main/java/org/apache/uniffle/client/response/RssGetInMemoryShuffleDataResponse.java	28
internal-client/src/main/java/org/apache/uniffle/client/response/RssUnregisterShuffleByAppIdResponse.java	7
internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleManagerClientFactory.java	20
internal-client/src/main/java/org/apache/uniffle/client/factory/CoordinatorClientFactory.java	78
internal-client/src/main/java/org/apache/uniffle/client/factory/ShuffleServerClientFactory.java	52
internal-client/src/main/java/org/apache/uniffle/client/request/RssReassignOnBlockSendFailureRequest.java	47
internal-client/src/main/java/org/apache/uniffle/client/request/RetryableRequest.java	12
internal-client/src/main/java/org/apache/uniffle/client/request/RssUnregisterShuffleRequest.java	20
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleResultForMultiPartRequest.java	45
internal-client/src/main/java/org/apache/uniffle/client/request/RssCancelDecommissionRequest.java	2
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleFetchFailureRequest.java	30
internal-client/src/main/java/org/apache/uniffle/client/request/RssApplicationInfoRequest.java	20
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleReadMetricRequest.java	96
internal-client/src/main/java/org/apache/uniffle/client/request/RssPartitionToShuffleServerRequest.java	30
internal-client/src/main/java/org/apache/uniffle/client/request/RssAccessClusterRequest.java	61
internal-client/src/main/java/org/apache/uniffle/client/request/RssAppHeartBeatRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssDecommissionRequest.java	2
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleAssignmentsRequest.java	137
internal-client/src/main/java/org/apache/uniffle/client/request/RssFetchRemoteStorageRequest.java	10
internal-client/src/main/java/org/apache/uniffle/client/request/RssFetchClientConfRequest.java	36
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleWriteFailureRequest.java	51
internal-client/src/main/java/org/apache/uniffle/client/request/RssFinishShuffleRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetSortedShuffleDataRequest.java	37
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendShuffleDataRequest.java	45
internal-client/src/main/java/org/apache/uniffle/client/request/RssUnregisterShuffleByAppIdRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssRegisterShuffleRequest.java	130
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleIndexRequest.java	49
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendCommitRequest.java	15
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleWriteMetricRequest.java	51
internal-client/src/main/java/org/apache/uniffle/client/request/RssSendHeartBeatRequest.java	108
internal-client/src/main/java/org/apache/uniffle/client/request/RssStartSortMergeRequest.java	27
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleResultRequest.java	44
internal-client/src/main/java/org/apache/uniffle/client/request/RssReportShuffleResultRequest.java	62
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetShuffleDataRequest.java	86
internal-client/src/main/java/org/apache/uniffle/client/request/RssGetInMemoryShuffleDataRequest.java	61
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcRetryableClient.java	261
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcClient.java	1243
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/CoordinatorGrpcClient.java	379
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerGrpcNettyClient.java	488
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleManagerGrpcClient.java	144
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/GrpcClient.java	60
internal-client/src/main/java/org/apache/uniffle/client/impl/grpc/ShuffleServerInternalGrpcClient.java	50
client-spark/spark2/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java	191
client-spark/spark2/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java	354
client-spark/spark2/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java	252
client-spark/spark2/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java	510
client-spark/spark2/src/main/java/org/apache/spark/network/util/NettyUtils.java	88
client-spark/spark3/src/main/java/org/apache/spark/shuffle/Spark3VersionUtils.java	8
client-spark/spark3/src/main/java/org/apache/spark/shuffle/FunctionUtils.java	18
client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleDriverComponents.java	15
client-spark/spark3/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManager.java	269
client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleManager.java	589
client-spark/spark3/src/main/java/org/apache/spark/shuffle/reader/RssShuffleReader.java	332
client-spark/spark3/src/main/java/org/apache/spark/shuffle/writer/RssShuffleWriter.java	914
client-spark/spark3/src/main/java/org/apache/spark/shuffle/RssShuffleDataIo.java	20
client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkConfig.java	427
client-spark/common/src/main/java/org/apache/spark/shuffle/RssSparkShuffleUtils.java	325
client-spark/common/src/main/java/org/apache/spark/shuffle/RssStageResubmitManager.java	21
client-spark/common/src/main/java/org/apache/spark/shuffle/RssStageInfo.java	21
client-spark/common/src/main/java/org/apache/spark/shuffle/ShuffleHandleInfoManager.java	28
client-spark/common/src/main/java/org/apache/spark/shuffle/SparkVersionUtils.java	30
client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssShuffleDataIterator.java	174
client-spark/common/src/main/java/org/apache/spark/shuffle/reader/RssFetchFailedIterator.java	93
client-spark/common/src/main/java/org/apache/spark/shuffle/RssShuffleHandle.java	45
client-spark/common/src/main/java/org/apache/spark/shuffle/DelegationRssShuffleManagerUtils.java	19
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriterBuffer.java	87
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/BlockSuccessCallback.java	5
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/WriteBufferManager.java	592
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/BlockFailureCallback.java	5
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/TaskAttemptAssignment.java	35
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/AddBlockEvent.java	47
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/BufferManagerOptions.java	107
client-spark/common/src/main/java/org/apache/spark/shuffle/writer/DataPusher.java	144
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/SimpleShuffleHandleInfo.java	49
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/ShuffleHandleInfoBase.java	17
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/MutableShuffleHandleInfo.java	315
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/ShuffleHandleInfo.java	17
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/split/PartitionSplitInfo.java	32
client-spark/common/src/main/java/org/apache/spark/shuffle/handle/StageAttemptShuffleHandleInfo.java	103
client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleAssignmentInfoEvent.java	16
client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleWriteMetric.java	6
client-spark/common/src/main/java/org/apache/spark/shuffle/events/TaskShuffleWriteInfoEvent.java	27
client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleReadMetric.java	44
client-spark/common/src/main/java/org/apache/spark/shuffle/events/ShuffleMetric.java	15
client-spark/common/src/main/java/org/apache/spark/shuffle/events/TaskShuffleReadInfoEvent.java	27
client-spark/common/src/main/java/org/apache/spark/shuffle/events/UniffleEvent.java	7
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerBase.java	1314
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/RssShuffleManagerInterface.java	27
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerGrpcService.java	677
client-spark/common/src/main/java/org/apache/uniffle/shuffle/manager/ShuffleManagerServerFactory.java	39
client-spark/common/src/main/java/org/apache/uniffle/shuffle/BlockIdSelfManagedShuffleWriteClient.java	99
client-spark/common/src/main/java/org/apache/uniffle/shuffle/BlockIdManager.java	45
client-spark/common/src/main/java/org/apache/uniffle/shuffle/RssShuffleClientFactory.java	44
client-spark/extension/src/main/scala/org/apache/spark/ui/ShufflePage.scala	299
client-spark/extension/src/main/scala/org/apache/spark/ui/ShuffleTab.scala	12
client-spark/extension/src/main/scala/org/apache/spark/UniffleStatusStore.scala	99
client-spark/extension/src/main/scala/org/apache/spark/UniffleListener.scala	102
client-spark/extension/src/main/scala/org/apache/spark/UnifflePlugin.scala	38
client-spark/extension/src/main/scala/org/apache/spark/UniffleHistoryServerPlugin.scala	16
dev/local_dev_template/log4j2.xml	54
spotbugs-exclude.xml	9
server/src/main/java/org/apache/uniffle/server/Checker.java	7
server/src/main/java/org/apache/uniffle/server/ShuffleServer.java	559
server/src/main/java/org/apache/uniffle/server/flush/EventInvalidException.java	15
server/src/main/java/org/apache/uniffle/server/flush/EventRetryException.java	15
server/src/main/java/org/apache/uniffle/server/flush/EventDiscardException.java	15
server/src/main/java/org/apache/uniffle/server/ShuffleServerMetrics.java	480
server/src/main/java/org/apache/uniffle/server/ShuffleServerFactory.java	31
server/src/main/java/org/apache/uniffle/server/ShuffleServerNettyMetrics.java	89
server/src/main/java/org/apache/uniffle/server/ShuffleSpecification.java	32
server/src/main/java/org/apache/uniffle/server/ShuffleServerInternalGrpcService.java	62
server/src/main/java/org/apache/uniffle/server/netty/ShuffleServerNettyHandler.java	963
server/src/main/java/org/apache/uniffle/server/netty/StreamServerMetricHandler.java	27
server/src/main/java/org/apache/uniffle/server/netty/StreamServer.java	187
server/src/main/java/org/apache/uniffle/server/DefaultFlushEventHandler.java	239
server/src/main/java/org/apache/uniffle/server/HealthCheck.java	77
server/src/main/java/org/apache/uniffle/server/ShuffleDataReadEvent.java	35
server/src/main/java/org/apache/uniffle/server/HugePartitionUtils.java	76
server/src/main/java/org/apache/uniffle/server/merge/Partition.java	434
server/src/main/java/org/apache/uniffle/server/merge/ShuffleMergeManager.java	268
server/src/main/java/org/apache/uniffle/server/merge/MergeStatus.java	16
server/src/main/java/org/apache/uniffle/server/merge/MergeEventHandler.java	6
server/src/main/java/org/apache/uniffle/server/merge/BlockFlushFileReader.java	402
server/src/main/java/org/apache/uniffle/server/merge/MergeEvent.java	60
server/src/main/java/org/apache/uniffle/server/merge/MergedResult.java	116
server/src/main/java/org/apache/uniffle/server/merge/Shuffle.java	82
server/src/main/java/org/apache/uniffle/server/merge/DefaultMergeEventHandler.java	82
server/src/main/java/org/apache/uniffle/server/LocalStorageChecker.java	284
server/src/main/java/org/apache/uniffle/server/RegisterHeartBeat.java	82
server/src/main/java/org/apache/uniffle/server/event/ShufflePurgeEvent.java	11
server/src/main/java/org/apache/uniffle/server/event/AppPurgeEvent.java	18
server/src/main/java/org/apache/uniffle/server/event/AppUnregisterPurgeEvent.java	6
server/src/main/java/org/apache/uniffle/server/event/PurgeEvent.java	46
server/src/main/java/org/apache/uniffle/server/ShuffleServerConf.java	686
server/src/main/java/org/apache/uniffle/server/audit/ServerRpcAuditContext.java	22
server/src/main/java/org/apache/uniffle/server/block/PartitionedShuffleBlockIdManager.java	130
server/src/main/java/org/apache/uniffle/server/block/ShuffleBlockIdManager.java	29
server/src/main/java/org/apache/uniffle/server/block/DefaultShuffleBlockIdManager.java	177
server/src/main/java/org/apache/uniffle/server/block/ShuffleBlockIdManagerFactory.java	24
server/src/main/java/org/apache/uniffle/server/ShuffleTaskInfo.java	283
server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcService.java	1719
server/src/main/java/org/apache/uniffle/server/FlushEventHandler.java	6
server/src/main/java/org/apache/uniffle/server/ShuffleDataFlushEvent.java	176
server/src/main/java/org/apache/uniffle/server/ShuffleServerGrpcMetrics.java	165
server/src/main/java/org/apache/uniffle/server/buffer/AbstractShuffleBuffer.java	149
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithSkipList.java	243
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBuffer.java	36
server/src/main/java/org/apache/uniffle/server/buffer/RequireBufferStatusCode.java	12
server/src/main/java/org/apache/uniffle/server/buffer/PreAllocatedBufferInfo.java	25
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferWithLinkedList.java	240
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferType.java	5
server/src/main/java/org/apache/uniffle/server/buffer/ShuffleBufferManager.java	765
server/src/main/java/org/apache/uniffle/server/TopNShuffleDataSizeOfAppCalcTask.java	111
server/src/main/java/org/apache/uniffle/server/HealthScriptChecker.java	72
server/src/main/java/org/apache/uniffle/server/ShuffleTaskManager.java	957
server/src/main/java/org/apache/uniffle/server/storage/MultiPartLocalStorageManager.java	82
server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManagerFallbackStrategy.java	22
server/src/main/java/org/apache/uniffle/server/storage/RotateStorageManagerFallbackStrategy.java	20
server/src/main/java/org/apache/uniffle/server/storage/SingleStorageManager.java	132
server/src/main/java/org/apache/uniffle/server/storage/StorageManager.java	29
server/src/main/java/org/apache/uniffle/server/storage/StorageManagerFactory.java	24
server/src/main/java/org/apache/uniffle/server/storage/HybridStorageManager.java	135
server/src/main/java/org/apache/uniffle/server/storage/HadoopStorageManager.java	189
server/src/main/java/org/apache/uniffle/server/storage/StorageMediaFromEnvProvider.java	52
server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManager.java	416
server/src/main/java/org/apache/uniffle/server/storage/AbstractStorageManagerFallbackStrategy.java	45
server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManagerFallbackStrategy.java	22
server/src/main/java/org/apache/uniffle/server/storage/hybrid/DefaultStorageManagerSelector.java	25
server/src/main/java/org/apache/uniffle/server/storage/hybrid/FallbackBasedStorageManagerSelector.java	31
server/src/main/java/org/apache/uniffle/server/storage/hybrid/StorageManagerSelector.java	10
server/src/main/java/org/apache/uniffle/server/storage/hybrid/HugePartitionSensitiveStorageManagerSelector.java	23
server/src/main/java/org/apache/uniffle/server/storage/LocalStorageManagerFactory.java	26
server/src/main/java/org/apache/uniffle/server/web/vo/ServerConfVO.java	9
server/src/main/java/org/apache/uniffle/server/web/resource/ServerResource.java	61
server/src/main/java/org/apache/uniffle/server/ShuffleFlushManager.java	264
server/src/main/java/org/apache/uniffle/server/ShuffleDetailInfo.java	50
cli/src/main/java/org/apache/uniffle/api/AdminRestApi.java	115
cli/src/main/java/org/apache/uniffle/AbstractCustomCommandLine.java	81
cli/src/main/java/org/apache/uniffle/client/UniffleRestClient.java	62
cli/src/main/java/org/apache/uniffle/client/exception/UniffleRestException.java	6
cli/src/main/java/org/apache/uniffle/client/RestClient.java	6
cli/src/main/java/org/apache/uniffle/client/HttpClientFactory.java	36
cli/src/main/java/org/apache/uniffle/client/RestClientConf.java	31
cli/src/main/java/org/apache/uniffle/client/RestClientImpl.java	119
cli/src/main/java/org/apache/uniffle/entity/ApplicationResponse.java	26
cli/src/main/java/org/apache/uniffle/cli/UniffleAdminCLI.java	84
cli/src/main/java/org/apache/uniffle/cli/UniffleCLI.java	248
cli/src/main/java/org/apache/uniffle/cli/CLIContentUtils.java	160
cli/src/main/java/org/apache/uniffle/UniffleCliArgsException.java	10
cli/src/main/java/org/apache/uniffle/CustomCommandLine.java	6
coordinator/src/main/java/org/apache/uniffle/coordinator/ClusterManager.java	22
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/AbstractRssClientConfApplyStrategy.java	9
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/BypassRssClientConfApplyStrategy.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/YamlClientConfParser.java	51
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/ClientConfParser.java	10
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/ClientConf.java	18
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/LegacyClientConfParser.java	72
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/RssClientConfFetchInfo.java	25
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/RssClientConfApplyManager.java	33
coordinator/src/main/java/org/apache/uniffle/coordinator/conf/DynamicClientConfService.java	131
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorFactory.java	24
coordinator/src/main/java/org/apache/uniffle/coordinator/AppInfo.java	69
coordinator/src/main/java/org/apache/uniffle/coordinator/AccessManager.java	77
coordinator/src/main/java/org/apache/uniffle/coordinator/QuotaManager.java	151
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorConf.java	241
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorGrpcService.java	497
coordinator/src/main/java/org/apache/uniffle/coordinator/ClusterManagerFactory.java	13
coordinator/src/main/java/org/apache/uniffle/coordinator/util/CoordinatorUtils.java	156
coordinator/src/main/java/org/apache/uniffle/coordinator/access/AccessInfo.java	49
coordinator/src/main/java/org/apache/uniffle/coordinator/access/AccessCheckResult.java	25
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessCandidatesChecker.java	135
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessClusterLoadChecker.java	87
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AbstractAccessChecker.java	7
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessQuotaChecker.java	51
coordinator/src/main/java/org/apache/uniffle/coordinator/access/checker/AccessChecker.java	8
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AssignmentStrategyFactory.java	25
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AssignmentStrategy.java	19
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionBalanceAssignmentStrategy.java	154
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/PartitionRangeAssignment.java	58
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/BasicAssignmentStrategy.java	72
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/assignment/AbstractAssignmentStrategy.java	73
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/PreferDiffHostAssignmentStrategy.java	28
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/HostAssignmentStrategy.java	6
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/BasicHostAssignmentStrategy.java	9
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/host/MustDiffHostAssignmentStrategy.java	24
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/SelectStorageStrategy.java	6
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AppBalanceSelectStorageStrategy.java	49
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/RankValue.java	48
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/AbstractSelectStorageStrategy.java	149
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/storage/LowestIOSampleCostSelectStorageStrategy.java	53
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/SelectPartitionStrategy.java	13
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/RoundSelectPartitionStrategy.java	32
coordinator/src/main/java/org/apache/uniffle/coordinator/strategy/partition/ContinuousSelectPartitionStrategy.java	36
coordinator/src/main/java/org/apache/uniffle/coordinator/CoordinatorServer.java	235
coordinator/src/main/java/org/apache/uniffle/coordinator/ServerNode.java	341
coordinator/src/main/java/org/apache/uniffle/coordinator/audit/CoordinatorRpcAuditContext.java	17
coordinator/src/main/java/org/apache/uniffle/coordinator/SimpleClusterManager.java	429
coordinator/src/main/java/org/apache/uniffle/coordinator/web/vo/CoordinatorConfVO.java	9
coordinator/src/main/java/org/apache/uniffle/coordinator/web/vo/AppInfoVO.java	26
coordinator/src/main/java/org/apache/uniffle/coordinator/web/vo/UserAppNumVO.java	13
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/CoordinatorServerResource.java	89
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/APIResource.java	24
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ServerResource.java	217
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/AdminResource.java	36
coordinator/src/main/java/org/apache/uniffle/coordinator/web/resource/ApplicationResource.java	117
coordinator/src/main/java/org/apache/uniffle/coordinator/web/request/DecommissionRequest.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/web/request/ApplicationRequest.java	51
coordinator/src/main/java/org/apache/uniffle/coordinator/web/request/CancelDecommissionRequest.java	11
coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorMetrics.java	97
coordinator/src/main/java/org/apache/uniffle/coordinator/metric/CoordinatorGrpcMetrics.java	28
coordinator/src/main/java/org/apache/uniffle/coordinator/ApplicationManager.java	421
storage/src/main/java/org/apache/uniffle/storage/handler/api/ClientReadHandler.java	9
storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleWriteHandler.java	6
storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleDeleteHandler.java	4
storage/src/main/java/org/apache/uniffle/storage/handler/api/ShuffleWriteHandlerWrapper.java	15
storage/src/main/java/org/apache/uniffle/storage/handler/api/ServerReadHandler.java	8
storage/src/main/java/org/apache/uniffle/storage/handler/AsynDeletionEvent.java	54
storage/src/main/java/org/apache/uniffle/storage/handler/ClientReadHandlerMetric.java	72
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleDeleteHandler.java	96
storage/src/main/java/org/apache/uniffle/storage/handler/impl/MemoryClientReadHandler.java	105
storage/src/main/java/org/apache/uniffle/storage/handler/impl/ComposedClientReadHandler.java	167
storage/src/main/java/org/apache/uniffle/storage/handler/impl/ShuffleServerReadCostTracker.java	24
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileNioWriter.java	58
storage/src/main/java/org/apache/uniffle/storage/handler/impl/AsynDeletionEventManager.java	76
storage/src/main/java/org/apache/uniffle/storage/handler/impl/PrefetchableClientReadHandler.java	122
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileAsyncDeleteHandler.java	69
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileClientReadHandler.java	175
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileServerReadHandler.java	143
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileNullDeviceWriter.java	14
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileReader.java	119
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriterFactory.java	21
storage/src/main/java/org/apache/uniffle/storage/handler/impl/CompositeLocalFileServerReadHandler.java	49
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriteHandler.java	142
storage/src/main/java/org/apache/uniffle/storage/handler/impl/PooledHadoopShuffleWriteHandler.java	99
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileDeleteHandler.java	32
storage/src/main/java/org/apache/uniffle/storage/handler/impl/FileSegment.java	20
storage/src/main/java/org/apache/uniffle/storage/handler/impl/ShuffleServerReadCost.java	69
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileReader.java	84
storage/src/main/java/org/apache/uniffle/storage/handler/impl/AbstractClientReadHandler.java	62
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileWriter.java	52
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopFileWriter.java	107
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopClientReadHandler.java	219
storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataFileSegment.java	22
storage/src/main/java/org/apache/uniffle/storage/handler/impl/LocalFileBlackHoleWriter.java	28
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleWriteHandler.java	192
storage/src/main/java/org/apache/uniffle/storage/handler/impl/HadoopShuffleReadHandler.java	198
storage/src/main/java/org/apache/uniffle/storage/handler/impl/DataSkippableReadHandler.java	77
storage/src/main/java/org/apache/uniffle/storage/handler/impl/MultiReplicaClientReadHandler.java	86
storage/src/main/java/org/apache/uniffle/storage/api/FileWriter.java	11
storage/src/main/java/org/apache/uniffle/storage/api/FileReader.java	8
storage/src/main/java/org/apache/uniffle/storage/common/LocalStorage.java	275
storage/src/main/java/org/apache/uniffle/storage/common/LocalStorageMeta.java	95
storage/src/main/java/org/apache/uniffle/storage/common/Storage.java	19
storage/src/main/java/org/apache/uniffle/storage/common/ShuffleSegment.java	2
storage/src/main/java/org/apache/uniffle/storage/common/ShuffleInfo.java	15
storage/src/main/java/org/apache/uniffle/storage/common/DefaultStorageMediaProvider.java	92
storage/src/main/java/org/apache/uniffle/storage/common/CompositeReadingViewStorage.java	57
storage/src/main/java/org/apache/uniffle/storage/common/AbstractStorage.java	75
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/common/ShuffleFileInfo.java	69
storage/src/main/java/org/apache/uniffle/storage/common/FileBasedShuffleSegment.java	95
storage/src/main/java/org/apache/uniffle/storage/common/StorageMediaProvider.java	7
storage/src/main/java/org/apache/uniffle/storage/common/HadoopStorage.java	90
storage/src/main/java/org/apache/uniffle/storage/util/ShuffleStorageUtils.java	185
storage/src/main/java/org/apache/uniffle/storage/util/StorageType.java	29
storage/src/main/java/org/apache/uniffle/storage/factory/ShuffleHandlerFactory.java	173
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleDeleteHandlerRequest.java	38
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleReadHandlerRequest.java	195
storage/src/main/java/org/apache/uniffle/storage/request/CreateShuffleWriteHandlerRequest.java	109
proto/src/main/proto/Rss.proto	652
client-mr/hadoop3.2/src/main/java/org/apache/uniffle/hadoop/shim/HadoopShimImpl.java	28
client-mr/core/src/main/java/org/apache/hadoop/mapred/RssCombineOutputCollector.java	11
client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBufferManager.java	435
client-mr/core/src/main/java/org/apache/hadoop/mapred/RssMapOutputCollector.java	211
client-mr/core/src/main/java/org/apache/hadoop/mapred/SortWriteBuffer.java	362
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/v2/app/RssMRAppMaster.java	490
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRUtils.java	301
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/RssMRConfig.java	177
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RMRssShuffle.java	207
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/MRMetricsReporter.java	13
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssEventFetcher.java	131
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssBypassWriter.java	36
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssRemoteMergeManagerImpl.java	253
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssFetcher.java	249
client-mr/core/src/main/java/org/apache/hadoop/mapreduce/task/reduce/RssShuffle.java	249
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/MRIdHelper.java	8
client-mr/core/src/main/java/org/apache/uniffle/client/shuffle/MRCombiner.java	54
client-mr/core/src/main/java/org/apache/uniffle/client/shuffle/RecordCollector.java	288
client-mr/hadoop2.8/src/main/java/org/apache/uniffle/hadoop/shim/HadoopShimImpl.java	40