LazyFilterResult#

class dataframely.filter_result.LazyFilterResult[source]#

Container for results of calling Schema.filter() on a lazy frame.

Methods:

collect_all

Collect the results from the filter operation.

Attributes:

failure

Information about the rows that failed validation.

result

The rows that passed validation.

collect_all(
**kwargs: Any,
) FilterResult[S][source]#

Collect the results from the filter operation.

Using this method is more efficient than individually calling collect() on both the result and failure objects as this method takes advantage of common subplan elimination.

Parameters:

kwargs – Keyword arguments passed directly to polars.collect_all().

Returns:

The collected filter result.

Attention

Until pola-rs/polars#24129 is released, the performance advantage of this method is limited.

failure: FailureInfo[S]#

Information about the rows that failed validation.

result: LazyFrame[S]#

The rows that passed validation.