Skip to main content

execute_copy_from

linkrs_query::executor::streaming::operators::copy

Function execute_copy_from 

Source 
pub fn execute_copy_from(
    storage_lock: &Arc<RwLock<dyn QueryStorage>>,
    space_name: &str,
    target: &CopyTarget,
    file_paths: &[String],
    by_column: bool,
    header: bool,
    delimiter: u8,
    batch_size: usize,
    runtime: Option<Arc<ExecutionRuntime>>,
) -> Result<u64, QueryError>
Expand description

Execute a COPY FROM statement and return the number of rows inserted.