Table and SQL

When to use it

Choose table, delta_table or view for registered objects. Choose sql when the source must be a reviewed extraction query rather than a reusable catalog object.

Runtime requirements

Basic example

source:
  type: connector
  connector: table
  table: main.raw.orders

source:
  type: connector
  connector: sql
  query: |
    SELECT id, updated_at, amount
    FROM main.raw.orders
    WHERE status = 'closed'

Supported source types

Advanced patterns

Use SQL sources for small, reviewed extraction predicates. If the SQL becomes a business transformation, promote it to a view, notebook step or a Silver/Gold contract.

source:
  type: connector
  connector: sql
  query: |
    SELECT order_id, updated_at, amount
    FROM main.raw.orders
    WHERE updated_at >= timestamp '2026-01-01'
watermark_columns: [updated_at]

Operational validation

SELECT run_id, status, source_connector, source_table, source_query, rows_read, rows_written
FROM main.ops.ctrl_ingestion_runs
WHERE source_connector IN ('table', 'delta_table', 'view', 'sql')
ORDER BY started_at_utc DESC;

Common issues