Skip to content

daft.functions.decompress#

decompress #

decompress(bytes: Expression, codec: COMPRESSION_CODEC) -> Expression

Decompress binary values using the specified codec.

Parameters:

Name Type Description Default
bytes Binray Expression

The binary expression to decompress.

required
codec str

The decompression codec (deflate, gzip, zlib)

required

Returns:

Name Type Description
Expression Expression

A binary expression with the decoded values.

Examples:

1
2
3
4
5
>>> import zlib
>>> import daft
>>> from daft.functions import decompress
>>> df = daft.from_pydict({"bytes": [zlib.compress(b"hello, world!")]})
>>> df.select(decompress(df["bytes"], "zlib")).show()
╭──────────────────╮
│ bytes            │
│ ---              │
│ Binary           │
╞══════════════════╡
│ b"hello, world!" │
╰──────────────────╯
(Showing first 1 of 1 rows)
Source code in daft/functions/binary.py
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
def decompress(bytes: Expression, codec: COMPRESSION_CODEC) -> Expression:
    """Decompress binary values using the specified codec.

    Args:
        bytes (Binray Expression): The binary expression to decompress.
        codec (str): The decompression codec (deflate, gzip, zlib)

    Returns:
        Expression: A binary expression with the decoded values.

    Examples:
        >>> import zlib
        >>> import daft
        >>> from daft.functions import decompress
        >>> df = daft.from_pydict({"bytes": [zlib.compress(b"hello, world!")]})
        >>> df.select(decompress(df["bytes"], "zlib")).show()
        ╭──────────────────╮
        │ bytes            │
        │ ---              │
        │ Binary           │
        ╞══════════════════╡
        │ b"hello, world!" │
        ╰──────────────────╯
        <BLANKLINE>
        (Showing first 1 of 1 rows)

    """
    return Expression._call_builtin_scalar_fn("decode", bytes, codec=codec)