@InternalApi(value="Intended for use by the BigtableIO in apache/beam only.") public abstract class Heartbeat extends Object implements ChangeStreamRecord, Serializable
ReadChangeStreamResponse.Heartbeat.| Constructor and Description |
|---|
Heartbeat() |
| Modifier and Type | Method and Description |
|---|---|
abstract ChangeStreamContinuationToken |
getChangeStreamContinuationToken() |
org.threeten.bp.Instant |
getEstimatedLowWatermark()
This method is obsolete.
|
abstract Instant |
getEstimatedLowWatermarkTime() |
@InternalApi(value="Intended for use by the BigtableIO in apache/beam only.") public abstract ChangeStreamContinuationToken getChangeStreamContinuationToken()
@ObsoleteApi(value="Use getEstimatedLowWatermarkTime() instead") public org.threeten.bp.Instant getEstimatedLowWatermark()
getEstimatedLowWatermarkTime() instead.@InternalApi(value="Intended for use by the BigtableIO in apache/beam only.") public abstract Instant getEstimatedLowWatermarkTime()
Copyright © 2026 Google LLC. All rights reserved.