HsSubpartitionConsumerInternalOperations (Flink : Runtime 1.19.3-cp2 API)

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

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.