Path	Lines of Code
common/src/main/java-templates/org/apache/uniffle/common/ProjectConstants.java	12
common/src/main/java/io/netty/util/CompositeFileRegion.java	106
common/src/main/java/org/apache/uniffle/common/Application.java	131
common/src/main/java/org/apache/uniffle/common/Arguments.java	11
common/src/main/java/org/apache/uniffle/common/AuditType.java	12
common/src/main/java/org/apache/uniffle/common/BlockCompletionCallback.java	4
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/PartitionInfo.java	38
common/src/main/java/org/apache/uniffle/common/PartitionRange.java	45
common/src/main/java/org/apache/uniffle/common/PartitionSplitMode.java	5
common/src/main/java/org/apache/uniffle/common/ReceivingFailureServer.java	58
common/src/main/java/org/apache/uniffle/common/ReconfigurableConfManager.java	165
common/src/main/java/org/apache/uniffle/common/ReconfigurableRegistry.java	90
common/src/main/java/org/apache/uniffle/common/RemoteStorageInfo.java	108
common/src/main/java/org/apache/uniffle/common/ServerStatus.java	34
common/src/main/java/org/apache/uniffle/common/ShuffleAssignmentsInfo.java	19
common/src/main/java/org/apache/uniffle/common/ShuffleBlockInfo.java	139
common/src/main/java/org/apache/uniffle/common/ShuffleDataDistributionType.java	5
common/src/main/java/org/apache/uniffle/common/ShuffleDataResult.java	76
common/src/main/java/org/apache/uniffle/common/ShuffleDataSegment.java	27
common/src/main/java/org/apache/uniffle/common/ShuffleIndexResult.java	85
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedBlock.java	108
common/src/main/java/org/apache/uniffle/common/ShufflePartitionedData.java	54
common/src/main/java/org/apache/uniffle/common/ShuffleRegisterInfo.java	36
common/src/main/java/org/apache/uniffle/common/ShuffleServerInfo.java	110
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/audit/RpcAuditContext.java	80
common/src/main/java/org/apache/uniffle/common/compression/Codec.java	35
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	91
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	169
common/src/main/java/org/apache/uniffle/common/config/FallbackKey.java	25
common/src/main/java/org/apache/uniffle/common/config/RssBaseConf.java	301
common/src/main/java/org/apache/uniffle/common/config/RssClientConf.java	289
common/src/main/java/org/apache/uniffle/common/config/RssConf.java	307
common/src/main/java/org/apache/uniffle/common/exception/ExceedHugePartitionHardLimitException.java	12
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/NoBufferException.java	12
common/src/main/java/org/apache/uniffle/common/exception/NoBufferForHugePartitionException.java	12
common/src/main/java/org/apache/uniffle/common/exception/NoRegisterException.java	12
common/src/main/java/org/apache/uniffle/common/exception/NotRetryException.java	12
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/exception/RssSendFailedException.java	12
common/src/main/java/org/apache/uniffle/common/exception/RssWaitFailedException.java	12
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/filesystem/HadoopFilesystemProvider.java	40
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/future/CompletableFutureExtension.java	58
common/src/main/java/org/apache/uniffle/common/future/CompletableFutureUtils.java	48
common/src/main/java/org/apache/uniffle/common/merger/KeyValueIterator.java	8
common/src/main/java/org/apache/uniffle/common/merger/MergeState.java	14
common/src/main/java/org/apache/uniffle/common/merger/Merger.java	188
common/src/main/java/org/apache/uniffle/common/merger/Segment.java	17
common/src/main/java/org/apache/uniffle/common/merger/StreamedSegment.java	47
common/src/main/java/org/apache/uniffle/common/metrics/AbstractMetricReporter.java	18
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/GRPCMetrics.java	64
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	120
common/src/main/java/org/apache/uniffle/common/metrics/NettyMetrics.java	40
common/src/main/java/org/apache/uniffle/common/metrics/RPCMetrics.java	148
common/src/main/java/org/apache/uniffle/common/metrics/SupplierGauge.java	65
common/src/main/java/org/apache/uniffle/common/metrics/prometheus/PrometheusPushGatewayMetricReporter.java	120
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	58
common/src/main/java/org/apache/uniffle/common/netty/TransportFrameDecoder.java	142
common/src/main/java/org/apache/uniffle/common/netty/buffer/FileSegmentManagedBuffer.java	95
common/src/main/java/org/apache/uniffle/common/netty/buffer/ManagedBuffer.java	11
common/src/main/java/org/apache/uniffle/common/netty/buffer/MultiFileSegmentManagedBuffer.java	54
common/src/main/java/org/apache/uniffle/common/netty/buffer/NettyManagedBuffer.java	38
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	202
common/src/main/java/org/apache/uniffle/common/netty/client/TransportConf.java	43
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	34
common/src/main/java/org/apache/uniffle/common/netty/handle/TransportResponseHandler.java	88
common/src/main/java/org/apache/uniffle/common/netty/protocol/AbstractFileRegion.java	29
common/src/main/java/org/apache/uniffle/common/netty/protocol/Decoders.java	99
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	133
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataResponse.java	28
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleDataV2Request.java	68
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetLocalShuffleIndexRequest.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/GetLocalShuffleIndexV2Response.java	87
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataRequest.java	122
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetMemoryShuffleDataResponse.java	71
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetSortedShuffleDataRequest.java	79
common/src/main/java/org/apache/uniffle/common/netty/protocol/GetSortedShuffleDataResponse.java	65
common/src/main/java/org/apache/uniffle/common/netty/protocol/Message.java	154
common/src/main/java/org/apache/uniffle/common/netty/protocol/MessageWithHeader.java	120
common/src/main/java/org/apache/uniffle/common/netty/protocol/RequestMessage.java	17
common/src/main/java/org/apache/uniffle/common/netty/protocol/ResponseMessage.java	13
common/src/main/java/org/apache/uniffle/common/netty/protocol/RpcResponse.java	70
common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequest.java	141
common/src/main/java/org/apache/uniffle/common/netty/protocol/SendShuffleDataRequestV1.java	108
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/rpc/ClientContextServerInterceptor.java	31
common/src/main/java/org/apache/uniffle/common/rpc/GrpcServer.java	211
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	43
common/src/main/java/org/apache/uniffle/common/security/HadoopSecurityContext.java	106
common/src/main/java/org/apache/uniffle/common/security/NoOpSecurityContext.java	16
common/src/main/java/org/apache/uniffle/common/security/SecurityConfig.java	57
common/src/main/java/org/apache/uniffle/common/security/SecurityContext.java	7
common/src/main/java/org/apache/uniffle/common/security/SecurityContextFactory.java	34
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/LocalOrderSegmentSplitter.java	16
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/serializer/BufferSerInputStream.java	40
common/src/main/java/org/apache/uniffle/common/serializer/DeserializationStream.java	9
common/src/main/java/org/apache/uniffle/common/serializer/DynBufferSerOutputStream.java	36
common/src/main/java/org/apache/uniffle/common/serializer/FileSerInputStream.java	95
common/src/main/java/org/apache/uniffle/common/serializer/FileSerOutputStream.java	33
common/src/main/java/org/apache/uniffle/common/serializer/SerInputStream.java	31
common/src/main/java/org/apache/uniffle/common/serializer/SerOutputStream.java	12
common/src/main/java/org/apache/uniffle/common/serializer/SerializationStream.java	9
common/src/main/java/org/apache/uniffle/common/serializer/Serializer.java	5
common/src/main/java/org/apache/uniffle/common/serializer/SerializerFactory.java	42
common/src/main/java/org/apache/uniffle/common/serializer/SerializerInstance.java	12
common/src/main/java/org/apache/uniffle/common/serializer/WrappedByteArrayOutputStream.java	13
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/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/kryo/PoolWrapper.java	40
common/src/main/java/org/apache/uniffle/common/serializer/writable/BufferedRawWritableDeserializationStream.java	74
common/src/main/java/org/apache/uniffle/common/serializer/writable/BufferedRawWritableSerializationStream.java	53
common/src/main/java/org/apache/uniffle/common/serializer/writable/ComparativeOutputBuffer.java	20
common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableDeserializationStream.java	59
common/src/main/java/org/apache/uniffle/common/serializer/writable/RawWritableSerializationStream.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/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/WritableSerializerInstance.java	50
common/src/main/java/org/apache/uniffle/common/storage/ApplicationStorageInfo.java	30
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/storage/StorageMedia.java	47
common/src/main/java/org/apache/uniffle/common/storage/StorageStatus.java	45
common/src/main/java/org/apache/uniffle/common/util/BlockId.java	44
common/src/main/java/org/apache/uniffle/common/util/BlockIdLayout.java	147
common/src/main/java/org/apache/uniffle/common/util/ByteBufUtils.java	67
common/src/main/java/org/apache/uniffle/common/util/ByteBufferUtils.java	15
common/src/main/java/org/apache/uniffle/common/util/ByteUnit.java	56
common/src/main/java/org/apache/uniffle/common/util/ChecksumUtils.java	33
common/src/main/java/org/apache/uniffle/common/util/Constants.java	59
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/IdHelper.java	4
common/src/main/java/org/apache/uniffle/common/util/JavaUtils.java	58
common/src/main/java/org/apache/uniffle/common/util/JvmPauseMonitor.java	154
common/src/main/java/org/apache/uniffle/common/util/NettyUtils.java	129
common/src/main/java/org/apache/uniffle/common/util/OutputUtils.java	51
common/src/main/java/org/apache/uniffle/common/util/RetryUtils.java	86
common/src/main/java/org/apache/uniffle/common/util/RssUtils.java	373
common/src/main/java/org/apache/uniffle/common/util/StatefulCloseable.java	5
common/src/main/java/org/apache/uniffle/common/util/ThreadUtils.java	150
common/src/main/java/org/apache/uniffle/common/util/TripleFunction.java	5
common/src/main/java/org/apache/uniffle/common/util/UnitConverter.java	116
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	146
common/src/main/java/org/apache/uniffle/common/web/JsonConverter.java	61
common/src/main/java/org/apache/uniffle/common/web/resource/Authorization.java	10
common/src/main/java/org/apache/uniffle/common/web/resource/AuthorizationRequestFilter.java	33
common/src/main/java/org/apache/uniffle/common/web/resource/BaseMetricResource.java	18
common/src/main/java/org/apache/uniffle/common/web/resource/BaseResource.java	11
common/src/main/java/org/apache/uniffle/common/web/resource/ConfOpsResource.java	46
common/src/main/java/org/apache/uniffle/common/web/resource/ConfVO.java	24
common/src/main/java/org/apache/uniffle/common/web/resource/MetricResource.java	50
common/src/main/java/org/apache/uniffle/common/web/resource/PrometheusMetricResource.java	34
common/src/main/java/org/apache/uniffle/common/web/resource/Response.java	41