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(org.joda.time.Instant lowWatermark, org.joda.time.Instant highWatermark, org.joda.time.Instant synchronizedProcessingTime)

Method Summary

Modifier and Type	Method	Description
org.joda.time.Instant	getHighWatermark()
org.joda.time.Instant	getLowWatermark()
org.joda.time.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(org.joda.time.Instant lowWatermark,
 org.joda.time.Instant highWatermark,
 org.joda.time.Instant synchronizedProcessingTime)

Method Details

getLowWatermark

public org.joda.time.Instant getLowWatermark()

getHighWatermark

public org.joda.time.Instant getHighWatermark()

getSynchronizedProcessingTime

public org.joda.time.Instant getSynchronizedProcessingTime()

toString

public String toString()

Overrides:

toString in class Object