Connectors
Connect Your Data
Nine connectors available today, across cloud storage, warehouses, databases, and APIs. Schema inference, auth, and incremental sync are built into every one.
Built Into Every Connector
These features work across all source types.
Automatic Schema Inference
Every connector detects column names, types, and nested structures on connect. No manual schema definition needed.
OAuth & Credential Management
GCS and BigQuery use Google OAuth, no raw access keys to manage. Other connectors take a service credential or connection string, whichever the source requires. Tokens refresh automatically where OAuth applies.
Incremental Sync
File connectors track modification dates so only new and changed data is ingested on subsequent runs.
AI-Guided Setup
The Ingestion Engineer walks you through configuration conversationally: browsing, file selection, validation, and schema inference.
Available Today
Nine connectors you can use right now.
Cloud Storage
Connect to object stores and ingest files at any scale. Browse buckets and folders, select specific files, and auto-detect schema.
- Bucket and prefix browsing
- File-level selection
- CSV, Parquet, JSON auto-detect
- Incremental sync by modification date
- Bucket and prefix browsing
- File-level selection
- CSV, Parquet, JSON auto-detect
- Incremental sync by modification date
Data Warehouses
Ingest from existing warehouses or use them as compute engines for large-scale processing.
- Dataset and table browsing
- BigLake Iceberg integration
- Partitioned table support
- Also used as a compute engine
- Schema and table browsing
- Cross-account access via role assumption
- Partitioned table support
- Also used as a compute engine
Databases
Connect directly to a running database. Every run reads through a query, either the full table or one you provide.
- Schema reflection via SQLAlchemy
- Full table or custom query ingestion
- Type-safe column mapping
- Fail-loud schema inference
- Schema reflection via SQLAlchemy
- Full table or custom query ingestion
- Type-safe column mapping
- Fail-loud schema inference
APIs
Ingest from any REST or GraphQL endpoint with automatic pagination and nested response flattening.
- Any JSON or CSV endpoint
- Automatic pagination handling
- Nested JSON flattening
- Custom headers and auth
- Schema discovery via introspection
- Relay-style cursor pagination
- Nested response data extraction
- Custom headers and auth
Analytics
Pull reporting data directly from a connected analytics property.
- Dimension and metric selection
- Configurable lookback window
- Direct Analytics Data API access
- Property shared with a service account, same as BigQuery
What's Next
Connected a source? Build your first pipeline.
Connect once. OptimaFlo handles schema inference, auth refresh, and incremental sync.