Package com.scaleoutsoftware.collections.timewindowing

Class LatenessToleranceWatermarkGenerator

java.lang.Object

com.scaleoutsoftware.collections.timewindowing.LatenessToleranceWatermarkGenerator

All Implemented Interfaces:

WatermarkGenerator

public class LatenessToleranceWatermarkGenerator
extends Object
implements WatermarkGenerator

The LatenessToleranceWatermarkGenerator generates watermarks with a constant lateness tolerance.

Constructor Summary

Constructors

Constructor	Description
LatenessToleranceWatermarkGenerator(long latenessToleranceMs)	Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance.
LatenessToleranceWatermarkGenerator(long latenessToleranceMs, long currentWaterMarkMs)	Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance and the current watermark in milliseconds.

Method Summary

Modifier and Type	Method	Description
long	generateWatermark(long lastEventTimestampMs)	Generates (or returns the existing) watermark based on the last seen event timestamp.

Methods inherited from class java.lang.Object

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

Constructor Details

LatenessToleranceWatermarkGenerator

public LatenessToleranceWatermarkGenerator(long latenessToleranceMs)

Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance.

Parameters:

latenessToleranceMs - the lateness tolerance in milliseconds.

LatenessToleranceWatermarkGenerator

public LatenessToleranceWatermarkGenerator(long latenessToleranceMs,
 long currentWaterMarkMs)

Constructs a new LatenessToleranceWatermarkGenerator with a constant lateness tolerance and the current watermark in milliseconds.

Parameters:

latenessToleranceMs - the lateness tolerance in milliseconds.

currentWaterMarkMs - the current watermark in milliseconds.

Method Details

generateWatermark

public long generateWatermark(long lastEventTimestampMs)

Generates (or returns the existing) watermark based on the last seen event timestamp.

Specified by:

generateWatermark in interface WatermarkGenerator

Parameters:

lastEventTimestampMs - the last seen event timestamp.

Returns:

the new or existing watermark for a windowing collection.