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

Class ExecuteQueryCallable

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.ExecuteQueryCallable

@InternalApi
public class ExecuteQueryCallable
extends com.google.api.gax.rpc.ServerStreamingCallable<ExecuteQueryCallContext,com.google.cloud.bigtable.data.v2.internal.SqlRow>

Callable that creates SqlServerStreams from ExecuteQueryRequests.

This handles setting up the future that is used to allow users to access metadata.

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
SqlServerStream	call(BoundStatement boundStatement) This should be used to create execute query calls.
void	call(ExecuteQueryCallContext callContext, com.google.api.gax.rpc.ResponseObserver<com.google.cloud.bigtable.data.v2.internal.SqlRow> responseObserver, com.google.api.gax.rpc.ApiCallContext apiCallContext)

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

ExecuteQueryCallable

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

Method Detail

call

public SqlServerStream call(BoundStatement boundStatement)

This should be used to create execute query calls. This replaces the typical API which allows passing of an ApiCallContext.

This class is considered an internal implementation detail and not meant to be used by applications. Users should only use executeQuery through the BigtableDataClient

call

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

Specified by:

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