com.google.cloud.bigtable.data.v2.stub.sql

Class MetadataErrorHandlingCallable

java.lang.Object

com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow>

com.google.cloud.bigtable.data.v2.stub.sql.MetadataErrorHandlingCallable

@InternalApi(value="For internal use only")
public class MetadataErrorHandlingCallable
extends com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow>

Callable that handles passing execeptions through to the metadata future. This needs to be used after all retries, so that non-retriable errors don't surface as errors to users accessing the metadata.

In non-error cases the metadata future is resolved by the PlanRefreshingCallable because the metadata needs to resolve before the SqlRowMerger starts yielding rows

This is considered an internal implementation detail and should not be used by applications.

Constructor Summary

Constructors

Constructor and Description
MetadataErrorHandlingCallable(com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow> inner)

Method Summary

Modifier and Type	Method and Description
void	call(ExecuteQueryCallContext request, com.google.api.gax.rpc.ResponseObserver<com.google.cloud.bigtable.data.v2.internal.SqlRow> responseObserver, com.google.api.gax.rpc.ApiCallContext context)

Methods inherited from class com.google.api.gax.rpc.ServerStreamingCallable

all, blockingServerStreamingCall, blockingServerStreamingCall, call, call, call, first, serverStreamingCall, serverStreamingCall, withDefaultCallContext

Methods inherited from class java.lang.Object

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

Constructor Detail

MetadataErrorHandlingCallable

public MetadataErrorHandlingCallable(com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow> inner)

Method Detail

call

public void call(ExecuteQueryCallContext request,
                 com.google.api.gax.rpc.ResponseObserver<com.google.cloud.bigtable.data.v2.internal.SqlRow> responseObserver,
                 com.google.api.gax.rpc.ApiCallContext context)

Specified by:

call in class com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow>