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

Interface HsSubpartitionConsumerInternalOperations

All Known Implementing Classes:

HsSubpartitionConsumer

public interface HsSubpartitionConsumerInternalOperations

Operations provided by HsSubpartitionConsumer that are used by other internal components of hybrid result partition.

Method Summary

Modifier and Type	Method and Description
int	getConsumingOffset(boolean withLock) Get the latest consuming offset of the subpartition.
void	notifyDataAvailable() Callback for new data become available.

Method Detail

notifyDataAvailable

void notifyDataAvailable()

Callback for new data become available.

getConsumingOffset

int getConsumingOffset(boolean withLock)

Get the latest consuming offset of the subpartition.

Parameters:

withLock - If true, read the consuming offset outside the guarding of lock. This is sometimes desired to avoid lock contention, if the caller does not depend on any other states to change atomically with the consuming offset.

Returns:

latest consuming offset.