Path	Lines of Code
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGate.java	132
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java	71
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartition.java	175
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java	133
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java	82
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/FlinkResultPartitionInfo.java	51
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java	131
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleDescriptor.java	56
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	197
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateDelegation.java	455
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java	280
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java	226
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResource.java	41
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionDelegation.java	261
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResource.java	5
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceDescriptor.java	37
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleResourceTracker.java	159
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/ShuffleTaskInfo.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/Buffer.java	19
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferHeader.java	46
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java	291
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferRecycler.java	5
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferWithSubpartition.java	17
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/CreditListener.java	21
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/DataBuffer.java	20
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java	44
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/ReceivedNoHeaderBufferPacker.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBasedDataBuffer.java	273
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java	156
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/CelebornBufferStream.java	288
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/client/FlinkShuffleClientImpl.java	618
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ForceFallbackPolicy.java	25
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/QuotaFallbackPolicy.java	29
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicy.java	10
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyFactory.java	21
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/ShuffleFallbackPolicyRunner.java	31
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/fallback/WorkersAvailableFallbackPolicy.java	27
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RemoteShuffleMetricFactory.java	41
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/metric/RequestedMemoryUsageMetric.java	18
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/netty/NettyShuffleEnvironmentWrapper.java	63
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java	40
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java	73
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java	136
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java	228
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/ReadData.java	51
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/protocol/SubPartitionReadData.java	49
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java	105
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java	53
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/Utils.java	35
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	134
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	43
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.16/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	134
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	137
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.18/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	32
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	60
client-flink/flink-1.19/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	39
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	33
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	64
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	37
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java	123
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java	269
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java	464
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java	83
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java	172
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java	386
client-flink/flink-1.20/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java	41
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	135
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	33
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	47
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	64
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	37
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferManager.java	123
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornChannelBufferReader.java	269
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierConsumerAgent.java	464
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierFactory.java	90
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierMasterAgent.java	172
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/CelebornTierProducerAgent.java	386
client-flink/flink-2.0/src/main/java/org/apache/celeborn/plugin/flink/tiered/TierShuffleDescriptorImpl.java	41