pyflink.multimodal.expression.AudioExpressionAccessor.convert_format

AudioExpressionAccessor.convert_format(*, format: str = 'wav', on_error: Literal['raise', 'null'] = 'raise', max_decoded_bytes: int = 1073741824, concurrency: Optional[int] = None) → pyflink.table.expression.Expression

Convert encoded audio to another encoded format.

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

Parameters

• format – Encoded output format.

• on_error – "raise" to propagate decode failures, or "null" to return null for rows that cannot be decoded.

• max_decoded_bytes – Maximum decoded PCM payload allowed during conversion.

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

Returns

A DataFrame expression that produces encoded BINARY audio bytes.