Skip to content
Permalink
Browse files
feat: create manual client for Write API (#112)
* First writeapi manual client

First version, test to be developed.

* Manual client with e2e

* StreamWriter library

* ProtoSchema convert library WriteApi client library addition. This library helps to convert a ProtoDescriptorProto out of ProtoDescriptor into a self contained ProtoDescriptorProto, that can be passed into API and reconstructed on the server side.

	modified:   google-cloud-bigquerystorage/pom.xml
	new file:   google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/ProtoSchemaConverter.java
	new file:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/ProtoSchemaConverterTest.java
	new file:   google-cloud-bigquerystorage/src/test/proto/test.proto
	modified:   pom.xml

* First writeapi manual client

First version, test to be developed.

* .

* incremental development

* .
	modified:   google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/StreamWriter.java
	modified:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/FakeBigQueryWriteImpl.java
	modified:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/FakeScheduledExecutorService.java
	modified:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/StreamWriterTest.java
	modified:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/it/ITBigQueryWriteManualClientTest.java

* .

* .

* .

* feat: create manual java client for writeapi

	modified:   google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/StreamWriter.java

* feat: add integration test final verification.

* .

* .

	modified:   google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/StreamWriter.java
	modified:   google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/it/ITBigQueryWriteManualClientTest.java

* .

* .

* .

* .

* avoid duplicate count++ and make it easier to read

* Update google-cloud-bigquerystorage/src/main/java/com/google/cloud/bigquery/storage/v1alpha2/Waiter.java

Co-Authored-By: Stephanie Wang <stephaniewang526@users.noreply.github.com>

* Update google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/it/ITBigQueryWriteManualClientTest.java

Co-Authored-By: Stephanie Wang <stephaniewang526@users.noreply.github.com>

* Update google-cloud-bigquerystorage/src/test/java/com/google/cloud/bigquery/storage/v1alpha2/it/ITBigQueryWriteManualClientTest.java

Co-Authored-By: Stephanie Wang <stephaniewang526@users.noreply.github.com>

* .

* .

* .

* .

* .

* dep: add undeclared dep in parent pom

* dep: remove duplicate and add undeclared

remove dupe gax; add undeclared commons-lang3

Co-authored-by: Stephanie Wang <stephaniewang526@users.noreply.github.com>
  • Loading branch information
yirutang and stephaniewang526 committed Apr 3, 2020
1 parent a68c0aa commit 98851e96f7c20228cf888e4a847ac98f3da2e4b7
@@ -100,6 +100,10 @@
<groupId>org.threeten</groupId>
<artifactId>threetenbp</artifactId>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifactId>commons-lang3</artifactId>
</dependency>

<!-- Test dependencies -->
<dependency>
@@ -31,7 +31,8 @@
public class ProtoSchemaConverter {
private static class StructName {
public String getName() {
return "__S" + (count++);
count++;
return count == 1 ? "__ROOT__" : "__S" + count;
}

private int count = 0;

0 comments on commit 98851e9

Please sign in to comment.