Skip to contents

Creating the OMOP CDM in Spark

createOmopTablesOnSpark()
Create OMOP CDM tables

Creating a cdm reference for OMOP CDM data in Spark

cdmFromSpark()
Create a cdm_reference object from a sparklyr connection.

Methods for Spark

cdmDisconnect(<spark_cdm>)
Disconnect the connection of the cdm object
dropSourceTable(<spark_cdm>)
Drop spark tables
insertTable(<spark_cdm>)
Insert a table to a cdm object

Utilities

mockSparkCdm()
creates a cdm reference to local spark OMOP CDM tables