org.apache.beam.sdk.io.gcp.bigtable.changestreams.encoder

Class MetadataTableEncoder

java.lang.Object

org.apache.beam.sdk.io.gcp.bigtable.changestreams.encoder.MetadataTableEncoder

@Internal
public class MetadataTableEncoder
extends java.lang.Object

Helper methods that simplifies some conversion and extraction of metadata table content.

Constructor Summary

Constructors

Constructor and Description
MetadataTableEncoder()

Method Summary

Modifier and Type	Method and Description
static @Nullable java.lang.String	getTokenFromRow(com.google.cloud.bigtable.data.v2.models.Row row) Read the continuation token cell of a row from ReadRows.
static @Nullable Instant	parseWatermarkFromRow(com.google.cloud.bigtable.data.v2.models.Row row) Read the watermark cell of a row from ReadRows.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataTableEncoder

public MetadataTableEncoder()

Method Detail

parseWatermarkFromRow

public static @Nullable Instant parseWatermarkFromRow(com.google.cloud.bigtable.data.v2.models.Row row)

Read the watermark cell of a row from ReadRows.

Parameters:

row - row to extract the watermark from

Returns:

the watermark of the row

getTokenFromRow

public static @Nullable java.lang.String getTokenFromRow(com.google.cloud.bigtable.data.v2.models.Row row)

Read the continuation token cell of a row from ReadRows.

Parameters:

row - to extract the token from

Returns:

the token of the row