Reads a Parquet file from a storage.

Returns DuckDB rows. You can expand these rows using * or select specific columns using the r['column_name'] syntax. To select specific columns, give the function call an easy alias, such as r:

    SELECT * FROM read_parquet('file.parquet');
    SELECT r['id'], r['name'] FROM read_parquet('file.parquet') r WHERE r['age'] > 21;
    SELECT COUNT(*) FROM read_parquet('file.parquet');
  

Required parameters:

Optional parameters mirror the DuckDB read_parquet function. To specify optional parameters, use parameter := 'value'.

Reads a CSV file from a storage.

Returns DuckDB rows. You can expand these rows using * or select specific columns using the r['column_name'] syntax. To select specific columns, give the function call an easy alias, such as r:

  SELECT * FROM read_csv('file.csv');
  SELECT r['id'], r['name'] FROM read_csv('file.csv') r WHERE r['age'] > 21;
  SELECT COUNT(*) FROM read_csv('file.csv');
  

Required parameters:

Optional parameters mirror the DuckDB read_csv function. To specify optional parameters, use parameter := 'value'.

Reads a JSON file from a storage.

Returns DuckDB rows. You can expand these rows using * or select specific columns using the r['column_name'] syntax. To select specific columns, give the function call an easy alias, such as r:

    SELECT * FROM read_parquet('file.parquet');
    SELECT r['id'], r['name'] FROM read_parquet('file.parquet') r WHERE r['age'] > 21;
    SELECT COUNT(*) FROM read_parquet('file.parquet');
  

Required parameters:

Optional parameters mirror the DuckDB read_json function. To specify optional parameters, use parameter := 'value'.

Reads an iceberg table from a storage.

Returns DuckDB rows. You can expand these rows using * or select specific columns using the r['column_name'] syntax. To select specific columns, give the function call an easy alias, such as r:

  SELECT * FROM iceberg_scan('data/iceberg/table');
  SELECT r['id'], r['name'] FROM iceberg_scan('data/iceberg/table') r WHERE r['age'] > 21;
  SELECT COUNT(*) FROM iceberg_scan('data/iceberg/table');
  

To use iceberg_scan, enable the iceberg extension:

  SELECT duckdb.install_extension('iceberg');
  

Required parameters:

Optional parameters mirror the DuckDB iceberg_scan function. To specify optional parameters, use parameter := 'value'.

Optional parameters:

Returns metadata of an iceberg table. Metadata is returned as a set of icerberg_metadata_record, which is defined as follows:

  CREATE TYPE duckdb.iceberg_metadata_record AS (
    manifest_path TEXT,
    manifest_sequence_number NUMERIC,
    manifest_content TEXT,
    status TEXT,
    content TEXT,
    file_path TEXT
  );
  

To use iceberg_metadata, enable the iceberg extension:

  SELECT duckdb.install_extension('iceberg');
  

Required parameters:

Optional parameters mirror the DuckDB iceberg_metadata function. To specify optional parameters, use parameter := 'value'.

Optional parameters:

Reads snapshot information from an iceberg table.

Returns snapshot metadata for an iceberg table, which can be useful for "time travel" queries and understanding table history.

  SELECT * FROM iceberg_snapshots('data/iceberg/table');
  

To use iceberg_snapshots, enable the iceberg extension:

  SELECT duckdb.install_extension('iceberg');
  

Required parameters:

Optional parameters mirror the DuckDB iceberg_snapshots function. To specify optional parameters, use parameter := 'value'.

Optional parameters:

Reads a Delta dataset from a storage.

Returns DuckDB rows. You can expand these rows using * or select specific columns using the r['column_name'] syntax. To select specific columns, give the function call an easy alias, such as r:

  SELECT * FROM delta_scan('/path/to/delta/dataset');
  SELECT r['id'], r['name'] FROM delta_scan('/path/to/delta/dataset') r WHERE r['age'] > 21;
  SELECT COUNT(*) FROM delta_scan('/path/to/delta/dataset');
  

To use delta_scan, enable the delta extension:

  SELECT duckdb.install_extension('delta');
  

Required parameters: