Package io.github.flink.gcp.connector.spanner.source

Interface SpannerReadOperationResolver

All Superinterfaces:
Serializable
@Internal public interface SpannerReadOperationResolver extends Serializable
Resolves a table-layer read after the batch transaction has selected its snapshot.

  • Method Summary

    Modifier and Type
    Method
    Description
    SpannerReadOperation
    resolve(com.google.cloud.spanner.DatabaseClient client, com.google.cloud.Timestamp readTimestamp)
    Resolves the concrete read operation at the batch transaction's exact snapshot.

  • Method Details

    • resolve

      SpannerReadOperation resolve(com.google.cloud.spanner.DatabaseClient client, com.google.cloud.Timestamp readTimestamp) throws IOException
      Resolves the concrete read operation at the batch transaction's exact snapshot.
      Parameters:
      client - a client for the source database
      readTimestamp - the batch transaction's read timestamp
      Returns:
      a concrete query or table read
      Throws:
      IOException - if metadata cannot be read or validated