public class PartitionMetadataMapper extends java.lang.Object
public PartitionMetadata from(Struct row)
Structrepresenting a partition metadata row into a
Structis expected to have the following fields:
Stringrepresenting the partition unique identifier.
Stringrepresenting the partition parents' unique identifiers.
Timestamprepresenting the start time at which the partition started existing in Cloud Spanner.
Timestamprepresenting the end time for querying this partition.
Longrepresenting the number of milliseconds after the stream is idle, which a heartbeat record will be emitted.
PartitionMetadata.Statein which the partition is in.
Timestamprepresenting the time for which all records with a timestamp less than it have been processed.
Timestamprepresenting the time at which this partition was first detected.
Timestamprepresenting the time at which this partition was scheduled to be queried.
Timestamprepresenting the time at which the connector started processing this partition.
Timestamprepresenting the time at which the connector finished processing this partition.