pyflink.multimodal.operators.image_convert_format#

image_convert_format(*columns, format, concurrency=None)[source]#

Convert encoded image bytes to a different encoded format.

The input and output are both encoded image bytes. Use image_encode for decoded image input.

Parameters

*columns – Optional image columns. When provided, the UDF is applied directly instead of returning a factory.
format – Target image format (required), e.g. "PNG", "JPEG", "WEBP", "BMP".
concurrency – UDF concurrency. None uses the framework default.

Returns

A UDF producing encoded image bytes.

Example::

>>> # As a reusable variable
>>> convert_fmt = image_convert_format(format="PNG")
>>> df = df.with_columns("png_img", convert_fmt(col("img")))
>>>
>>> # Inline
>>> df = df.with_columns("png_img", image_convert_format(col("img"), format="PNG"))