diff --git a/cmd/bigquery/main.go b/cmd/bigquery/main.go index 7f9ca21c..c30c28f0 100644 --- a/cmd/bigquery/main.go +++ b/cmd/bigquery/main.go @@ -25,8 +25,8 @@ Example invocation (assuming the bigquery table already exists): bazelisk run //cmd/bigquery:bigquery -- \ --log_path text:///tmp/reproxy_log.rpl \ --alsologtostderr=true \ - --table . \ - --project_id # (ex:"foundry-x-experiments") + --bq_project # (ex:"foundry-x-experiments") \ + --bq_table . If you don't have a bigquery table yet, you can create it using the following steps: @@ -87,8 +87,6 @@ func main() { log.Exitf("Failed creating bigquery client: %v", err) } bqSpec := &bigquery.BQSpec{ - ProjectID: *bqProjectID, - TableSpec: *bqTableSpec, BatchSizeMB: *bqBatchMB, Client: client, CleanUp: cleanUp, diff --git a/cmd/reproxy/main.go b/cmd/reproxy/main.go index 960cd702..25b202a0 100644 --- a/cmd/reproxy/main.go +++ b/cmd/reproxy/main.go @@ -496,8 +496,6 @@ func initializeLogger(mi *ignoremismatch.MismatchIgnorer, e *monitoring.Exporter log.Errorf("Failed creating bigquery stream: %v", err) } else { bqSpec = &bigquery.BQSpec{ - ProjectID: *bqProjectID, - TableSpec: *bqTableSpec, BatchSizeMB: *bqBatchMB, Client: client, CleanUp: cleanUp, diff --git a/internal/pkg/bigquery/bigquery.go b/internal/pkg/bigquery/bigquery.go index 50a5be6e..98ffb4f0 100644 --- a/internal/pkg/bigquery/bigquery.go +++ b/internal/pkg/bigquery/bigquery.go @@ -83,8 +83,6 @@ func NewInserter(ctx context.Context, resourceSpec, defaultProject string, ts *o // BQSpec defines which bigquery table the LogRecords will be saved. type BQSpec struct { Err atomic.Pointer[error] - ProjectID string - TableSpec string BatchSizeMB int Client *bigquery.Inserter CleanUp func() error