pyflink.multimodal.expression.ImageExpressionAccessor.compress

ImageExpressionAccessor.compress(*, quality: int = 85, format: str = 'JPEG', concurrency: Optional[int] = None) → pyflink.table.expression.Expression

Compress image values using the requested format and quality.

Equivalent to image_compress(). See that function for full parameter details.

Parameters

• quality – Output quality for lossy compression.

• format – Output image format used for compression.

• concurrency – Optional execution concurrency for this operation. None uses the framework default.

Returns

A DataFrame expression that produces compressed BINARY image bytes.