com.google.cloud.bigquery.storage.v1beta1.stub.readrows

Class ReadRowsResumptionStrategy

java.lang.Object

com.google.cloud.bigquery.storage.v1beta1.stub.readrows.ReadRowsResumptionStrategy

All Implemented Interfaces:

StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>

@InternalApi
public class ReadRowsResumptionStrategy
extends Object
implements StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>

An implementation of a StreamResumptionStrategy for the ReadRows API. This class tracks the offset of the last row received and, upon retry, attempts to resume the stream at the next offset.

This class is considered an internal implementation detail and not meant to be used by applications.

Constructor Summary

Constructors

Constructor and Description
ReadRowsResumptionStrategy()

Method Summary

Modifier and Type	Method and Description
boolean	canResume()
StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>	createNew()
com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest	getResumeRequest(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest originalRequest)
com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse	processResponse(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse response)

Methods inherited from class java.lang.Object

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

Constructor Detail

ReadRowsResumptionStrategy

public ReadRowsResumptionStrategy()

Method Detail

createNew

public StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> createNew()

Specified by:

createNew in interface StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>

processResponse

public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse processResponse(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse response)

Specified by:

processResponse in interface StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>

getResumeRequest

public com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest getResumeRequest(com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest originalRequest)

Given the initial/original request, this implementation generates a request that will yield a new stream whose first response would come right after the last response received by processResponse. It takes into account the offset from the original request.

Specified by:

getResumeRequest in interface StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>

canResume

public boolean canResume()

Specified by:

canResume in interface StreamResumptionStrategy<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse>