Class | Description |
---|---|
ComparableWatermarkSelector |
Base class for
WatermarkSelector s that evaluate Comparable
objects. |
FirstItemWatermarkSelector |
Implementation of
WatermarkSelector that selects the first value of the
set. |
LastItemWatermarkSelector |
Implementation of
WatermarkSelector that selects the last value of the
set. |
MaxValueWatermarkSelector |
Implementation of
WatermarkSelector that selectes the maximum value of the
set. |
MinValueWatermarkSelector |
Implementation of
WatermarkSelector that selectes the minimum value of the
set. |
SelectorWatermark |
Implementation of
Watermark that relies on a WatermarkSelector to
update its values |
SelectorWatermarkPollingInterceptor |
Implementation of
WatermarkPollingInterceptor that uses
a WatermarkSelector to return the new watermark value. |
WatermarkSelector |
A watermark selector receives values and selects which one should be the new
watermark value
|
WatermarkSelectorWrapper |
Enum | Description |
---|---|
WatermarkSelectorBroker |
Broker for the default implementations of
WatermarkSelector |
Copyright © 2003–2016 MuleSoft, Inc.. All rights reserved.