MCPcopy Create free account

hub / github.com/OpenDCAI/DataFlow-MM / functions

Functions991 in github.com/OpenDCAI/DataFlow-MM

↓ 2 callersMethod_send_chat_request
Send a chat completion request to the OpenAI API and return the generated content. :param model: Model name for the request.
dataflow/serving/api_vlm_serving_openai.py:192
↓ 2 callersFunction_timecode_to_seconds
Convert timecode to seconds. Accepts integer seconds or 'HH:MM:SS.mmm' string format.
dataflow/operators/core_vision/generate/video_merged_caption_generator.py:13
↓ 2 callersFunction_to_frame_idx
(sec: Optional[float], fps: Optional[float])
dataflow/operators/core_vision/filter/video_clip_filter.py:56
↓ 2 callersFunction_to_secs
Parse 'HH:MM:SS.mmm' -> seconds as float; return None if invalid.
dataflow/operators/core_vision/filter/video_clip_filter.py:48
↓ 2 callersMethod_triples_and_has_verb
(self, doc)
dataflow/operators/core_vision/filter/cat_filter.py:47
↓ 2 callersMethod_validate_setup
Validate the model and API configuration.
dataflow/serving/lite_llm_serving.py:178
↓ 2 callersFunctionapply_aesthetic_filter
Apply aesthetic score filtering to clips. Args: dataframe: DataFrame with video_clips column containing aesthetic_score
dataflow/operators/core_vision/filter/video_aesthetic_filter.py:32
↓ 2 callersFunctionapply_luminance_filter
Apply luminance filtering to clips. Args: dataframe: DataFrame with video_clips column containing luminance_mean video_c
dataflow/operators/core_vision/filter/video_luminance_filter.py:32
↓ 2 callersFunctionapply_ocr_filter
Apply OCR score filtering to clips. Args: dataframe: DataFrame with video_clips column containing ocr_score video_clips_
dataflow/operators/core_vision/filter/video_ocr_filter.py:32
↓ 2 callersMethodbuild_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/whisper/whisper.py:31
↓ 2 callersFunctionbuild_model
(state_dict: dict, load_from_clip: bool)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:512
↓ 2 callersFunctionbytes_to_unicode
Returns list of utf-8 byte and a corresponding list of unicode strings. The reversible bpe codes work on unicode strings. This means you
dataflow/operators/core_vision/eval/image_text/model/simple_tokenizer.py:16
↓ 2 callersFunctionclean_markdown_markers
清洗字符串中的 markdown 标记,比如 **bold** 或 *italic*。 用于处理嵌套 bold (e.g. **Title **Sub** End**) 的情况。
dataflow/operators/core_vision/refine/wiki_qa_refiner.py:12
↓ 2 callersMethodcompute_similarity
(self, image_path: str, text: str)
dataflow/operators/core_vision/filter/image_clip_filter.py:49
↓ 2 callersMethodcreate_function_plot
(self, func, x_range, img_path)
dataflow/operators/core_vision/generate/multimodal_math_generator.py:107
↓ 2 callersFunctioncreate_system
根据数字系统类型返回创建相应的数字系统,默认为 mid NUMBERING_TYPES = ['low', 'mid', 'high']: 中文数字系统类型 low: '兆' = '亿' * '十' = $10^{9}$, '京' = '兆' * '十', et
dataflow/operators/core_audio/refine/cn_tn.py:518
↓ 2 callersMethoddigit2chntext
(self)
dataflow/operators/core_audio/refine/cn_tn.py:775
↓ 2 callersMethodencode_prompt
r""" Args: prompt (`str` or `List[str]`, *optional*): prompt to be encoded prompt_2 (`str` or `List[s
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:355
↓ 2 callersMethodensure_head
Instantiate the MLP head if not yet created; optionally load weights.
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:114
↓ 2 callersMethodextract_answer
Extract content between <answer> and </answer> tags.
dataflow/operators/core_vision/eval/general_text_answer_evaluator.py:46
↓ 2 callersFunctionextract_letter_only
提取大模型回复中的选项字母
dataflow/operators/core_vision/refine/visual_dependency_refiner.py:53
↓ 2 callersFunctionframe_to_time
(frame_idx)
dataflow/operators/core_audio/generaterow/audio_timestamp_chunk_row_generator.py:384
↓ 2 callersMethodgenerate_from_input_with_message
(self, *args, **kwargs)
test/test_data_selection.py:21
↓ 2 callersMethodgenerate_prompt
(self, language: Optional[str] = None, task: str = "transcribe", with_timestamps: bool = False)
dataflow/prompts/audio.py:131
↓ 2 callersMethodget_dataflow_statics_dir
()
dataflow/cli_funcs/paths.py:25
↓ 2 callersFunctionget_env_info
()
dataflow/cli_funcs/cli_env.py:14
↓ 2 callersMethodget_obj_map
Get the object map of the registry.
dataflow/utils/registry.py:179
↓ 2 callersFunctionget_pairs
Return set of symbol pairs in a word. Word is represented as tuple of symbols (symbols being variable-length strings).
dataflow/operators/core_vision/eval/image_text/model/simple_tokenizer.py:38
↓ 2 callersFunctionget_symbol
(char, system)
dataflow/operators/core_audio/refine/cn_tn.py:562
↓ 2 callersFunctionlength_to_mask
(lens)
dataflow/utils/utils.py:361
↓ 2 callersFunctionnormalize_matrix
(A)
dataflow/utils/utils.py:78
↓ 2 callersMethodprepare_ip_adapter_image_embeds
( self, ip_adapter_image, ip_adapter_image_embeds, device, num_images_per_prompt )
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:447
↓ 2 callersMethodprocess_audio_file
( self, audio_path: str, text: str, **kwargs, )
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:368
↓ 2 callersMethodprocess_audio_file
处理单个音频文件的完整流程。
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:374
↓ 2 callersFunctionprocess_audio_info
类似于 vision 的 process_vision_info,从 message 列表中提取音频输入。 支持三种格式输入: - 本地或 http(s) URL 路径(通过 librosa 接口处理) - base64 编码 (data:audio/…;b
dataflow/utils/audio.py:34
↓ 2 callersFunctionprocess_judgment
(judgment_str: str)
dataflow/utils/opencompass_verifier.py:103
↓ 2 callersFunctionretrieve_latents
( encoder_output: torch.Tensor, generator: Optional[torch.Generator] = None, sample_mode: str = "sample" )
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:174
↓ 2 callersFunctionscore_aesthetics_over_dataframe
Compute aesthetic scores per clip and inject them back into `video_clips`. Args: dataframe: upstream df with `video` and `video_clip
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:324
↓ 2 callersFunctionscore_luminance_over_dataframe
Compute luminance stats (mean/min/max) per clip and inject them into `video_clips`. Args: dataframe: upstream df with `video` and `v
dataflow/operators/core_vision/eval/video_luminance_evaluator.py:278
↓ 2 callersFunctionscore_ocr_over_dataframe
Compute OCR scores per clip and inject them into `video_clips`. Uses DataLoader for efficient batch processing with multi-worker data loading
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:356
↓ 2 callersFunctionseconds_to_frame_index
Convert seconds to integer frame index using fps.
dataflow/operators/core_vision/filter/video_scene_filter.py:87
↓ 2 callersFunctionseconds_to_timecode
Convert seconds (float) to 'HH:MM:SS.mmm' timecode.
dataflow/operators/core_vision/filter/video_scene_filter.py:77
↓ 2 callersFunctionshuffle_options_logic
混淆选项逻辑 (保持原版业务逻辑不变)
dataflow/operators/core_vision/refine/visual_dependency_refiner.py:20
↓ 2 callersFunctionsplit_paragraphs
Split a string into paragraphs.
dataflow/operators/core_vision/filter/rule_base_filter.py:22
↓ 2 callersMethodtelephone2chntext
(self, fixed=False)
dataflow/operators/core_audio/refine/cn_tn.py:796
↓ 2 callersFunctiontimecode_to_seconds
Convert 'HH:MM:SS.mmm' timecode into seconds (float).
dataflow/operators/core_vision/filter/video_scene_filter.py:71
↓ 1 callersFunctionBatchWrapper
把一个 OperatorABC 实例包装成按 batch_size 批处理的 Wrapper 同时让 wrapper.run 的函数签名 = operator.run 的签名
dataflow/wrapper/batch_wrapper_backup.py:6
↓ 1 callersMethodPCA
(self, input_tensor, PCA_dim)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:389
↓ 1 callersFunctionVideoCapture
上下文管理器,确保视频资源正确释放
dataflow/operators/core_vision/filter/video_motion_score_filter.py:16
↓ 1 callersMethod__getattr__
动态加载类。 :param item: 类名 :return: 动态加载的类对象
dataflow/utils/registry.py:304
↓ 1 callersMethod__init__
Args: name (str): the name of this registry
dataflow/utils/registry.py:62
↓ 1 callersMethod__init__
(self, repo_or_dir: str, source: str, device: str)
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:357
↓ 1 callersMethod__init__
(self, in_dim: int)
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:80
↓ 1 callersMethod_apply_text_filters
Apply all text filters. Returns True if passed, False if failed.
dataflow/operators/core_vision/filter/rule_base_filter.py:243
↓ 1 callersFunction_aspect_ratio
Compute width/height safely.
dataflow/operators/core_vision/filter/video_info_filter.py:185
↓ 1 callersFunction_aspect_ratio
(width: Optional[int], height: Optional[int])
dataflow/operators/core_vision/filter/video_clip_filter.py:38
↓ 1 callersMethod_build_message_content
构建 OpenAI API 格式的消息内容 :param prompt: 文本提示 :param image_paths: 图像路径列表 :param video_paths: 视频路径列表 :par
dataflow/serving/api_vlm_serving_openai.py:551
↓ 1 callersMethod_build_messages_from_conversation
从对话历史构建 OpenAI API 格式的消息列表 :param conversation: 单个对话历史,格式为 [{"role": "user", "content": "..."}, ...] :param image_pa
dataflow/serving/api_vlm_serving_openai.py:741
↓ 1 callersMethod_build_openai_edit_request
Build OpenAI image editing request (supports DALL-E 2 and gpt-image-1) Returns: (files_dict, data_dict): files dictionary
dataflow/serving/api_image_gen_serving.py:173
↓ 1 callersMethod_build_openai_request
Build a single OpenAI image generation request (supports DALL-E 2/3 and gpt-image-1)
dataflow/serving/api_image_gen_serving.py:92
↓ 1 callersMethod_build_openai_variation_request
Build OpenAI image variation request (only supports DALL-E 2) Returns: (files_dict, data_dict): files dictionary (for mul
dataflow/serving/api_image_gen_serving.py:227
↓ 1 callersMethod_build_prompts
Build one prompt per row using the configured template. Unlike the QA variant, this template does not depend on row fields, so we sim
dataflow/operators/core_vision/generate/video_caption_generator.py:45
↓ 1 callersMethod_build_prompts
(self, df: pd.DataFrame, sks: str)
dataflow/operators/core_vision/generate/personalized_qa_generator.py:91
↓ 1 callersMethod_build_prompts
Build one prompt per row using the template and the caption column. Raises: KeyError: if the required caption column is missing.
dataflow/operators/core_vision/generate/video_qa_generator.py:48
↓ 1 callersMethod_build_prompts
Build one prompt per row using the template and problem information.
dataflow/operators/core_vision/generate/video_cotqa_generator.py:47
↓ 1 callersMethod_build_prompts
Build one prompt per row using the template and problem information.
dataflow/statics/pipelines/gpu_pipelines/video_cotqa_pipeline.py:65
↓ 1 callersMethod_build_prompts
Build one prompt per row using the template and problem information.
dataflow/statics/pipelines/api_pipelines/video_cotqa_api_pipeline.py:65
↓ 1 callersFunction_build_reasoning_chains_from_rollouts
( node_data: Dict[str, Any], backtrack_message: str = "Wait, this seems off. Let's try something else.
dataflow/operators/core_text/refine/mcts_tree_refiner.py:30
↓ 1 callersMethod_build_reformatting_prompts
Build reformatting prompts for each video with valid parsed reasoning. Args: df: DataFrame containing parsed_rea
dataflow/statics/pipelines/api_pipelines/video_longvideo_cotqa_api_pipeline.py:268
↓ 1 callersFunction_build_samples_from_df
( df: pd.DataFrame, input_video_key: str, video_clips_key: str, figure_root: str, )
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:257
↓ 1 callersFunction_build_samples_from_df
Build a list of ClipSample objects from the dataframe. Similar to video_aesthetic_evaluator._build_samples_from_df.
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:185
↓ 1 callersFunction_build_samples_from_df
( df: pd.DataFrame, input_video_key: str, video_clips_key: str, figure_root: str, )
dataflow/operators/core_vision/eval/video_luminance_evaluator.py:177
↓ 1 callersFunction_build_samples_from_df_whole_video
Build samples for whole-video aesthetic scoring (no clip splitting required). Each row produces a single sample, frames will be sampled from
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:277
↓ 1 callersFunction_build_samples_from_df_whole_video
Build samples for whole-video OCR (no clip splitting required). Each row produces a single sample with frames sampled directly from the video
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:216
↓ 1 callersFunction_build_samples_from_df_whole_video
Build samples for whole-video luminance scoring (no clip splitting required). Each row produces a single sample; frames are sampled from vide
dataflow/operators/core_vision/eval/video_luminance_evaluator.py:198
↓ 1 callersMethod_calculate_informativeness
Calculate informativeness using singular value entropy (SVE) of multi-modal token embeddings. Based on DataTailor paper equa
dataflow/operators/core_vision/filter/datatailor_filter.py:169
↓ 1 callersMethod_calculate_representativeness
Calculate representativeness using inter-cluster similarities. Based on DataTailor paper equations (5) and (6): τ_i^
dataflow/operators/core_vision/filter/datatailor_filter.py:289
↓ 1 callersMethod_calculate_resized_dimensions
计算调整后的尺寸
dataflow/operators/core_vision/filter/video_motion_score_filter.py:138
↓ 1 callersMethod_calculate_uniqueness
Calculate uniqueness within clusters using weighted distances. Based on DataTailor paper equation (4): V_i^Uni = ∑||
dataflow/operators/core_vision/filter/datatailor_filter.py:240
↓ 1 callersMethod_calculate_uniqueness_scores
Calculate uniqueness scores based on k-nearest neighbor similarity. Args: embeddings: Image embeddings of shape
dataflow/operators/core_vision/filter/knn_similarity_filter.py:112
↓ 1 callersMethod_call_api
Send API request
dataflow/serving/api_image_gen_serving.py:504
↓ 1 callersMethod_call_gemini_api
Call Gemini API to generate images using google.genai library
dataflow/serving/api_image_gen_serving.py:466
↓ 1 callersMethod_call_gemini_chat_api
Use chat mode for multi-round image editing Returns: list of images generated in the last round
dataflow/serving/api_image_gen_serving.py:393
↓ 1 callersMethod_call_openai_edit_api
Call OpenAI image editing API (/images/edits)
dataflow/serving/api_image_gen_serving.py:257
↓ 1 callersMethod_call_openai_variation_api
Call OpenAI image variation API (/images/variations)
dataflow/serving/api_image_gen_serving.py:310
↓ 1 callersMethod_check_image_basic
Check basic image properties.
dataflow/operators/core_vision/filter/rule_base_filter.py:204
↓ 1 callersMethod_check_nsfw_content
Check if image contains NSFW content. Returns True if safe, False if NSFW.
dataflow/operators/core_vision/filter/rule_base_filter.py:225
↓ 1 callersFunction_clips_from_cell
(cell: Any)
dataflow/operators/core_vision/filter/video_frame_filter.py:91
↓ 1 callersMethod_cluster_samples
Perform hierarchical clustering on sample embeddings.
dataflow/operators/core_vision/filter/datatailor_filter.py:217
↓ 1 callersMethod_compute_clip_scores
Compute CLIP scores between images and their corresponding texts. Args: images: List of images in various format
dataflow/operators/core_vision/filter/clipscore_filter.py:57
↓ 1 callersMethod_compute_flow
计算两帧之间的光流
dataflow/operators/core_vision/filter/video_motion_score_filter.py:173
↓ 1 callersFunction_compute_indices
Determine which local indices (0..num_frames-1) to save. - If interval_sec provided & fps>0 -> stride by round(interval_sec*fps), min 1.
dataflow/operators/core_vision/filter/video_frame_filter.py:112
↓ 1 callersFunction_compute_luminance_stats
Compute luminance statistics for a stack of frames. Args: images_uint8: (N, C, H, W) uint8 in [0,255], C=3 RGB Returns: (
dataflow/operators/core_vision/eval/video_luminance_evaluator.py:215
↓ 1 callersFunction_compute_ocr_score_for_images
Compute OCR text area ratio for a list of images. Args: images: List of image arrays (numpy arrays from cv2) clip_height
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:246
↓ 1 callersMethod_compute_video_motion_score
计算单个视频的运动分数
dataflow/operators/core_vision/filter/video_motion_score_filter.py:189
↓ 1 callersMethod_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/operators/conversations/format/conversation_to_message.py:49
↓ 1 callersFunction_copy_examples
()
dataflow/cli_funcs/cli_init.py:29
↓ 1 callersFunction_copy_pipelines
()
dataflow/cli_funcs/cli_init.py:16
↓ 1 callersFunction_copy_playground
()
dataflow/cli_funcs/cli_init.py:23
↓ 1 callersFunction_cos_sim_unit
(a: torch.Tensor, b: torch.Tensor)
dataflow/operators/core_vision/eval/image_clip_evaluator.py:13
← previousnext →101–200 of 991, ranked by callers