org.apache.beam.runners.spark.util

Class GlobalWatermarkHolder.SparkWatermarks

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

GlobalWatermarkHolder

public static class GlobalWatermarkHolder.SparkWatermarks
extends java.lang.Object
implements java.io.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 and Description
SparkWatermarks(Instant lowWatermark, Instant highWatermark, Instant synchronizedProcessingTime)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

SparkWatermarks

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

Method Detail

getLowWatermark

public Instant getLowWatermark()

getHighWatermark

public Instant getHighWatermark()

getSynchronizedProcessingTime

public Instant getSynchronizedProcessingTime()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object