Package | Description |
---|---|
org.nuxeo.lib.stream.computation |
The Computation pattern with a Log implementation.
|
org.nuxeo.lib.stream.computation.internals | |
org.nuxeo.lib.stream.computation.log |
Computation pattern implemented with Log
|
Modifier and Type | Field and Description |
---|---|
static Watermark |
Watermark.LOWEST |
Modifier and Type | Method and Description |
---|---|
static Watermark |
Watermark.completedOf(Watermark watermark) |
static Watermark |
Watermark.ofNow() |
static Watermark |
Watermark.ofTimestamp(long timestamp) |
static Watermark |
Watermark.ofTimestamp(long timestamp,
short sequence) |
static Watermark |
Watermark.ofValue(long watermarkValue) |
Modifier and Type | Method and Description |
---|---|
int |
Watermark.compareTo(Watermark o) |
static Watermark |
Watermark.completedOf(Watermark watermark) |
Modifier and Type | Field and Description |
---|---|
protected Watermark |
WatermarkMonotonicInterval.high |
protected Watermark |
WatermarkMonotonicInterval.low |
protected Watermark |
WatermarkMonotonicInterval.lowest |
Modifier and Type | Method and Description |
---|---|
Watermark |
WatermarkMonotonicInterval.getHigh() |
Watermark |
WatermarkMonotonicInterval.getLow()
Returns the low mark.
|
Modifier and Type | Method and Description |
---|---|
long |
WatermarkMonotonicInterval.mark(Watermark watermark)
Take in account the watermark.
Not thread safe. |
Modifier and Type | Method and Description |
---|---|
Watermark |
ComputationRunner.getLowWatermark() |
Copyright © 2018 Nuxeo. All rights reserved.