pyflink.multimodal.expression.VideoExpressionAccessor.metadata#

VideoExpressionAccessor.metadata(*, on_error: Literal['raise', 'null'] = 'raise', container_options: Optional[Mapping[str, str]] = None, read_chunk_size: Optional[int] = None, max_cached_blocks: Optional[int] = None, read_ahead_blocks: Optional[int] = None, concurrency: Optional[int] = None) → pyflink.table.expression.Expression[source]#

Probe video metadata for this expression.

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

Parameters

on_error – "raise" to propagate failures, or "null" to return None for unreadable inputs.
container_options – Optional PyAV av.open options.
read_chunk_size – Optional read chunk size in bytes for video files.
max_cached_blocks – Optional number of read chunks to cache per opened video.
read_ahead_blocks – Optional number of chunks to prefetch after a read.
concurrency – Optional execution concurrency for this operation. None uses the framework default.

Returns

A DataFrame expression that produces a video metadata ROW with width, height, fps, duration_ms, frame_count, time_base, codec_name, and video_stream_index fields.