Package org.apache.flink.runtime.state.heap

Class AbstractHeapPriorityQueueElement

java.lang.Object

org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueueElement

All Implemented Interfaces:

HeapPriorityQueueElement

Direct Known Subclasses:

ForStDBCachingPriorityQueueSet, RocksDBCachingPriorityQueueSet, SourceCoordinator.WatermarkElement

public abstract class AbstractHeapPriorityQueueElement
extends Object
implements HeapPriorityQueueElement

Abstract base class for HeapPriorityQueueElement.

Field Summary

Fields inherited from interface org.apache.flink.runtime.state.heap.HeapPriorityQueueElement

NOT_CONTAINED

Constructor Summary

Constructors

Constructor	Description
AbstractHeapPriorityQueueElement()

Method Summary

Modifier and Type	Method	Description
int	getInternalIndex()	Returns the current index of this object in the internal array of HeapPriorityQueue.
void	setInternalIndex(int newIndex)	Sets the current index of this object in the HeapPriorityQueue and should only be called by the owning HeapPriorityQueue.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractHeapPriorityQueueElement

public AbstractHeapPriorityQueueElement()

Method Detail

getInternalIndex

public int getInternalIndex()

Description copied from interface: HeapPriorityQueueElement

Returns the current index of this object in the internal array of HeapPriorityQueue.

Specified by:

getInternalIndex in interface HeapPriorityQueueElement

setInternalIndex

public void setInternalIndex(int newIndex)

Description copied from interface: HeapPriorityQueueElement

Sets the current index of this object in the HeapPriorityQueue and should only be called by the owning HeapPriorityQueue.

Specified by:

setInternalIndex in interface HeapPriorityQueueElement

Parameters:

newIndex - the new index in the timer heap.