public class MaxValueWatermarkSelector extends ComparableWatermarkSelector
WatermarkSelector
that selectes the maximum value of the
set. For this to work, received values need to implement the Comparable
interface. Values that don't meet this condition will be discardedvalue
Constructor and Description |
---|
MaxValueWatermarkSelector() |
Modifier and Type | Method and Description |
---|---|
protected int |
comparableQualifier()
Returns an int value according to the
Comparable contract (-1, 0, 1). |
acceptValue
getSelectedValue, reset
protected int comparableQualifier()
ComparableWatermarkSelector
Comparable
contract (-1, 0, 1).
Then the result of the comparation matches this method's return value, then
the selected value is updatedcomparableQualifier
in class ComparableWatermarkSelector
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.