Package org.apache.beam.runners.spark.util

Class GlobalWatermarkHolder.SparkWatermarks

java.lang.Object

org.apache.beam.runners.spark.util.GlobalWatermarkHolder.SparkWatermarks

All Implemented Interfaces:

Serializable

Enclosing class:

GlobalWatermarkHolder

public static class GlobalWatermarkHolder.SparkWatermarks
extends Object
implements Serializable

A GlobalWatermarkHolder.SparkWatermarks holds the watermarks and batch time relevant to a micro-batch input from a specific source.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
SparkWatermarks(Instant lowWatermark, Instant highWatermark, Instant synchronizedProcessingTime)

Method Summary

Modifier and Type	Method	Description
Instant	getHighWatermark()
Instant	getLowWatermark()
Instant	getSynchronizedProcessingTime()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

SparkWatermarks

public SparkWatermarks(Instant lowWatermark,
 Instant highWatermark,
 Instant synchronizedProcessingTime)

Method Details

getLowWatermark

public Instant getLowWatermark()

getHighWatermark

public Instant getHighWatermark()

getSynchronizedProcessingTime

public Instant getSynchronizedProcessingTime()

toString

public String toString()

Overrides:

toString in class Object