diff --git a/clients/bigquery/merge.go b/clients/bigquery/merge.go index bf807e87..f334a3e0 100644 --- a/clients/bigquery/merge.go +++ b/clients/bigquery/merge.go @@ -4,8 +4,6 @@ import ( "fmt" "strings" - "cloud.google.com/go/bigquery" - "github.com/artie-labs/transfer/clients/shared" "github.com/artie-labs/transfer/lib/config/constants" "github.com/artie-labs/transfer/lib/destination/types" @@ -16,20 +14,6 @@ import ( "github.com/artie-labs/transfer/lib/typing/columns" ) -type Row struct { - data map[string]bigquery.Value -} - -func NewRow(data map[string]bigquery.Value) *Row { - return &Row{ - data: data, - } -} - -func (r *Row) Save() (map[string]bigquery.Value, string, error) { - return r.data, bigquery.NoDedupeID, nil -} - func (s *Store) Merge(tableData *optimization.TableData) error { var additionalEqualityStrings []string if tableData.TopicConfig().BigQueryPartitionSettings != nil {