pyflink.multimodal.operators.image_blur#

image_blur(*columns, radius=2, blur_type='gaussian', concurrency=None)[source]#

Apply blur to an image.

Parameters

*columns – Optional image columns. When provided, the UDF is applied directly instead of returning a factory.
radius – Blur radius in pixels. Default 2.
blur_type – Blur algorithm — "gaussian" (default), "box", or "mean". "box" applies a box blur with the given radius; "mean" uses PIL’s fixed-kernel mean blur (Data-Juicer compatible).
concurrency – UDF concurrency. None uses the framework default.

Returns

A UDF producing decoded image values.

Example::

>>> # As a reusable variable
>>> blur = image_blur(radius=3)
>>> df = df.with_columns("blurred", blur(col("img")))
>>>
>>> # Inline
>>> df = df.with_columns("blurred", image_blur(col("img"), radius=3))