pyflink.multimodal.operators.image_compress#

image_compress(*columns, quality=85, format='JPEG', concurrency=None)[source]#

Compress an image to encoded bytes with the specified format and quality.

The input may be raw encoded image bytes or a decoded image value. The output is always newly encoded image bytes. Corrupt encoded bytes return None; malformed decoded image input may fail fast.

Parameters

*columns – Optional image columns. When provided, the UDF is applied directly instead of returning a factory.
quality – Compression quality (1-100). Default 85.
format – Output image format, e.g. "JPEG", "PNG", "WEBP". Default "JPEG".
concurrency – UDF concurrency. None uses the framework default.

Returns

A UDF producing encoded image bytes.

Example::

>>> # As a reusable variable
>>> compress = image_compress(quality=60)
>>> df = df.with_columns("compressed", compress(col("img")))
>>>
>>> # Inline
>>> df = df.with_columns("compressed", image_compress(col("img"), quality=60))