The Write API can be used to write data to BigQuery. + * + *
For supplementary information about the Write API, see: + * https://cloud.google.com/bigquery/docs/write-api + * + *
This class provides the ability to make remote calls to the backing service through method + * calls that map to API methods. Sample code to get started: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * TableName parent = TableName.of("[PROJECT]", "[DATASET]", "[TABLE]");
+ * WriteStream writeStream = WriteStream.newBuilder().build();
+ * WriteStream response = bigQueryWriteClient.createWriteStream(parent, writeStream);
+ * }
+ * }
+ *
+ * Note: close() needs to be called on the BigQueryWriteClient object to clean up resources such + * as threads. In the example above, try-with-resources is used, which automatically calls close(). + * + *
The surface of this class includes several types of Java methods for each of the API's + * methods: + * + *
See the individual methods for example code. + * + *
Many parameters require resource names to be formatted in a particular way. To assist with + * these names, this class includes a format method for each type of name, and additionally a parse + * method to extract the individual identifiers contained within names that are returned. + * + *
This class can be customized by passing in a custom instance of BigQueryWriteSettings to + * create(). For example: + * + *
To customize credentials: + * + *
{@code
+ * BigQueryWriteSettings bigQueryWriteSettings =
+ * BigQueryWriteSettings.newBuilder()
+ * .setCredentialsProvider(FixedCredentialsProvider.create(myCredentials))
+ * .build();
+ * BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create(bigQueryWriteSettings);
+ * }
+ *
+ * To customize the endpoint: + * + *
{@code
+ * BigQueryWriteSettings bigQueryWriteSettings =
+ * BigQueryWriteSettings.newBuilder().setEndpoint(myEndpoint).build();
+ * BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create(bigQueryWriteSettings);
+ * }
+ *
+ * Please refer to the GitHub repository's samples for more quickstart code snippets. + */ +@Generated("by gapic-generator-java") +public class BigQueryWriteClient implements BackgroundResource { + private final BigQueryWriteSettings settings; + private final BigQueryWriteStub stub; + + /** Constructs an instance of BigQueryWriteClient with default settings. */ + public static final BigQueryWriteClient create() throws IOException { + return create(BigQueryWriteSettings.newBuilder().build()); + } + + /** + * Constructs an instance of BigQueryWriteClient, using the given settings. The channels are + * created based on the settings passed in, or defaults for any settings that are not set. + */ + public static final BigQueryWriteClient create(BigQueryWriteSettings settings) + throws IOException { + return new BigQueryWriteClient(settings); + } + + /** + * Constructs an instance of BigQueryWriteClient, using the given stub for making calls. This is + * for advanced usage - prefer using create(BigQueryWriteSettings). + */ + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + public static final BigQueryWriteClient create(BigQueryWriteStub stub) { + return new BigQueryWriteClient(stub); + } + + /** + * Constructs an instance of BigQueryWriteClient, using the given settings. This is protected so + * that it is easy to make a subclass, but otherwise, the static factory methods should be + * preferred. + */ + protected BigQueryWriteClient(BigQueryWriteSettings settings) throws IOException { + this.settings = settings; + this.stub = ((BigQueryWriteStubSettings) settings.getStubSettings()).createStub(); + } + + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + protected BigQueryWriteClient(BigQueryWriteStub stub) { + this.settings = null; + this.stub = stub; + } + + public final BigQueryWriteSettings getSettings() { + return settings; + } + + @BetaApi("A restructuring of stub classes is planned, so this may break in the future") + public BigQueryWriteStub getStub() { + return stub; + } + + // AUTO-GENERATED DOCUMENTATION AND METHOD. + /** + * Creates a write stream to the given table. Additionally, every table has a special stream named + * '_default' to which data can be written. This stream doesn't need to be created using + * CreateWriteStream. It is a stream that can be used simultaneously by any number of clients. + * Data written to this stream is considered committed as soon as an acknowledgement is received. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * TableName parent = TableName.of("[PROJECT]", "[DATASET]", "[TABLE]");
+ * WriteStream writeStream = WriteStream.newBuilder().build();
+ * WriteStream response = bigQueryWriteClient.createWriteStream(parent, writeStream);
+ * }
+ * }
+ *
+ * @param parent Required. Reference to the table to which the stream belongs, in the format of
+ * `projects/{project}/datasets/{dataset}/tables/{table}`.
+ * @param writeStream Required. Stream to be created.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream createWriteStream(TableName parent, WriteStream writeStream) {
+ CreateWriteStreamRequest request =
+ CreateWriteStreamRequest.newBuilder()
+ .setParent(parent == null ? null : parent.toString())
+ .setWriteStream(writeStream)
+ .build();
+ return createWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a write stream to the given table. Additionally, every table has a special stream named
+ * '_default' to which data can be written. This stream doesn't need to be created using
+ * CreateWriteStream. It is a stream that can be used simultaneously by any number of clients.
+ * Data written to this stream is considered committed as soon as an acknowledgement is received.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * String parent = TableName.of("[PROJECT]", "[DATASET]", "[TABLE]").toString();
+ * WriteStream writeStream = WriteStream.newBuilder().build();
+ * WriteStream response = bigQueryWriteClient.createWriteStream(parent, writeStream);
+ * }
+ * }
+ *
+ * @param parent Required. Reference to the table to which the stream belongs, in the format of
+ * `projects/{project}/datasets/{dataset}/tables/{table}`.
+ * @param writeStream Required. Stream to be created.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream createWriteStream(String parent, WriteStream writeStream) {
+ CreateWriteStreamRequest request =
+ CreateWriteStreamRequest.newBuilder().setParent(parent).setWriteStream(writeStream).build();
+ return createWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a write stream to the given table. Additionally, every table has a special stream named
+ * '_default' to which data can be written. This stream doesn't need to be created using
+ * CreateWriteStream. It is a stream that can be used simultaneously by any number of clients.
+ * Data written to this stream is considered committed as soon as an acknowledgement is received.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * CreateWriteStreamRequest request =
+ * CreateWriteStreamRequest.newBuilder()
+ * .setParent(TableName.of("[PROJECT]", "[DATASET]", "[TABLE]").toString())
+ * .setWriteStream(WriteStream.newBuilder().build())
+ * .build();
+ * WriteStream response = bigQueryWriteClient.createWriteStream(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream createWriteStream(CreateWriteStreamRequest request) {
+ return createWriteStreamCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Creates a write stream to the given table. Additionally, every table has a special stream named
+ * '_default' to which data can be written. This stream doesn't need to be created using
+ * CreateWriteStream. It is a stream that can be used simultaneously by any number of clients.
+ * Data written to this stream is considered committed as soon as an acknowledgement is received.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * CreateWriteStreamRequest request =
+ * CreateWriteStreamRequest.newBuilder()
+ * .setParent(TableName.of("[PROJECT]", "[DATASET]", "[TABLE]").toString())
+ * .setWriteStream(WriteStream.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * bigQueryWriteClient.createWriteStreamCallable().futureCall(request);
+ * // Do something.
+ * WriteStream response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableIf `offset` is specified, the `offset` is checked against the end of stream. The server + * returns `OUT_OF_RANGE` in `AppendRowsResponse` if an attempt is made to append to an offset + * beyond the current end of the stream or `ALREADY_EXISTS` if user provides an `offset` that has + * already been written to. User can retry with adjusted offset within the same RPC connection. If + * `offset` is not specified, append happens at the end of the stream. + * + *
The response contains an optional offset at which the append happened. No offset information + * will be returned for appends to a default stream. + * + *
Responses are received in the same order in which requests are sent. There will be one + * response for each successful inserted request. Responses may optionally embed error information + * if the originating AppendRequest was not successfully processed. + * + *
The specifics of when successfully appended data is made visible to the table are governed + * by the type of stream: + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * BidiStream bidiStream =
+ * bigQueryWriteClient.appendRowsCallable().call();
+ * AppendRowsRequest request =
+ * AppendRowsRequest.newBuilder()
+ * .setWriteStream(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .setOffset(Int64Value.newBuilder().build())
+ * .setTraceId("traceId-1067401920")
+ * .build();
+ * bidiStream.send(request);
+ * for (AppendRowsResponse response : bidiStream) {
+ * // Do something when a response is received.
+ * }
+ * }
+ * }
+ */
+ public final BidiStreamingCallableSample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * WriteStreamName name = WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]");
+ * WriteStream response = bigQueryWriteClient.getWriteStream(name);
+ * }
+ * }
+ *
+ * @param name Required. Name of the stream to get, in the form of
+ * `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream getWriteStream(WriteStreamName name) {
+ GetWriteStreamRequest request =
+ GetWriteStreamRequest.newBuilder().setName(name == null ? null : name.toString()).build();
+ return getWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a write stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * String name = WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString();
+ * WriteStream response = bigQueryWriteClient.getWriteStream(name);
+ * }
+ * }
+ *
+ * @param name Required. Name of the stream to get, in the form of
+ * `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream getWriteStream(String name) {
+ GetWriteStreamRequest request = GetWriteStreamRequest.newBuilder().setName(name).build();
+ return getWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a write stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * GetWriteStreamRequest request =
+ * GetWriteStreamRequest.newBuilder()
+ * .setName(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .build();
+ * WriteStream response = bigQueryWriteClient.getWriteStream(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final WriteStream getWriteStream(GetWriteStreamRequest request) {
+ return getWriteStreamCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Gets information about a write stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * GetWriteStreamRequest request =
+ * GetWriteStreamRequest.newBuilder()
+ * .setName(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .build();
+ * ApiFuture future =
+ * bigQueryWriteClient.getWriteStreamCallable().futureCall(request);
+ * // Do something.
+ * WriteStream response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableSample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * WriteStreamName name = WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]");
+ * FinalizeWriteStreamResponse response = bigQueryWriteClient.finalizeWriteStream(name);
+ * }
+ * }
+ *
+ * @param name Required. Name of the stream to finalize, in the form of
+ * `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FinalizeWriteStreamResponse finalizeWriteStream(WriteStreamName name) {
+ FinalizeWriteStreamRequest request =
+ FinalizeWriteStreamRequest.newBuilder()
+ .setName(name == null ? null : name.toString())
+ .build();
+ return finalizeWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Finalize a write stream so that no new data can be appended to the stream. Finalize is not
+ * supported on the '_default' stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * String name = WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString();
+ * FinalizeWriteStreamResponse response = bigQueryWriteClient.finalizeWriteStream(name);
+ * }
+ * }
+ *
+ * @param name Required. Name of the stream to finalize, in the form of
+ * `projects/{project}/datasets/{dataset}/tables/{table}/streams/{stream}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FinalizeWriteStreamResponse finalizeWriteStream(String name) {
+ FinalizeWriteStreamRequest request =
+ FinalizeWriteStreamRequest.newBuilder().setName(name).build();
+ return finalizeWriteStream(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Finalize a write stream so that no new data can be appended to the stream. Finalize is not
+ * supported on the '_default' stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * FinalizeWriteStreamRequest request =
+ * FinalizeWriteStreamRequest.newBuilder()
+ * .setName(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .build();
+ * FinalizeWriteStreamResponse response = bigQueryWriteClient.finalizeWriteStream(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FinalizeWriteStreamResponse finalizeWriteStream(FinalizeWriteStreamRequest request) {
+ return finalizeWriteStreamCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Finalize a write stream so that no new data can be appended to the stream. Finalize is not
+ * supported on the '_default' stream.
+ *
+ * Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * FinalizeWriteStreamRequest request =
+ * FinalizeWriteStreamRequest.newBuilder()
+ * .setName(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .build();
+ * ApiFuture future =
+ * bigQueryWriteClient.finalizeWriteStreamCallable().futureCall(request);
+ * // Do something.
+ * FinalizeWriteStreamResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableStreams must be finalized before commit and cannot be committed multiple times. Once a + * stream is committed, data in the stream becomes available for read operations. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * String parent = "parent-995424086";
+ * BatchCommitWriteStreamsResponse response =
+ * bigQueryWriteClient.batchCommitWriteStreams(parent);
+ * }
+ * }
+ *
+ * @param parent Required. Parent table that all the streams should belong to, in the form of
+ * `projects/{project}/datasets/{dataset}/tables/{table}`.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final BatchCommitWriteStreamsResponse batchCommitWriteStreams(String parent) {
+ BatchCommitWriteStreamsRequest request =
+ BatchCommitWriteStreamsRequest.newBuilder().setParent(parent).build();
+ return batchCommitWriteStreams(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Atomically commits a group of `PENDING` streams that belong to the same `parent` table.
+ *
+ * Streams must be finalized before commit and cannot be committed multiple times. Once a + * stream is committed, data in the stream becomes available for read operations. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * BatchCommitWriteStreamsRequest request =
+ * BatchCommitWriteStreamsRequest.newBuilder()
+ * .setParent("parent-995424086")
+ * .addAllWriteStreams(new ArrayList())
+ * .build();
+ * BatchCommitWriteStreamsResponse response =
+ * bigQueryWriteClient.batchCommitWriteStreams(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final BatchCommitWriteStreamsResponse batchCommitWriteStreams(
+ BatchCommitWriteStreamsRequest request) {
+ return batchCommitWriteStreamsCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Atomically commits a group of `PENDING` streams that belong to the same `parent` table.
+ *
+ * Streams must be finalized before commit and cannot be committed multiple times. Once a + * stream is committed, data in the stream becomes available for read operations. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * BatchCommitWriteStreamsRequest request =
+ * BatchCommitWriteStreamsRequest.newBuilder()
+ * .setParent("parent-995424086")
+ * .addAllWriteStreams(new ArrayList())
+ * .build();
+ * ApiFuture future =
+ * bigQueryWriteClient.batchCommitWriteStreamsCallable().futureCall(request);
+ * // Do something.
+ * BatchCommitWriteStreamsResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableIf users are appending rows to BUFFERED stream, flush operation is required in order for the + * rows to become available for reading. A Flush operation flushes up to any previously flushed + * offset in a BUFFERED stream, to the offset specified in the request. + * + *
Flush is not supported on the _default stream, since it is not BUFFERED. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * WriteStreamName writeStream =
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]");
+ * FlushRowsResponse response = bigQueryWriteClient.flushRows(writeStream);
+ * }
+ * }
+ *
+ * @param writeStream Required. The stream that is the target of the flush operation.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FlushRowsResponse flushRows(WriteStreamName writeStream) {
+ FlushRowsRequest request =
+ FlushRowsRequest.newBuilder()
+ .setWriteStream(writeStream == null ? null : writeStream.toString())
+ .build();
+ return flushRows(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Flushes rows to a BUFFERED stream.
+ *
+ * If users are appending rows to BUFFERED stream, flush operation is required in order for the + * rows to become available for reading. A Flush operation flushes up to any previously flushed + * offset in a BUFFERED stream, to the offset specified in the request. + * + *
Flush is not supported on the _default stream, since it is not BUFFERED. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * String writeStream =
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString();
+ * FlushRowsResponse response = bigQueryWriteClient.flushRows(writeStream);
+ * }
+ * }
+ *
+ * @param writeStream Required. The stream that is the target of the flush operation.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FlushRowsResponse flushRows(String writeStream) {
+ FlushRowsRequest request = FlushRowsRequest.newBuilder().setWriteStream(writeStream).build();
+ return flushRows(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Flushes rows to a BUFFERED stream.
+ *
+ * If users are appending rows to BUFFERED stream, flush operation is required in order for the + * rows to become available for reading. A Flush operation flushes up to any previously flushed + * offset in a BUFFERED stream, to the offset specified in the request. + * + *
Flush is not supported on the _default stream, since it is not BUFFERED. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * FlushRowsRequest request =
+ * FlushRowsRequest.newBuilder()
+ * .setWriteStream(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .setOffset(Int64Value.newBuilder().build())
+ * .build();
+ * FlushRowsResponse response = bigQueryWriteClient.flushRows(request);
+ * }
+ * }
+ *
+ * @param request The request object containing all of the parameters for the API call.
+ * @throws com.google.api.gax.rpc.ApiException if the remote call fails
+ */
+ public final FlushRowsResponse flushRows(FlushRowsRequest request) {
+ return flushRowsCallable().call(request);
+ }
+
+ // AUTO-GENERATED DOCUMENTATION AND METHOD.
+ /**
+ * Flushes rows to a BUFFERED stream.
+ *
+ * If users are appending rows to BUFFERED stream, flush operation is required in order for the + * rows to become available for reading. A Flush operation flushes up to any previously flushed + * offset in a BUFFERED stream, to the offset specified in the request. + * + *
Flush is not supported on the _default stream, since it is not BUFFERED. + * + *
Sample code: + * + *
{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * FlushRowsRequest request =
+ * FlushRowsRequest.newBuilder()
+ * .setWriteStream(
+ * WriteStreamName.of("[PROJECT]", "[DATASET]", "[TABLE]", "[STREAM]").toString())
+ * .setOffset(Int64Value.newBuilder().build())
+ * .build();
+ * ApiFuture future =
+ * bigQueryWriteClient.flushRowsCallable().futureCall(request);
+ * // Do something.
+ * FlushRowsResponse response = future.get();
+ * }
+ * }
+ */
+ public final UnaryCallableThe default instance has everything set to sensible defaults: + * + *
The builder of this class is recursive, so contained classes are themselves builders. When + * build() is called, the tree of builders is called to create the complete settings object. + * + *
For example, to set the total timeout of createWriteStream to 30 seconds: + * + *
{@code
+ * BigQueryWriteSettings.Builder bigQueryWriteSettingsBuilder = BigQueryWriteSettings.newBuilder();
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .setRetrySettings(
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * BigQueryWriteSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class BigQueryWriteSettings extends ClientSettingsNote: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction ======================= BigQueryWriteClient =======================
+ *
+ * Service Description: BigQuery Write API.
+ *
+ * The Write API can be used to write data to BigQuery.
+ *
+ * For supplementary information about the Write API, see:
+ * https://cloud.google.com/bigquery/docs/write-api
+ *
+ * Sample for BigQueryWriteClient:
+ *
+ * The default instance has everything set to sensible defaults:
+ *
+ * The builder of this class is recursive, so contained classes are themselves builders. When
+ * build() is called, the tree of builders is called to create the complete settings object.
+ *
+ * For example, to set the total timeout of createWriteStream to 30 seconds:
+ *
+ * Note: This method does not support applying settings to streaming methods.
+ */
+ public Builder applyToAllUnaryMethods(
+ ApiFunction This class is for advanced usage.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcBigQueryWriteCallableFactory implements GrpcStubCallableFactory {
+
+ @Override
+ public This class is for advanced usage and reflects the underlying API directly.
+ */
+@Generated("by gapic-generator-java")
+public class GrpcBigQueryWriteStub extends BigQueryWriteStub {
+ private static final MethodDescriptor{@code
+ * try (BigQueryWriteClient bigQueryWriteClient = BigQueryWriteClient.create()) {
+ * TableName parent = TableName.of("[PROJECT]", "[DATASET]", "[TABLE]");
+ * WriteStream writeStream = WriteStream.newBuilder().build();
+ * WriteStream response = bigQueryWriteClient.createWriteStream(parent, writeStream);
+ * }
+ * }
*/
@Generated("by gapic-generator-java")
package com.google.cloud.bigquery.storage.v1;
diff --git a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
index 751a07b377..8ca93bf54e 100644
--- a/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
+++ b/google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1/stub/BigQueryReadStubSettings.java
@@ -215,11 +215,6 @@ public static class Builder extends StubSettings.Builder
+ *
+ *
+ * {@code
+ * BigQueryWriteStubSettings.Builder bigQueryWriteSettingsBuilder =
+ * BigQueryWriteStubSettings.newBuilder();
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .setRetrySettings(
+ * bigQueryWriteSettingsBuilder
+ * .createWriteStreamSettings()
+ * .getRetrySettings()
+ * .toBuilder()
+ * .setTotalTimeout(Duration.ofSeconds(30))
+ * .build());
+ * BigQueryWriteStubSettings bigQueryWriteSettings = bigQueryWriteSettingsBuilder.build();
+ * }
+ */
+@Generated("by gapic-generator-java")
+public class BigQueryWriteStubSettings extends StubSettings