public class EnhancedBigQueryStorageStub extends Object implements BackgroundResource
This class is for advanced usage and reflects the underlying API directly.
Modifier and Type | Method and Description |
---|---|
boolean |
awaitTermination(long duration,
TimeUnit unit) |
UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> |
batchCreateReadSessionStreamsCallable() |
void |
close() |
static EnhancedBigQueryStorageStub |
create(EnhancedBigQueryStorageStubSettings settings) |
UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> |
createReadSessionCallable() |
UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest,Empty> |
finalizeStreamCallable() |
boolean |
isShutdown() |
boolean |
isTerminated() |
ServerStreamingCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> |
readRowsCallable() |
void |
shutdown() |
void |
shutdownNow() |
UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> |
splitReadStreamCallable() |
public static EnhancedBigQueryStorageStub create(EnhancedBigQueryStorageStubSettings settings) throws IOException
IOException
public UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.CreateReadSessionRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadSession> createReadSessionCallable()
public ServerStreamingCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.ReadRowsResponse> readRowsCallable()
public UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.BatchCreateReadSessionStreamsResponse> batchCreateReadSessionStreamsCallable()
public UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.FinalizeStreamRequest,Empty> finalizeStreamCallable()
public UnaryCallable<com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamRequest,com.google.cloud.bigquery.storage.v1beta1.Storage.SplitReadStreamResponse> splitReadStreamCallable()
public void close()
close
in interface AutoCloseable
public void shutdown()
shutdown
in interface BackgroundResource
public boolean isShutdown()
isShutdown
in interface BackgroundResource
public boolean isTerminated()
isTerminated
in interface BackgroundResource
public void shutdownNow()
shutdownNow
in interface BackgroundResource
public boolean awaitTermination(long duration, TimeUnit unit) throws InterruptedException
awaitTermination
in interface BackgroundResource
InterruptedException
Copyright © 2019 Google LLC. All rights reserved.