Module Polars_async.Lazy_frame

include module type of Polars.Lazy_frame
val scan_parquet : string -> (t, string) Core.result
val scan_parquet_exn : string -> t
val scan_csv : string -> (t, string) Core.result
val scan_csv_exn : string -> t
val scan_jsonl : string -> (t, string) Core.result
val scan_jsonl_exn : string -> t
val explain : ?optimized:bool -> t -> (string, string) Core.result
val explain_exn : ?optimized:bool -> t -> string
val to_dot : ?optimized:bool -> t -> (string, string) Core.result
val to_dot_exn : ?optimized:bool -> t -> string
val cache : t -> t
type profile_result = Polars.Lazy_frame.profile_result = {
  1. collected : Polars.Data_frame0.t;
  2. profile : Polars.Data_frame0.t;
}
val filter : t -> predicate:Polars.Expr.t -> t
val select : t -> exprs:Polars.Expr.t list -> t
val with_columns : t -> exprs:Polars.Expr.t list -> t
val groupby : ?is_stable:bool -> t -> by:Polars.Expr.t list -> agg:Polars.Expr.t list -> t
val groupby_dynamic : ?every:string -> ?period:string -> ?offset:string -> ?truncate:bool -> ?include_boundaries:bool -> ?closed_window:[ `Both | `Left | `None_ | `Right ] -> ?start_by: [ `Data_point | `Friday | `Monday | `Saturday | `Sunday | `Thursday | `Tuesday | `Wednesday | `Window_bound ] -> ?check_sorted:bool -> t -> index_column:Polars.Expr.t -> by:Polars.Expr.t list -> agg:Polars.Expr.t list -> t
val join : t -> other:t -> on:Polars.Expr.t list -> how:Polars.Join_type.t -> t
val join' : t -> other:t -> left_on:Polars.Expr.t list -> right_on:Polars.Expr.t list -> how:Polars.Join_type.t -> t
val concat : ?how:[ `Diagonal | `Vertical | `Vertical_relaxed ] -> ?rechunk:bool -> ?parallel:bool -> t list -> t
val melt : ?variable_name:string -> ?value_name:string -> ?streamable:bool -> t -> id_vars:string list -> value_vars:string list -> t
val sort : ?descending:bool -> ?nulls_last:bool -> t -> by_column:string -> t
val limit : t -> n:int -> t
val explode : t -> columns:Polars.Expr.t list -> t
val with_streaming : t -> toggle:bool -> t
val schema : t -> (Polars.Schema.t, string) Core.result
val schema_exn : t -> Polars.Schema.t
val collect : ?streaming:bool -> t -> (Polars.Data_frame.t, string) Core.result Async.Deferred.t
val collect_exn : ?streaming:bool -> t -> Polars.Data_frame.t Async.Deferred.t
val collect_all : t list -> (Polars.Data_frame.t list, string) Core.result Async.Deferred.t
val collect_all_exn : t list -> Polars.Data_frame.t list Async.Deferred.t
val profile : t -> (profile_result, string) Core.result Async.Deferred.t
val profile_exn : t -> profile_result Async.Deferred.t
val fetch : t -> n_rows:int -> (Polars.Data_frame.t, string) Core.result Async.Deferred.t
val fetch_exn : t -> n_rows:int -> Polars.Data_frame.t Async.Deferred.t