Skip to contents

Iterates over tables in a WRDS PostgreSQL schema and calls wrds_update_pq for each table.

Usage

wrds_schema_to_pq(
  schema,
  data_dir = NULL,
  force = FALSE,
  tables = NULL,
  views = FALSE,
  chunk_size = 100000L,
  wrds_id = NULL,
  transfer_method = c("dbi", "adbc"),
  numeric_mode = c("decimal", "float64", "text", "raw"),
  ...
)

Arguments

schema

WRDS schema name.

data_dir

Root directory of the local Parquet data repository.

force

If TRUE, re-download tables even if local files appear current.

tables

Optional subset of table names to process.

views

If TRUE, include views as well as base tables.

chunk_size

Number of rows fetched and written per chunk.

wrds_id

Optional WRDS username override.

transfer_method

Transfer backend passed to wrds_update_pq.

numeric_mode

Numeric handling mode passed to wrds_update_pq.

...

Additional arguments passed to wrds_update_pq.

Value

Invisibly returns a named list of output paths or NULL values for skipped/failed tables.