pyflink.multimodal.expression.AudioExpressionAccessor.split_by_duration#

AudioExpressionAccessor.split_by_duration(*, segment_duration_ms: int, segment_type: Literal['audio', 'ref'] = 'audio', max_segments: int = 1024, concurrency: Optional[int] = None) → pyflink.dataframe.udf.DataFrameUDTFCall[source]#

Split audio by fixed duration.

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

Parameters

segment_duration_ms – Segment duration in milliseconds.
segment_type – "audio" for waveform segments or "ref" for lazy reference segments.
max_segments – Maximum allowed number of returned segments.
concurrency – Optional execution concurrency for this operation. None uses the framework default.

Returns

A DataFrame UDTF call for join_lateral. Alias the output as one segment column, for example df.join_lateral( col("waveform").audio.split_by_duration( segment_duration_ms=1000).alias("segment")).