Skip to main content

RowSink

Trait RowSink 

Source
pub trait RowSink {
    // Required method
    fn accept(
        &mut self,
        result_set: &ResultSet,
        rows: Vec<Vec<Option<String>>>,
    ) -> Result<(), SnowflakeError>;
}
Expand description

Receives a statement’s rows in partition order while it streams (reality-check bead E5).

Required Methods§

Source

fn accept( &mut self, result_set: &ResultSet, rows: Vec<Vec<Option<String>>>, ) -> Result<(), SnowflakeError>

Take the next rows: the inline rows, then each fetched partition. An error stops the fetch and cancels the statement server-side.

§Errors

Whatever the sink could not do with the rows (a write failure, a row limit).

Dyn Compatibility§

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors§