pyflink.multimodal.operators.audio_duration#

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

Return audio duration in seconds.

Parameters

*columns – Optional audio columns. Supported inputs are BYTES, URI STRING, AUDIO_CLIP_REF, and AUDIO_WAVEFORM.
concurrency – UDF concurrency. None uses the framework default.

Returns

A UDF producing DOUBLE seconds, or NULL when duration is unavailable. Corrupt supported encoded inputs also return NULL as row-level dirty data. URI access errors, dependency errors, unsupported input kinds, and unexpected internal errors still fail fast.

Raises

ValueError – If a row value is not BYTES, URI STRING, AUDIO_CLIP_REF, or AUDIO_WAVEFORM.

Examples::

>>> # Usage 1: create a reusable UDF and apply it to a column.
>>> duration = audio_duration()
>>> df = df.with_column("seconds", duration(col("audio")))
>>>
>>> # Usage 2: pass the column directly when building the expression.
>>> df = df.with_column(
...     "seconds",
...     audio_duration(col("audio")),
... )