Struct KernelSession 

pub struct KernelSession { /* private fields */ }

Session-scoped holder for the optimizer kernel registry.

KernelSession is the session variable that owns an ArrayKernels registry. Its Default implementation installs vortex-array’s built-in parent-reduce and execute-parent kernels, mirroring how ScalarFnSession and the other session variables register their built-ins.

Implementations

impl KernelSession

pub fn empty() -> Self

Create a KernelSession with an empty kernel registry.

pub fn kernels(&self) -> &ArrayKernels

Returns the ArrayKernels registry held by this session.

Methods from Deref<Target = ArrayKernels>

pub fn register_reduce_parent( &self, parent: Id, child: Id, fns: &[ReduceParentFn], )

Register ReduceParentFns for (parent, child).

The optimizer invokes these functions in registration order when it sees a parent with encoding id parent holding a child with encoding id child during a reduce_parent step, before trying the child encoding’s static PARENT_RULES. parent is usually the parent array’s encoding id. For ScalarFnArray, it is the scalar function id, for example Cast.id().

If functions have already been registered for the same pair, these functions are appended after them.

pub fn find_reduce_parent( &self, parent: Id, child: Id, ) -> Option<Arc<[ReduceParentFn]>>

Look up the ReduceParentFns registered for (parent, child).

Returns an owned Arc so the session-variable borrow can be dropped before invoking the functions.

pub fn register_execute_parent( &self, parent: Id, child: Id, fns: &[ExecuteParentFn], )

Register ExecuteParentFns for (parent, child).

The executor invokes these functions in registration order when it sees a parent with encoding id parent holding a child with encoding id child during a parent execution step.

If functions have already been registered for the same pair, these functions are appended after them.

pub fn register_execute_parent_kernel<V, K>( &self, parent: Id, child: V, kernel: K, )

where V: VTable, K: ExecuteParentKernel<V>,

Register a typed ExecuteParentKernel for (parent, child.id()).

The executor invokes registered kernels in registration order before falling through to later registered kernels for the same key. parent is usually the parent array’s encoding id. For ScalarFnArray, it is the scalar function id, for example Cast.id().

If kernels have already been registered for the same pair, this kernel is appended after them; registering for an existing key cannot override built-in kernels installed earlier.

pub fn has_execute_parent(&self, parent: Id, child: Id) -> bool

Returns true when one or more execute-parent kernels are registered for (parent, child).

Trait Implementations

impl Clone for KernelSession

fn clone(&self) -> KernelSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for KernelSession

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

Formats the value using the given formatter.

impl Default for KernelSession

fn default() -> Self

Returns the “default value” for a type.

impl Deref for KernelSession

Derefs to the held ArrayKernels registry, so a KernelSession (or a SessionGuard<KernelSession> read from a session) can be used wherever an &ArrayKernels is expected.

type Target = ArrayKernels

The resulting type after dereferencing.

fn deref(&self) -> &ArrayKernels

Dereferences the value.

impl SessionVar for KernelSession

fn as_any(&self) -> &dyn Any

fn as_any_mut(&mut self) -> &mut dyn Any