Class Heartbeat (2.79.0)

2.79.0 (latest) 2.78.1 2.77.0 2.74.0 2.73.0 2.72.0 2.71.0 2.70.0 2.68.0 2.67.1 2.66.0 2.65.1 2.63.0 2.62.0 2.61.0 2.60.0 2.59.0 2.58.2 2.56.0 2.54.0 2.52.0 2.51.2 2.49.0 2.46.0 2.45.1 2.44.1 2.43.0 2.42.0 2.40.0 2.39.5 2.37.0 2.35.1 2.34.0 2.33.0 2.32.0 2.31.0 2.30.0 2.29.1 2.28.0

public abstract class Heartbeat implements ChangeStreamRecord, Serializable

A simple wrapper for ReadChangeStreamResponse.Heartbeat.

Inheritance

java.lang.Object > Heartbeat

Implements

ChangeStreamRecord, Serializable

Inherited Members

Object.clone()

Object.equals(Object)

Object.finalize()

Object.getClass()

Object.hashCode()

Object.notify()

Object.notifyAll()

Object.toString()

Object.wait()

Object.wait(long)

Object.wait(long,int)

Constructors

Heartbeat()

public Heartbeat()

Methods

getChangeStreamContinuationToken()

public abstract ChangeStreamContinuationToken getChangeStreamContinuationToken()

Internal Only: This feature is not stable for application use.

Intended for use by the BigtableIO in apache/beam only.

Returns
Type	Description
ChangeStreamContinuationToken

getEstimatedLowWatermark()

public Instant getEstimatedLowWatermark()

Obsolete

Use getEstimatedLowWatermarkTime() instead

This feature is stable for usage in this major version, but may be deprecated in a future release.

This method is obsolete. Use #getEstimatedLowWatermarkTime() instead.

Returns
Type	Description
org.threeten.bp.Instant

getEstimatedLowWatermarkTime()

public abstract Instant getEstimatedLowWatermarkTime()

Internal Only: This feature is not stable for application use.

Intended for use by the BigtableIO in apache/beam only.

Returns
Type	Description
Instant