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

Interface HsSubpartitionFileReader.Factory

All Known Implementing Classes:

HsSubpartitionFileReaderImpl.Factory

Enclosing interface:

HsSubpartitionFileReader

public static interface HsSubpartitionFileReader.Factory

Factory to create HsSubpartitionFileReader.

Method Summary

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

Method Detail

createFileReader

HsSubpartitionFileReader createFileReader(int subpartitionId,
                                          HsConsumerId consumerId,
                                          FileChannel dataFileChannel,
                                          HsSubpartitionConsumerInternalOperations operation,
                                          HsFileDataIndex dataIndex,
                                          int maxBuffersReadAhead,
                                          java.util.function.Consumer<HsSubpartitionFileReader> fileReaderReleaser,
                                          ByteBuffer headerBuffer)