Method process_file

benchmarks/src/sql_benchmark.rs:478–509

(&mut self, ctx: &SessionContext, path: &Path)

    }

    async fn process_file(&mut self, ctx: &SessionContext, path: &Path) -> Result<()> {
        debug!("Processing file {}", path.display());

        let mut replacement_mapping = self.replacement_mapping.clone();
        insert_replacement(
            &mut replacement_mapping,
            "FILE_PATH",
            path.to_string_lossy().into_owned(),
        );

        let mut reader = BenchmarkFileReader::new(path, replacement_mapping)?;
        let mut line = String::with_capacity(1024);
        let mut reader_result = reader.read_line(&mut line);

        while let Some(result) = reader_result {
            match result {
                Ok(_) => {
                    if !is_blank_or_comment_line(&line) {
                        // boxing required because of recursion
                        Box::pin(self.process_line(ctx, &mut reader, &mut line)).await?;
                    }
                }
                Err(e) => return Err(e),
            }

            // Clear the line buffer for the next iteration.
            line.clear();
            reader_result = reader.read_line(&mut line);
        }

        Ok(())
    }

    async fn process_line(
        &mut self,