org.apache.flink.runtime.io.network.partition

Class PartitionedFileReader

java.lang.Object

org.apache.flink.runtime.io.network.partition.PartitionedFileReader

All Implemented Interfaces:

AutoCloseable

public class PartitionedFileReader
extends Object
implements AutoCloseable

Reader which can read all data of the target subpartition from a PartitionedFile.

Constructor Summary

Constructors

Constructor and Description
PartitionedFileReader(PartitionedFile partitionedFile, int targetSubpartition)

Method Summary

Modifier and Type	Method and Description
void	close()
boolean	hasRemaining()
Buffer	readBuffer(MemorySegment target, BufferRecycler recycler) Reads a buffer from the PartitionedFile and moves the read position forward.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PartitionedFileReader

public PartitionedFileReader(PartitionedFile partitionedFile,
                             int targetSubpartition)
                      throws IOException

Throws:

IOException

Method Detail

readBuffer

@Nullable
public Buffer readBuffer(MemorySegment target,
                                   BufferRecycler recycler)
                            throws IOException

Reads a buffer from the PartitionedFile and moves the read position forward.

Note: The caller is responsible for recycling the target buffer if any exception occurs.

Throws:

IOException

hasRemaining

@VisibleForTesting
public boolean hasRemaining()
                                        throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException