From 00d144f6a67af596dee6a8bca4f451e3621a9687 Mon Sep 17 00:00:00 2001
From: Nathan <148575555+nathan-artie@users.noreply.github.com>
Date: Tue, 18 Jun 2024 13:37:44 -0700
Subject: [PATCH] [bigquery] Rename `putTableViaStorageWriteAPI` method

---
 clients/bigquery/bigquery.go | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/clients/bigquery/bigquery.go b/clients/bigquery/bigquery.go
index c6d992ab3..1bc15630c 100644
--- a/clients/bigquery/bigquery.go
+++ b/clients/bigquery/bigquery.go
@@ -103,8 +103,7 @@ func (s *Store) PrepareTemporaryTable(tableData *optimization.TableData, tableCo
 		return fmt.Errorf("unable to cast tempTableID to BigQuery TableIdentifier")
 	}
 
-	// Load the data
-	return s.putTableViaStorageWriteAPI(context.Background(), bqTempTableID, tableData)
+	return s.putTable(context.Background(), bqTempTableID, tableData)
 }
 
 func (s *Store) IdentifierFor(topicConfig kafkalib.TopicConfig, table string) sql.TableIdentifier {
@@ -152,7 +151,7 @@ func (s *Store) GetClient(ctx context.Context) *bigquery.Client {
 	return client
 }
 
-func (s *Store) putTableViaStorageWriteAPI(ctx context.Context, bqTableID TableIdentifier, tableData *optimization.TableData) error {
+func (s *Store) putTable(ctx context.Context, bqTableID TableIdentifier, tableData *optimization.TableData) error {
 	columns := tableData.ReadOnlyInMemoryCols().ValidColumns()
 
 	messageDescriptor, err := columnsToMessageDescriptor(columns)