Struct AlgeonNativeExecutionConfig 

pub struct AlgeonNativeExecutionConfig { /* private fields */ }

Adapter-side native execution configuration.

This type holds the DataFusion-facing settings for native cuDF execution. It does not eagerly create cuDF runtime state. Production ExecutionContext values are acquired only through backend admission when an accepted native plan begins execution.

Implementations

impl AlgeonNativeExecutionConfig

pub fn has_query_admission_authority(&self) -> bool

Returns whether this config carries a backend admission source or an attempt-bound ticket.

This presence check does not claim capacity or establish that the backend is open.

impl AlgeonNativeExecutionConfig

pub const AUTO_SIZED_DEVICE_BUDGET_HEADROOM_BYTES: u64

Device-memory headroom, in bytes, reserved by automatic per-device backend profiles for libcudf and driver overhead.

pub fn new(source_chunking: SourceChunking) -> Self

A configuration with source_chunking and default settings otherwise. It carries no device capacity: admitted execution always runs under the selected device’s immutable grant.

pub fn with_source_scheduler_policy( self, source_scheduler_policy: SourceSchedulerPolicy, ) -> Self

Set bounded source scheduling controls.

pub fn with_source_chunk_planning_mode( self, mode: SourceChunkPlanningMode, ) -> Self

Set bounded source chunk planning mode.

pub fn with_lakehouse_cache_fill_config( self, config: LakehouseCacheFillConfig, ) -> Self

Set the lakehouse cache-fill resource policy projected into backend execution.

pub fn with_host_output_memory_pool_accounting(self, enabled: bool) -> Self

Account native host Arrow output batches against DataFusion’s host MemoryPool.

This is intentionally host-only. Device memory admission and grants stay in the native query service/governor ledger.

pub fn with_query_id(self, query_id: impl Into<QueryId>) -> Self

Attach a diagnostic query id to native execution metrics.

pub fn with_trace_id(self, trace_id: impl Into<TraceId>) -> Self

Attach a parent trace id to native diagnostics.

pub fn query_id(&self) -> Option<&QueryId>

Borrows the optional diagnostic query correlation id carried by this execution template.

pub fn trace_id(&self) -> Option<&TraceId>

Borrows the optional parent trace correlation id carried by this execution template.

pub fn runtime_observation_config(&self) -> RuntimeObservationConfig

Returns the bounded runtime observation retention policy copied into native execution.

pub fn with_lakehouse_footer_pruning(self, enabled: bool) -> Self

Prunes s3:// Parquet row groups from their footers before native execution admits the plan. Off by default.

pub fn lakehouse_footer_pruning(&self) -> bool

Whether footer pruning runs before admission.

pub fn with_statistical_aggregate_execution_mode( self, mode: StatisticalAggregateExecutionMode, ) -> Self

Select the execution contract for floating statistical aggregates.

Defaults to StatisticalAggregateExecutionMode::GpuNativeTolerant, whose results can differ from DataFusion in floating-point bits. Select StatisticalAggregateExecutionMode::DataFusionExactHostWelford when results must be identical to DataFusion’s. In that mode a candidate whose statistical aggregate input DataFusion reads through more than one partition stays on DataFusion, whose own result then depends on the order partitions deliver rows.

pub fn with_dynamic_filter_execution_options( self, options: DynamicFilterExecutionOptions, ) -> Self

Set native dynamic-filter execution policy.

Route discovery, admission, and runtime payload handling read one threshold set through Self::planning_policy. It is intentionally not exposed as a session/server setting until the expert surface is reviewed.

pub fn with_keyed_hash_join_strategy_options( self, options: KeyedHashJoinStrategyOptions, ) -> Self

Set native keyed-hash join strategy policy.

Capability admission, admission reports, and runtime observed-build strategy selection read one threshold set through Self::planning_policy. It is intentionally not exposed as a session/server setting until the expert surface is reviewed.

pub fn with_aggregate_strategy_execution_options( self, options: AggregateStrategyExecutionOptions, ) -> Self

Set native grouped aggregate strategy execution policy.

This policy is copied into native execution contexts so runtime aggregate strategy selection, exact-cardinality probes, and strategy metric rows share one threshold set. It is intentionally not exposed as a session/server setting until the expert surface is reviewed.

pub fn with_source_chunk_planning_options( self, options: SourceChunkPlanningOptions, ) -> Self

Set expert local-throughput source chunk planning policy.

This policy is intentionally Rust-only; public source chunk settings remain the bounded memory policy and source chunk planning mode.

pub fn s3_storage(&self) -> Option<&S3SourceStorageProfile>

The S3 storage every s3:// source reads through, when configured.

pub fn with_s3_storage(self, profile: S3SourceStorageProfile) -> Self

Reads every s3:// source through profile: native reads, cache fills, footer pruning, and the DataFusion object store that sessions installed with this config resolve for s3:// URLs.

pub fn with_lakehouse_byte_cache(self, cache: LakehouseByteCache) -> Self

Keeps a local byte cache of s3:// Parquet objects.

pub fn source_chunking(&self) -> SourceChunking

Source chunking of native reads.

pub fn max_source_reads_in_flight(&self) -> usize

Maximum active native source reads allowed per bounded query.

pub fn source_scheduler_policy(&self) -> SourceSchedulerPolicy

Source scheduling policy used by bounded native source reads.

pub fn source_chunk_planning_mode(&self) -> SourceChunkPlanningMode

Source chunk planning mode used by bounded native source reads.

pub fn lakehouse_cache_fill_config(&self) -> &LakehouseCacheFillConfig

Lakehouse cache-fill resource policy projected into backend execution.

pub fn host_output_memory_pool_accounting(&self) -> bool

Whether host Arrow output from native execution is charged to DataFusion’s host-side memory pool.

pub fn statistical_aggregate_execution_mode( &self, ) -> StatisticalAggregateExecutionMode

Execution contract for floating statistical aggregates.

pub fn planning_policy(&self) -> PlanningPolicy

Join and dynamic-filter thresholds native plans are optimized, admitted, and executed under.

pub fn aggregate_strategy_execution_options( &self, ) -> AggregateStrategyExecutionOptions

Grouped aggregate strategy execution policy copied into native contexts.

pub fn source_chunk_planning_options(&self) -> SourceChunkPlanningOptions

Expert local-throughput source chunk planning policy copied into native contexts.

Trait Implementations

impl Clone for AlgeonNativeExecutionConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for AlgeonNativeExecutionConfig

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

Formats the value using the given formatter.

impl Default for AlgeonNativeExecutionConfig

fn default() -> Self

Returns the “default value” for a type.