Uses of Class
org.apache.flink.runtime.io.network.partition.hybrid.HsConsumerId

Packages that use HsConsumerId

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

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

Fields in org.apache.flink.runtime.io.network.partition.hybrid declared as HsConsumerId

Modifier and Type	Field	Description
static HsConsumerId	HsConsumerId.ANY	This consumer id is used in the scenarios that information related to specific consumer needs to be ignored.
static HsConsumerId	HsConsumerId.DEFAULT	This consumer id is used for the first consumer of a single subpartition.

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

Modifier and Type	Method	Description
static HsConsumerId	HsConsumerId.newId(HsConsumerId lastId)

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

Modifier and Type	Method	Description
void	HsBufferContext.consumed(HsConsumerId consumerId)
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)
static HsSpillingInfoProvider.ConsumeStatusWithId	HsSpillingInfoProvider.ConsumeStatusWithId.fromStatusAndConsumerId(HsSpillingInfoProvider.ConsumeStatus consumeStatus, HsConsumerId consumerId)
List<Integer>	HsMemoryDataManager.getNextBufferIndexToConsume(HsConsumerId consumerId)
List<Integer>	HsSpillingInfoProvider.getNextBufferIndexToConsume(HsConsumerId consumerId)	Get all subpartition's next buffer index to consume of specific consumer.
boolean	HsBufferContext.isConsumed(HsConsumerId consumerId)
static HsConsumerId	HsConsumerId.newId(HsConsumerId lastId)
void	HsMemoryDataManager.onConsumerReleased(int subpartitionId, HsConsumerId consumerId)
void	HsMemoryDataManagerOperation.onConsumerReleased(int subpartitionId, HsConsumerId consumerId)	This method is called when consumer is decided to released.
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.
HsSubpartitionConsumerMemoryDataManager	HsSubpartitionMemoryDataManager.registerNewConsumer(HsConsumerId consumerId)
void	HsSubpartitionMemoryDataManager.releaseConsumer(HsConsumerId consumerId)

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

Modifier and Type	Method	Description
void	HsMemoryDataManager.onDataAvailable(int subpartitionId, Collection<HsConsumerId> consumerIds)
void	HsMemoryDataManagerOperation.onDataAvailable(int subpartitionId, Collection<HsConsumerId> consumerIds)	This method is called when subpartition data become available.

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

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