Skip to contents

All functions

db_browser()
Browse the data lake interactively
db_browser_server()
Shiny module server for db_browser()
db_browser_ui()
Shiny module UI for db_browser()
db_catalog()
List tables and file stats tracked by DuckLake
db_changes()
Get row-level changes from the Data Change Feed
db_cleanup_files()
Clean up orphaned files from DuckLake storage
db_comment()
Add comment/metadata to table or column
db_compact()
Compact small files in a DuckLake table
db_connect()
Connect to a DuckLake data lake
db_create_macro()
Create a macro in DuckLake
db_create_schema()
Create a new schema in DuckLake
db_create_view()
Create a view in DuckLake
db_deletions()
Get deleted rows from the Data Change Feed
db_dictionary()
Generate a data dictionary
db_diff()
Compare a table between two snapshots
db_disconnect()
Disconnect from the CSO Data Lake
db_drop_macro()
Drop a macro from DuckLake
db_drop_view()
Drop a view from DuckLake
db_enable_logging()
Enable DuckDB/DuckLake logging
db_export_iceberg()
Export a DuckLake table as Iceberg format (EXPERIMENTAL)
db_file_stats()
Get file statistics for DuckLake tables
db_flush_inlined()
Flush inlined data to parquet files
db_get_docs()
Get documentation for a table
db_get_lineage()
Get lineage information
db_get_partitioning()
Get partitioning configuration for a DuckLake table
db_iceberg_metadata()
Get Iceberg metadata for a DuckLake table
db_insertions()
Get inserted rows from the Data Change Feed
db_lineage()
Record data lineage
db_list_macros()
List macros in a DuckLake schema
db_list_schemas()
List schemas in the DuckLake catalog
db_list_views()
List views in a DuckLake schema
db_preview_upsert()
Preview an upsert operation
db_preview_write()
Preview a DuckLake write operation
db_query()
Run arbitrary SQL and return results
db_read()
Read a DuckLake table (lazy)
db_read_arrow()
Read a DuckLake table as an Arrow Table
db_recluster()
Re-cluster table data
db_rollback()
Rollback a table to a previous snapshot
db_search()
Search for tables
db_search_columns()
Search for columns by name
db_set_clustering()
Set sort order for a table
db_set_inline_threshold()
Set the inline threshold for a table, schema, or globally
db_set_partitioning()
Set partitioning for a DuckLake table
db_snapshots()
List DuckLake snapshots
db_status()
Get connection status and configuration
db_table_cols()
Get column names for a DuckLake table
db_table_exists()
Check if a DuckLake table exists
db_tables()
List tables in a DuckLake schema
db_upsert()
Upsert into a DuckLake table using MERGE INTO
db_vacuum()
Vacuum old snapshots from DuckLake
db_view_cols()
Get column names for a DuckLake view
db_write()
Write a DuckLake table (overwrite/append)
db_write_arrow()
Write an Arrow Table to DuckLake
run_example()
Run a package example script