public interface HsSubpartitionConsumerInternalOperations
HsSubpartitionConsumerthat are used by other internal components of hybrid result partition.
|Modifier and Type||Method and Description|
Get the latest consuming offset of the subpartition.
Callback for new data become available.
int getConsumingOffset(boolean withLock)
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.
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.