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

Class SpannerReadOperationResolution

java.lang.Object

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

@Internal
public final class SpannerReadOperationResolution
extends Object

Internal bridge between a table-layer deferred read and the batch partition planner.

Method Summary

Modifier and Type	Method	Description
static SpannerReadOperation	deferred(SpannerReadOperationResolver resolver)	Creates a deferred operation without adding a table-only method to the public value type.
static SpannerReadOperation	resolve(SpannerReadOperation operation, com.google.cloud.spanner.DatabaseClient client, com.google.cloud.Timestamp readTimestamp)	Resolves the operation when necessary, otherwise returns it unchanged.

Methods inherited from class java.lang.Object

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

Method Details

deferred

public static SpannerReadOperation deferred(SpannerReadOperationResolver resolver)

Creates a deferred operation without adding a table-only method to the public value type.

resolve

public static SpannerReadOperation resolve(SpannerReadOperation operation,
 com.google.cloud.spanner.DatabaseClient client,
 com.google.cloud.Timestamp readTimestamp)
                                    throws IOException

Resolves the operation when necessary, otherwise returns it unchanged.

Throws:

IOException