org.apache.flink.runtime.source.coordinator

Class SourceCoordinator.WatermarkElement

java.lang.Object

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

org.apache.flink.runtime.source.coordinator.SourceCoordinator.WatermarkElement

All Implemented Interfaces:

HeapPriorityQueueElement, PriorityComparable<SourceCoordinator.WatermarkElement>

Enclosing class:

SourceCoordinator<SplitT extends SourceSplit,EnumChkT>

public static class SourceCoordinator.WatermarkElement
extends AbstractHeapPriorityQueueElement
implements PriorityComparable<SourceCoordinator.WatermarkElement>

The watermark element for HeapPriorityQueue.

Field Summary

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

NOT_CONTAINED

Constructor Summary

Constructors

Constructor and Description
WatermarkElement(Watermark watermark)

Method Summary

Modifier and Type	Method and Description
int	comparePriorityTo(SourceCoordinator.WatermarkElement other)
boolean	equals(Object o)
int	hashCode()

Methods inherited from class org.apache.flink.runtime.state.heap.AbstractHeapPriorityQueueElement

getInternalIndex, setInternalIndex

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkElement

public WatermarkElement(Watermark watermark)

Method Detail

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

comparePriorityTo

public int comparePriorityTo(@Nonnull
                             SourceCoordinator.WatermarkElement other)

Specified by:

comparePriorityTo in interface PriorityComparable<SourceCoordinator.WatermarkElement>

See Also:

PriorityComparator.comparePriority(Object, Object).