daft.functions.chunk#

def chunk(list_expr: Expression, size: int) -> Expression:
    """Splits each list into chunks of the given size.

    Args:
        list_expr (List Expression): expression to chunk
        size (int): size of chunks to split the list into. Must be greater than 0

    Returns:
        Expression (List[FixedSizedList] Expression):
            expression with lists of fixed size lists of the type of the list values
    """
    return Expression._call_builtin_scalar_fn("list_chunk", list_expr, size)