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

Packages that use HsSubpartitionConsumerInternalOperations

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

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

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

Modifier and Type	Class	Description
class	HsSubpartitionConsumer	The read view of HsResultPartition, data can be read from memory or disk.

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

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)
HsDataView	HsFileDataManager.registerNewConsumer(int subpartitionId, HsConsumerId consumerId, HsSubpartitionConsumerInternalOperations operation)	This method only called by result partition to create subpartitionFileReader.
HsDataView	HsMemoryDataManager.registerNewConsumer(int subpartitionId, HsConsumerId consumerId, HsSubpartitionConsumerInternalOperations viewOperations)	Register HsSubpartitionConsumerInternalOperations to HsMemoryDataManager.subpartitionViewOperationsMap.

Constructors in org.apache.flink.runtime.io.network.partition.hybrid with parameters of type HsSubpartitionConsumerInternalOperations

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