BIGQUERY INTEGRATION
Real-time Data for BigQuery
Stream changes from any database directly to BigQuery. Keep your warehouse fresh with CDC pipelines using BigQuery's Storage Write API.
BigQuery Integration Features
Storage Write API
Native integration with BigQuery's Storage Write API for efficient, low-latency data loading.
Automatic Schema Mapping
Schema changes in your source database are automatically reflected in BigQuery.
Cost Optimization
Only load changed data, reducing streaming insert costs.
Data Type Mapping
Automatic conversion of source data types to BigQuery-native types.
Common Use Cases
Replace batch ETL with real-time CDC
Build operational dashboards in Looker
Power ML models with fresh data
Sync OLTP to analytics
How It Works
1
Connect Source
PostgreSQL, MySQL, MongoDB, or any supported database
→
2
Stream via Streamkap
Real-time CDC with optional SQL transforms
→
3
Load to BigQuery
Storage Write API for low-latency loading