Struct spark_connect_rs::window::Window

pub struct Window { /* private fields */ }

Primary utility struct for defining window in DataFrames

Implementations

impl Window

pub fn new() -> Window

Creates a new empty WindowSpec

pub fn currentRow() -> i64

Returns 0

pub fn unboundedFollowing() -> i64

Returns i64::MAX

pub fn unboundedPreceding() -> i64

Returns i64::MIN

pub fn partitionBy<I>(self, cols: I) -> WindowSpec

where I: ToVecExpr,

Creates a WindowSpec with the partitioning defined

pub fn orderBy<I, T>(self, cols: I) -> WindowSpec

where T: ToExpr, I: IntoIterator<Item = T>,

Creates a WindowSpec with the ordering defined

pub fn rangeBetween(self, start: i64, end: i64) -> WindowSpec

Creates a WindowSpec with the frame boundaries defined, from start (inclusive) to end (inclusive).

Both start and end are relative from the current row. For example, “0” means “current row”, while “-1” means one off before the current row, and “5” means the five off after the current row.

Recommended to use Window::unboundedPreceding, Window::unboundedFollowing, and Window::currentRow to specify special boundary values, rather than using integral values directly.

Example

let window = Window::new()
    .partitionBy(col("name"))
    .orderBy([col("age")])
    .rangeBetween(Window::unboundedPreceding(), Window::currentRow());

let df = df.withColumn("rank", rank().over(window.clone()))
    .withColumn("min", min("age").over(window));

pub fn rowsBetween(self, start: i64, end: i64) -> WindowSpec

Creates a WindowSpec with the frame boundaries defined, from start (inclusive) to end (inclusive).

Both start and end are relative from the current row. For example, “0” means “current row”, while “-1” means one off before the current row, and “5” means the five off after the current row.

Recommended to use Window::unboundedPreceding, Window::unboundedFollowing, and Window::currentRow to specify special boundary values, rather than using integral values directly.

Example

let window = Window::new()
    .partitionBy(col("name"))
    .orderBy([col("age")])
    .rowsBetween(Window::unboundedPreceding(), Window::currentRow());

let df = df.withColumn("rank", rank().over(window.clone()))
    .withColumn("min", min("age").over(window));

Trait Implementations

impl Clone for Window

fn clone(&self) -> Window

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Window

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

Formats the value using the given formatter.

impl Default for Window

fn default() -> Window

Returns the “default value” for a type.