Method build_runtime

benchmarks/src/util/options.rs:137–149

Build the runtime environment, optionally wrapping the local filesystem with a throttled object store to simulate remote storage latency.

(&self)

    /// Build the runtime environment, optionally wrapping the local filesystem
    /// with a throttled object store to simulate remote storage latency.
    pub fn build_runtime(&self) -> Result<Arc<RuntimeEnv>> {
        let rt = self.runtime_env_builder()?.build_arc()?;
        if self.simulate_latency {
            let store: Arc<dyn object_store::ObjectStore> =
                Arc::new(LatencyObjectStore::new(LocalFileSystem::new()));
            let url = ObjectStoreUrl::parse("file:///")?;
            rt.register_object_store(url.as_ref(), store);
            println!(
                "Simulating S3-like object store latency (get: 25-200ms, list: 40-400ms)"
            );
        }
        Ok(rt)
    }
}

/// Parse capacity limit from string to number of bytes by allowing units: K, M and G.