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§
Sourcefn accept(
&mut self,
result_set: &ResultSet,
rows: Vec<Vec<Option<String>>>,
) -> Result<(), SnowflakeError>
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".