Skip to content

Commit

Permalink
feat: migrate managedwriter to v1 write from v1beta2 (#4788)
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: #4366
  • Loading branch information
shollyman committed Sep 21, 2021
1 parent e846dfd commit 4e1bf9f
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 4e1bf9f

Please sign in to comment.