Package | Description |
---|---|
org.nuxeo.ecm.platform.importer.mqueues.computation | |
org.nuxeo.ecm.platform.importer.mqueues.computation.internals | |
org.nuxeo.ecm.platform.importer.mqueues.computation.mqueue |
Computation pattern with an implementation using MQueue.
|
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.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 | 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 |
MQComputationRunner.getLowWatermark() |
Copyright © 2017 Nuxeo. All rights reserved.