pub enum FunctionIR {
OpaquePython(OpaquePythonUdf),
Opaque {
function: Arc<dyn DataFrameUdf>,
schema: Option<Arc<dyn UdfSchema>>,
predicate_pd: bool,
projection_pd: bool,
streamable: bool,
fmt_str: PlSmallStr,
},
FastCount {
sources: ScanSources,
scan_type: FileScan,
alias: Option<PlSmallStr>,
},
Pipeline {
function: Arc<Mutex<dyn DataFrameUdfMut>>,
schema: SchemaRef,
original: Option<Arc<IRPlan>>,
},
Unnest {
columns: Arc<[PlSmallStr]>,
},
Rechunk,
MergeSorted {
column: PlSmallStr,
},
Rename {
existing: Arc<[PlSmallStr]>,
new: Arc<[PlSmallStr]>,
swapping: bool,
schema: CachedSchema,
},
Explode {
columns: Arc<[PlSmallStr]>,
schema: CachedSchema,
},
Unpivot {
args: Arc<UnpivotArgsIR>,
schema: CachedSchema,
},
RowIndex {
name: PlSmallStr,
schema: CachedSchema,
offset: Option<IdxSize>,
},
}
Variants§
OpaquePython(OpaquePythonUdf)
Available on crate feature
python
only.Opaque
FastCount
Pipeline
Streaming engine pipeline
Unnest
Fields
§
columns: Arc<[PlSmallStr]>
Rechunk
MergeSorted
Available on crate feature
merge_sorted
only.Fields
§
column: PlSmallStr
Rename
Explode
Unpivot
Available on crate feature
pivot
only.RowIndex
Implementations§
Source§impl FunctionIR
impl FunctionIR
Sourcepub fn is_streamable(&self) -> bool
pub fn is_streamable(&self) -> bool
Whether this function can run on batches of data at a time.
Sourcepub fn expands_rows(&self) -> bool
pub fn expands_rows(&self) -> bool
Whether this function will increase the number of rows
pub fn evaluate(&self, df: DataFrame) -> PolarsResult<DataFrame>
pub fn to_streaming_lp(&self) -> Option<IRPlanRef<'_>>
Trait Implementations§
Source§impl Clone for FunctionIR
impl Clone for FunctionIR
Source§fn clone(&self) -> FunctionIR
fn clone(&self) -> FunctionIR
Returns a copy of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moreSource§impl Debug for FunctionIR
impl Debug for FunctionIR
Source§impl Display for FunctionIR
impl Display for FunctionIR
Source§impl<'_derivative_strum> From<&'_derivative_strum FunctionIR> for &'static str
impl<'_derivative_strum> From<&'_derivative_strum FunctionIR> for &'static str
Source§fn from(x: &'_derivative_strum FunctionIR) -> &'static str
fn from(x: &'_derivative_strum FunctionIR) -> &'static str
Converts to this type from the input type.
Source§impl From<FunctionIR> for &'static str
impl From<FunctionIR> for &'static str
Source§fn from(x: FunctionIR) -> &'static str
fn from(x: FunctionIR) -> &'static str
Converts to this type from the input type.
Source§impl From<FunctionIR> for DslFunction
impl From<FunctionIR> for DslFunction
Source§fn from(value: FunctionIR) -> Self
fn from(value: FunctionIR) -> Self
Converts to this type from the input type.
Source§impl Hash for FunctionIR
impl Hash for FunctionIR
Source§impl PartialEq for FunctionIR
impl PartialEq for FunctionIR
impl Eq for FunctionIR
Auto Trait Implementations§
impl !Freeze for FunctionIR
impl !RefUnwindSafe for FunctionIR
impl Send for FunctionIR
impl Sync for FunctionIR
impl Unpin for FunctionIR
impl !UnwindSafe for FunctionIR
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
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
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>
Converts
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>
Converts
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 moreSource§impl<T> Pointable for T
impl<T> Pointable for T
Source§impl<T> ToCompactString for Twhere
T: Display,
impl<T> ToCompactString for Twhere
T: Display,
Source§fn try_to_compact_string(&self) -> Result<CompactString, ToCompactStringError>
fn try_to_compact_string(&self) -> Result<CompactString, ToCompactStringError>
Fallible version of
ToCompactString::to_compact_string()
Read moreSource§fn to_compact_string(&self) -> CompactString
fn to_compact_string(&self) -> CompactString
Converts the given value to a
CompactString
. Read more