pub struct GpuDataFrame { /* private fields */ }Expand description
Owned cuDF DataFrame plus the placement observed when it entered the engine.
The wrapper preserves the device placement contract while allowing callers
to move the underlying frame between native operators. Clone semantics are
those of cudf::DataFrame.
Implementations§
Source§impl GpuDataFrame
impl GpuDataFrame
Sourcepub fn new(frame: DataFrame) -> Self
pub fn new(frame: DataFrame) -> Self
Wrap a cuDF frame and record its current execution placement.
Sourcepub fn try_new_with_source_residency(
frame: DataFrame,
source: &Self,
) -> Result<Self>
pub fn try_new_with_source_residency( frame: DataFrame, source: &Self, ) -> Result<Self>
Wrap a derived cuDF frame with identity-aware live-byte accounting and the source’s transitive resident and cache eviction-safety lifetimes.
Sourcepub fn into_frame(self) -> DataFrame
pub fn into_frame(self) -> DataFrame
Consume the wrapper and return the underlying cuDF frame.
Sourcepub fn with_graph_residency(
self,
graph_residency: GraphResidencyDescriptor,
) -> Self
pub fn with_graph_residency( self, graph_residency: GraphResidencyDescriptor, ) -> Self
Attach graph source provenance to this GPU frame.
Sourcepub fn graph_residency(&self) -> Option<&GraphResidencyDescriptor>
pub fn graph_residency(&self) -> Option<&GraphResidencyDescriptor>
Graph source provenance carried by this frame, when known.
Sourcepub fn placement(&self) -> ExecutionPlacement
pub fn placement(&self) -> ExecutionPlacement
Execution placement observed when the frame entered the engine.
Sourcepub fn num_columns(&self) -> usize
pub fn num_columns(&self) -> usize
Current column count reported by the cuDF frame.
Sourcepub fn device_allocated_size_bytes(&self) -> Result<u64>
pub fn device_allocated_size_bytes(&self) -> Result<u64>
Observed device allocation for the frame in bytes.
Trait Implementations§
Auto Trait Implementations§
impl !RefUnwindSafe for GpuDataFrame
impl !UnwindSafe for GpuDataFrame
impl Freeze for GpuDataFrame
impl Send for GpuDataFrame
impl Sync for GpuDataFrame
impl Unpin for GpuDataFrame
impl UnsafeUnpin for GpuDataFrame
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
fn instrument(self, span: Span) -> Instrumented<Self> ⓘ
Source§fn in_current_span(self) -> Instrumented<Self> ⓘ
fn in_current_span(self) -> Instrumented<Self> ⓘ
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
fn into_either(self, into_left: bool) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self> ⓘ
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read more