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 and 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)