Uses of Interface
org.apache.flink.runtime.io.network.partition.hybrid.HsSubpartitionFileReader

Packages that use HsSubpartitionFileReader

Package	Description
org.apache.flink.runtime.io.network.partition.hybrid

Uses of HsSubpartitionFileReader in org.apache.flink.runtime.io.network.partition.hybrid

Classes in org.apache.flink.runtime.io.network.partition.hybrid that implement HsSubpartitionFileReader

Modifier and Type	Class	Description
class	HsSubpartitionFileReaderImpl	Default implementation of HsSubpartitionFileReader.

Methods in org.apache.flink.runtime.io.network.partition.hybrid that return HsSubpartitionFileReader

Modifier and Type	Method	Description
HsSubpartitionFileReader	HsSubpartitionFileReader.Factory.createFileReader(int subpartitionId, HsConsumerId consumerId, FileChannel dataFileChannel, HsSubpartitionConsumerInternalOperations operation, HsFileDataIndex dataIndex, int maxBuffersReadAhead, java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser, ByteBuffer headerBuffer)
HsSubpartitionFileReader	HsSubpartitionFileReaderImpl.Factory.createFileReader(int subpartitionId, HsConsumerId consumerId, FileChannel dataFileChannel, HsSubpartitionConsumerInternalOperations operation, HsFileDataIndex dataIndex, int maxBuffersReadAhead, java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser, ByteBuffer headerBuffer)

Methods in org.apache.flink.runtime.io.network.partition.hybrid with parameters of type HsSubpartitionFileReader

Modifier and Type	Method	Description
int	HsSubpartitionFileReaderImpl.compareTo(HsSubpartitionFileReader that)	Provides priority calculation logic for io scheduler.
void	HsFileDataManager.releaseSubpartitionReader(HsSubpartitionFileReader subpartitionFileReader)	Release specific HsSubpartitionFileReader from HsFileDataManager.

Method parameters in org.apache.flink.runtime.io.network.partition.hybrid with type arguments of type HsSubpartitionFileReader

Modifier and Type	Method	Description
HsSubpartitionFileReader	HsSubpartitionFileReader.Factory.createFileReader(int subpartitionId, HsConsumerId consumerId, FileChannel dataFileChannel, HsSubpartitionConsumerInternalOperations operation, HsFileDataIndex dataIndex, int maxBuffersReadAhead, java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser, ByteBuffer headerBuffer)
HsSubpartitionFileReader	HsSubpartitionFileReaderImpl.Factory.createFileReader(int subpartitionId, HsConsumerId consumerId, FileChannel dataFileChannel, HsSubpartitionConsumerInternalOperations operation, HsFileDataIndex dataIndex, int maxBuffersReadAhead, java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser, ByteBuffer headerBuffer)

Constructor parameters in org.apache.flink.runtime.io.network.partition.hybrid with type arguments of type HsSubpartitionFileReader

Constructor	Description
HsSubpartitionFileReaderImpl(int subpartitionId, HsConsumerId consumerId, FileChannel dataFileChannel, HsSubpartitionConsumerInternalOperations operations, HsFileDataIndex dataIndex, int maxBufferReadAhead, java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser, ByteBuffer headerBuf)