Skip to content

Commit

Permalink
feat: migrate managedwriter to v1 write from v1beta2
Browse files Browse the repository at this point in the history
This PR updates the managedwriter to use the v1 endpoint of
bigquerystorage for interactions with the BigQueryWriteClient.

Towards: googleapis#4366
  • Loading branch information
shollyman committed Sep 21, 2021
1 parent 6861b30 commit 92dce61
Show file tree
Hide file tree
Showing 9 changed files with 10 additions and 10 deletions.
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/adapt/protoconversion.go
Expand Up @@ -19,7 +19,7 @@ import (
"fmt"
"strings"

storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/reflect/protodesc"
"google.golang.org/protobuf/reflect/protoreflect"
Expand Down
Expand Up @@ -21,7 +21,7 @@ import (

"cloud.google.com/go/bigquery/storage/managedwriter/testdata"
"github.com/google/go-cmp/cmp"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/protobuf/encoding/protojson"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/reflect/protodesc"
Expand Down
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/adapt/schemaconversion.go
Expand Up @@ -18,7 +18,7 @@ import (
"fmt"

"cloud.google.com/go/bigquery"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
)

var fieldTypeMap = map[bigquery.FieldType]storagepb.TableFieldSchema_Type{
Expand Down
Expand Up @@ -20,7 +20,7 @@ import (
"cloud.google.com/go/bigquery"
"cloud.google.com/go/internal/testutil"
"github.com/google/go-cmp/cmp"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/protobuf/testing/protocmp"
)

Expand Down
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/appendresult.go
Expand Up @@ -17,7 +17,7 @@ package managedwriter
import (
"context"

storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/protobuf/proto"
"google.golang.org/protobuf/types/known/wrapperspb"
)
Expand Down
4 changes: 2 additions & 2 deletions bigquery/storage/managedwriter/client.go
Expand Up @@ -20,11 +20,11 @@ import (
"runtime"
"strings"

storage "cloud.google.com/go/bigquery/storage/apiv1beta2"
storage "cloud.google.com/go/bigquery/storage/apiv1"
"cloud.google.com/go/internal/detect"
"github.com/googleapis/gax-go/v2"
"google.golang.org/api/option"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/grpc"
"google.golang.org/grpc/metadata"
)
Expand Down
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/doc.go
Expand Up @@ -19,7 +19,7 @@ More information about this new write client may also be found in the public doc
It is EXPERIMENTAL and subject to change or removal without notice. This library is in a pre-alpha
state, and breaking changes are frequent.
Currently, this client targets the BigQueryWriteClient present in the v1beta2 endpoint, and is intended as a more
Currently, this client targets the BigQueryWriteClient present in the v1 endpoint, and is intended as a more
feature-rich successor to the classic BigQuery streaming interface, which is presented as the Inserter abstraction
in cloud.google.com/go/bigquery, and the tabledata.insertAll method if you're more familiar with the BigQuery v2 REST
methods.
Expand Down
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/managed_stream.go
Expand Up @@ -22,7 +22,7 @@ import (

"github.com/googleapis/gax-go/v2"
"go.opencensus.io/tag"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/grpc/codes"
grpcstatus "google.golang.org/grpc/status"
"google.golang.org/protobuf/types/descriptorpb"
Expand Down
2 changes: 1 addition & 1 deletion bigquery/storage/managedwriter/managed_stream_test.go
Expand Up @@ -18,7 +18,7 @@ import (
"context"
"testing"

storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1beta2"
storagepb "google.golang.org/genproto/googleapis/cloud/bigquery/storage/v1"
"google.golang.org/grpc/codes"
"google.golang.org/grpc/status"
"google.golang.org/protobuf/proto"
Expand Down

0 comments on commit 92dce61

Please sign in to comment.