Struct datafusion::physical_expr::expressions::Ntile

pub struct Ntile { /* private fields */ }

Implementations

impl Ntile

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

Trait Implementations

impl BuiltInWindowFunctionExpr for Ntile

fn as_any(&self) -> &(dyn Any + 'static)

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

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

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

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

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, Global>, DataFusionError>

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

fn evaluate_args( &self, batch: &RecordBatch ) -> Result<Vec<Arc<dyn Array>, Global>, DataFusionError>

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<(), Error>

Formats the value using the given formatter.