Path	Lines of Code
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleEnvironment.java	132
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleInputGateFactory.java	78
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleResultPartitionFactory.java	145
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/AbstractRemoteShuffleServiceFactory.java	67
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/FlinkResultPartitionInfo.java	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteBufferStreamReader.java	118
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/RemoteShuffleInputGateDelegation.java	445
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleMaster.java	191
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleOutputGate.java	176
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/ResultPartitionAdapter.java	5
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	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/BufferPacker.java	254
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/CreditListener.java	21
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/FlinkNettyManagedBuffer.java	39
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/PartitionSortedBuffer.java	272
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/SortBuffer.java	32
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/buffer/TransferBufferPool.java	154
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/FlinkTransportClientFactory.java	59
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/MessageDecoderExt.java	65
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/ReadClientHandler.java	101
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/network/TransportFrameDecoderWithBufferSupplier.java	182
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/readclient/CelebornBufferStream.java	154
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/readclient/FlinkShuffleClientImpl.java	485
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/BufferUtils.java	80
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/FlinkUtils.java	49
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/ThreadUtils.java	26
client-flink/common/src/main/java/org/apache/celeborn/plugin/flink/utils/Utils.java	35
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	197
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	156
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	34
client-flink/flink-1.14/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	212
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	157
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	34
client-flink/flink-1.15/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleEnvironment.java	44
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGate.java	219
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleInputGateFactory.java	29
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartition.java	169
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleResultPartitionFactory.java	54
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/RemoteShuffleServiceFactory.java	38
client-flink/flink-1.17/src/main/java/org/apache/celeborn/plugin/flink/SimpleResultPartitionAdapter.java	8