Struct datafusion::physical_plan::expressions::Rank

pub struct Rank { /* private fields */ }

Rank calculates the rank in the window function with order by

Implementations

impl Rank

pub fn get_type(&self) -> RankType

Get rank_type of the rank in window function with order by

Trait Implementations

impl BuiltInWindowFunctionExpr for Rank

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

Return a reference to Any that can be used for downcasting

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

the field of the final result of this aggregation.

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

expressions that are passed to the Accumulator. Single-column aggregations such as sum return a single value, others (e.g. cov) return many.

fn name(&self) -> &str

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

fn supports_bounded_execution(&self) -> bool

fn create_evaluator( &self ) -> Result<Box<dyn PartitionEvaluator + 'static, Global>, DataFusionError>

Create built-in window evaluator with a batch

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

Evaluate window function arguments against the batch and return an array ref. Typically, the resulting vector is a single element vector.

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

Construct Reverse Expression that produces the same result on a reversed window. For example lead(10) –> lag(10)

fn uses_window_frame(&self) -> bool

impl Debug for Rank

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

Formats the value using the given formatter.