Google BigQuery

Datasets, tables, schemas, free table reads, bounded parameterised queries, MERGE upserts, streaming inserts and job cost monitoring.

Stream operational events into BigQuery and read curated tables back into flows with predictable query cost.

Build a flow with Google BigQuery Provider API documentation

Source actions

Destination actions

Data types

Validation status

Implemented · fixture tested.

Implementation is checked against provider-shaped fixtures for every action, authentication failures, rate limits, pagination and duplicate safety. Provider sandbox and authorised account validation are recorded separately when credential-backed runs are completed.

What you can map

columns

List columns
Source
Lists a table's columns (top-level schema fields) from table metadata.
columns.list

datasets

Get dataset
Source
Reads dataset metadata.
datasets.get
List datasets
Source
Lists datasets in the project.
datasets.list

jobs

Get job
Source
Reads a job's state and statistics.
jobs.get
List jobs
Source
Incremental
Lists query, load and copy jobs with bytes processed and billed (cost monitoring).
jobs.list

rows

Stream row (insertAll)
Destination
Not retried automatically
Approval before production
Streams one row with tabledata.insertAll. BigQuery uses insertId for best-effort de-duplication of retried inserts.
rows.create
Search table rows
Source
Incremental
Runs a generated, parameterised GoogleSQL SELECT (validated columns, filters, updated-since and LIMIT) with jobs.query.
rows.search
Upsert row
Destination
Not retried automatically
Approval before production
MERGEs one row into a table by key columns with named query parameters (DML).
rows.upsert

table rows

List table rows (no query)
Source
Pages through table storage with tabledata.list; not billed as a query. Values come back in schema order.
table_rows.list

tables

Get table
Source
Reads table metadata including its schema, row count and partitioning.
tables.get
List tables
Source
Lists tables and views in a dataset.
tables.list

Authentication

Service account key or OAuth client refresh token

Plans and access

Any Google Cloud project with the BigQuery API enabled (on-demand or capacity pricing). IAM roles apply (BigQuery Job User plus Data Viewer or Data Editor on the datasets). Queries are billed to the connection project.

Test environment

The BigQuery sandbox gives free monthly storage and query quota without billing.

Rate limits

Per-project API request quotas, concurrent query limits and streaming insert quotas; quota errors return HTTP 403/429 with rateLimitExceeded.

Pagination

pageToken for metadata, jobs and table data; generated LIMIT/OFFSET for searches.

Provider events

None (Pub/Sub notifications are configured separately). Nexra event triggers are not yet available; flows run on demand or on a schedule.

Before you build a flow

Free-form SQL is not accepted; only generated SELECT and MERGE statements with named parameters run.
Searches, MERGE upserts and streaming inserts are billable and are not retried automatically.
Queries wait up to 45 seconds; longer jobs return a job ID to inspect with jobs.get.
tabledata.list returns cells in schema order without column names; use columns.list to label them.
Domain-scoped project IDs (example.com:project) are not supported.

Developer reference

Create the Google Cloud credentials described above with the narrowest permissions your flows need.
In Nexra, open Connect, then Connections, then New connection, choose Google BigQuery, enter its settings and credentials, and tick only the write actions you need. Connection guide
Test the connection, then use its actions as flow sources and destinations. Flow guide

Google Cloud docsAPI reference Google Cloud docsAuthentication Google Cloud docsRate limits

Machine-readable detail: GET /api/public/connect/connectors/bigquery and the Connections API.