Struct DefaultEngineBuilder 

pub struct DefaultEngineBuilder<E> { /* private fields */ }

Builder for creating DefaultEngine instances.

Example

// Build a DefaultEngine with default executor
let engine = DefaultEngineBuilder::new(Arc::new(LocalFileSystem::new()))
    .build();

// Build with a custom executor
let engine = DefaultEngineBuilder::new(Arc::new(LocalFileSystem::new()))
    .with_task_executor(Arc::new(TokioBackgroundExecutor::new()))
    .build();

Implementations

impl DefaultEngineBuilder<DefaultTaskExecutor>

pub fn new(object_store: Arc<DynObjectStore>) -> Self

Create a new DefaultEngineBuilder instance with the default executor.

pub fn build(self) -> DefaultEngine<TokioBackgroundExecutor>

Build the DefaultEngine instance.

impl<E> DefaultEngineBuilder<E>

pub fn with_task_executor<F: TaskExecutor>( self, task_executor: Arc<F>, ) -> DefaultEngineBuilder<Arc<F>>

Set a custom task executor for the engine.

See executor::TaskExecutor for more details.

pub fn with_buffer_size(self, buffer_size: NonZero<usize>) -> Self

Set the maximum number of files read concurrently by the JSON and Parquet handlers in their read_*_files paths. This is the file-level I/O readahead depth: higher values overlap more object-store requests to hide latency, at the cost of more in-flight memory.

Defaults to the handlers’ built-in value when unset. Ordering of returned data is preserved regardless of this value.

pub fn with_batch_size(self, batch_size: NonZero<usize>) -> Self

Set the maximum number of rows per batch yielded by the JSON and Parquet handlers in their read_*_files paths.

Defaults to the handlers’ built-in value when unset. Overall read memory usage is roughly proportional to buffer_size * batch_size.

impl<E: TaskExecutor> DefaultEngineBuilder<Arc<E>>

pub fn build(self) -> DefaultEngine<E>

Build the DefaultEngine instance.

Trait Implementations

impl<E: Debug> Debug for DefaultEngineBuilder<E>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.