in src/pre_fetch.rs [65:73]
fn with_new_children(
self: std::sync::Arc<Self>,
children: Vec<std::sync::Arc<dyn ExecutionPlan>>,
) -> datafusion::error::Result<std::sync::Arc<dyn ExecutionPlan>> {
// TODO: handle more general case
assert_eq!(children.len(), 1);
let child = children[0].clone();
Ok(Arc::new(PrefetchExec::new(child, self.buf_size)))
}