Struct SnowflakeLoader 

pub struct SnowflakeLoader {
    pub connection: String,
    pub warehouse: String,
    pub database: String,
    pub schema: String,
    pub storage_integration: String,
    pub gcs_url: String,
    pub cluster_by: Vec<String>,
    pub private_key_path: Option<String>,
    pub run_id: Option<String>,
}

Loads Rivet Parquet from GCS into Snowflake.

Fields

connection: String

The snow CLI connection name (e.g. rivet).

warehouse: String

database: String

schema: String

storage_integration: String

A pre-created GCS STORAGE INTEGRATION (grants Snowflake read on the bucket). The external stage is created per-load using it.

gcs_url: String

gcs://bucket/prefix/ — the external stage’s URL (Snowflake wants the gcs:// scheme, not gs://).

cluster_by: Vec<String>

Clustering key — column(s)/expression(s) for CLUSTER BY, enabling background auto-clustering. Empty = no clustering key. Applies only at table creation.

private_key_path: Option<String>

Absolute path to the connection’s private key. The snow CLI does not expand ~, so a ~-relative private_key_path in the connection file must be overridden with an absolute path via env.

run_id: Option<String>

Load-run correlation id, emitted in the QUERY_TAG JSON as rivet_run so every statement of one rivet load invocation shares a run key — cost slices per run (across tables) as well as per table. None omits it.

Implementations

impl SnowflakeLoader

pub fn new(connection: impl Into<String>) -> Self

Trait Implementations

impl Clone for SnowflakeLoader

fn clone(&self) -> SnowflakeLoader

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SnowflakeLoader

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for SnowflakeLoader

fn default() -> SnowflakeLoader

Returns the “default value” for a type.

impl TargetLoader for SnowflakeLoader

fn fqtn(&self, table: &str) -> String

Fully-qualify table for this warehouse (project.dataset.t / db.schema.t).

fn materialize( &self, table: &str, specs: &[TargetColumnSpec], uris: &[String], ) -> Result<u64>

Overwrite table with the Parquet at uris, materializing the native column types in specs. Returns the rows the load landed.

fn append_changelog( &self, table: &str, specs: &[TargetColumnSpec], uris: &[String], pk: &[String], ) -> Result<u64>

Append the CDC change Parquet into <table>__changes (created if absent), prepending the __op / __pos / __seq meta columns to specs. Returns the rows this call appended.

fn warehouse(&self) -> Warehouse

The warehouse this adapter targets — lets the shared driver build the current-state view SQL (dialect keyword + identifier quoting) in ONE place per mode instead of once per adapter.

fn create_view(&self, table: &str, view_sql: &str) -> Result<()>

CREATE OR REPLACE the current-state view <table> from pre-built view_sql (the driver builds it via cdc::dedup_view_sql for CDC or cdc::inc_dedup_view_sql for incremental). The adapter only executes it its way (e.g. Snowflake prefixes a QUERY_TAG).