Struct datafusion_physical_expr::expressions::Ntile

pub struct Ntile { /* private fields */ }

Implementations

impl Ntile

pub fn new(name: String, n: u64) -> Self

Trait Implementations

impl BuiltInWindowFunctionExpr for Ntile

fn as_any(&self) -> &dyn Any

Returns the aggregate expression as Any so that it can be downcast to a specific implementation.

fn field(&self) -> Result<Field>

The field of the final result of evaluating this window function.

fn expressions(&self) -> Vec<Arc<dyn PhysicalExpr>>

Expressions that are passed to the PartitionEvaluator.

fn name(&self) -> &str

Human readable name such as "MIN(c2)" or "RANK()". The default implementation returns placeholder text.

fn create_evaluator(&self) -> Result<Box<dyn PartitionEvaluator>>

Create a PartitionEvaluator for evaluating the function on a particular partition.

fn evaluate_args(&self, batch: &RecordBatch) -> Result<Vec<ArrayRef>>

Evaluate window function’s arguments against the input window batch and return an ArrayRef.

fn reverse_expr(&self) -> Option<Arc<dyn BuiltInWindowFunctionExpr>>

Construct a new BuiltInWindowFunctionExpr that produces the same result as this function on a window with reverse order. The return value of this function is used by the DataFusion optimizer to avoid re-sorting the data when possible.

fn add_equal_orderings(&self, _builder: &mut OrderingEquivalenceBuilder)

Adds any equivalent orderings generated by this expression to builder.

impl Debug for Ntile

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

Formats the value using the given formatter.