操作/选择#

LazyFrame.approx_n_unique()

唯一值的近似计数。

LazyFrame.bottom_k(k, *, by[, reverse])

返回k个最小的行。

LazyFrame.cast(dtypes, *[, strict])

将LazyFrame列转换为指定的数据类型。

LazyFrame.clear([n])

创建一个当前LazyFrame的空副本,行数为零到'n'。

LazyFrame.clone()

创建此 LazyFrame 的副本。

LazyFrame.drop(*columns[, strict])

从DataFrame中移除列。

LazyFrame.drop_nans([subset])

删除包含一个或多个NaN值的所有行。

LazyFrame.drop_nulls([subset])

删除包含一个或多个空值的所有行。

LazyFrame.explode(columns, *more_columns)

将DataFrame通过展开给定列来转换为长格式。

LazyFrame.fill_nan(value)

填充浮点数的NaN值。

LazyFrame.fill_null([value, strategy, ...])

使用指定的值或策略填充空值。

LazyFrame.filter(*predicates, **constraints)

根据谓词表达式过滤LazyFrame中的行。

LazyFrame.first()

获取DataFrame的第一行。

LazyFrame.gather_every(n[, offset])

在LazyFrame中每隔n行取一行,并返回一个新的LazyFrame。

LazyFrame.group_by(*by[, maintain_order])

开始一个分组操作。

LazyFrame.group_by_dynamic(index_column, *, ...)

基于时间值(或类型为Int32、Int64的索引值)进行分组。

LazyFrame.head([n])

获取前n行。

LazyFrame.inspect([fmt])

检查计算图中的一个节点。

LazyFrame.interpolate()

插值中间值。

LazyFrame.join(other[, on, how, left_on, ...])

向逻辑计划中添加一个连接操作。

LazyFrame.join_asof(other, *[, left_on, ...])

执行一个asof连接。

LazyFrame.join_where(other, *predicates[, ...])

基于一个或多个(不)等式谓词执行连接。

LazyFrame.last()

获取DataFrame的最后一行。

LazyFrame.limit([n])

获取前n行。

LazyFrame.melt([id_vars, value_vars, ...])

将DataFrame从宽格式转换为长格式。

LazyFrame.merge_sorted(other, key)

取两个已排序的DataFrame并按排序键合并它们。

LazyFrame.rename(mapping, *[, strict])

重命名列名。

LazyFrame.reverse()

反转DataFrame。

LazyFrame.rolling(index_column, *, period[, ...])

基于时间或整数列创建滚动组。

LazyFrame.select(*exprs, **named_exprs)

从这个LazyFrame中选择列。

LazyFrame.select_seq(*exprs, **named_exprs)

从这个LazyFrame中选择列。

LazyFrame.set_sorted(column, *[, descending])

指示一个或多个列已排序。

LazyFrame.shift([n, fill_value])

将值按给定的索引数进行移动。

LazyFrame.slice(offset[, length])

获取此DataFrame的一个切片。

LazyFrame.sort(by, *more_by[, descending, ...])

按给定的列对LazyFrame进行排序。

LazyFrame.sql(query, *[, table_name])

对LazyFrame执行SQL查询。

LazyFrame.tail([n])

获取最后 n 行。

LazyFrame.top_k(k, *, by[, reverse])

返回k个最大的行。

LazyFrame.unique([subset, keep, maintain_order])

从这个DataFrame中删除重复的行。

LazyFrame.unnest(columns, *more_columns)

将结构体列分解为每个字段的单独列。

LazyFrame.unpivot([on, index, ...])

将DataFrame从宽格式转换为长格式。

LazyFrame.update(other[, on, how, left_on, ...])

使用other中的值更新此LazyFrame中的值。

LazyFrame.with_columns(*exprs, **named_exprs)

向此LazyFrame添加列。

LazyFrame.with_columns_seq(*exprs, **named_exprs)

向此LazyFrame添加列。

LazyFrame.with_context(other)

向计算图添加外部上下文。

LazyFrame.with_row_count([name, offset])

在第0列添加一个用于计算行数的列。

LazyFrame.with_row_index([name, offset])

在LazyFrame中添加一行索引作为第一列。