Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/OpenDCAI/DataFlow-MM
/ functions
Functions
991 in github.com/OpenDCAI/DataFlow-MM
⨍
Functions
991
◇
Types & classes
216
Method
_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/qwen_audio/qwen_audio_2.py:63
Method
_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/unifiedreward_qwen/unifiedreward.py:64
Method
_conversation_to_message
将格式1的数据转换为格式2。 支持多轮对话和多模态(图片、视频、音频),并验证token数量。
dataflow/io/qwen_vl/qwen_vl_2_5.py:106
Function
_convert_image_to_rgb
(image)
dataflow/operators/core_vision/eval/image_text/model/longclip.py:31
Function
_convert_weights_to_fp16
(l)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:491
Function
_copy_scripts
()
dataflow/cli_funcs/cli_init.py:7
Function
_custom_collate_fn
Custom collate function for DataLoader since we have variable-length image lists. We don't stack images; we just return lists.
dataflow/operators/core_vision/eval/video_ocr_evaluator.py:302
Function
_exists
(v: Any)
dataflow/operators/core_vision/filter/video_info_filter.py:300
Function
_fps_from_info
(v: Any)
dataflow/operators/core_vision/filter/video_scene_filter.py:446
Function
_init_worker
(devices, model_init_args)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:46
Function
_init_worker
(devices, model_init_args)
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:19
Method
_is_base64
check whether string is validate base64
dataflow/serving/api_vlm_serving_openai.py:328
Method
_load_images_for_gemini
Load multiple image files, return PIL Image object list
dataflow/serving/api_image_gen_serving.py:382
Function
_parallel_worker
子进程工作函数
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:54
Function
_parallel_worker
子进程工作函数
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:330
Method
_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_luminance_filter.py:225
Method
_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_aesthetic_filter.py:220
Method
_pass
(v: Optional[float])
dataflow/operators/core_vision/filter/video_ocr_filter.py:242
Function
_path_from_cell
(v: Any)
dataflow/operators/core_vision/filter/video_scene_filter.py:438
Method
_process_audio_chunk_static
静态方法封装,给多进程用
dataflow/operators/core_audio/generaterow/audio_timestamp_chunk_row_generator.py:230
Function
_process_job
Top-level picklable worker for ProcessPoolExecutor.
dataflow/operators/core_vision/filter/video_scene_filter.py:46
Method
_send_conversation_request_with_id
发送带有对话历史的单个请求 :param idx: 请求索引 :param conversation: 对话历史 :param image_paths: 图像路径列表 :param video_pat
dataflow/serving/api_vlm_serving_openai.py:830
Method
_send_single_request_with_id
发送单个请求并返回结果 :param idx: 请求索引 :param prompt: 文本提示 :param image_paths: 图像路径列表 :param video_paths: 视频路径
dataflow/serving/api_vlm_serving_openai.py:619
Function
_sort_key
(rec: Dict[str, Any])
dataflow/operators/core_vision/filter/video_info_filter.py:338
Function
_worker
(task_queue, results_queue, task_params, process_id)
dataflow/operators/core_vision/generate/video_clip_generator.py:119
Method
analyze_images_with_gpt_with_id
Batch-tracked version of `analyze_images_with_gpt`, returning (request_id, analysis). :param image_paths: List of image file paths.
dataflow/serving/api_vlm_serving_openai.py:417
Method
api_chat
(self, system_info: str, messages: str, model: str)
dataflow/serving/api_llm_serving_request.py:50
Method
api_chat_with_id
(system_info: str, messages: str, model: str, id)
dataflow/serving/api_llm_serving_request.py:80
Method
apply_wrapper
(row)
dataflow/operators/core_text/refine/functional_refiner.py:52
Method
build_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/qwen_audio/qwen_audio_2.py:32
Method
build_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/unifiedreward_qwen/unifiedreward.py:28
Method
build_full_prompts
输入: messages -> list of list (每个元素是聊天序列) 输出: full_prompts -> list of dict {prompt, multi_modal_data}
dataflow/io/qwen_vl/qwen_vl_2_5.py:27
Method
build_message
( self, user_inputs: list[list[dict]], image_list: list[list[str]] = None, vid
dataflow/io/qwen_vl/qwen_vl_2_5.py:63
Method
build_prompt
参数: - need_fields: 本次会使用到的字段名集合(来自算子的 input_keys.keys()) - kwargs: 每个字段名 -> 该行的值(来自 DataFrame) 逻辑: - 对于每个字段名
dataflow/prompts/prompt_template.py:33
Method
build_prompt
(self)
dataflow/prompts/image.py:11
Method
build_prompt
(self)
dataflow/prompts/image.py:25
Method
build_prompt
(self)
dataflow/prompts/image.py:79
Method
build_prompt
(self)
dataflow/prompts/image.py:96
Method
build_prompt
(self)
dataflow/prompts/image.py:132
Method
build_prompt
(self)
dataflow/prompts/image.py:176
Method
build_prompt
Generate system prompt for video quality evaluation.
dataflow/prompts/video.py:15
Method
build_prompt
(self, caption: str)
dataflow/prompts/video.py:29
Method
build_prompt
Generate prompt for CoT QA generation with question parameter.
dataflow/prompts/video.py:71
Method
build_prompt
(self, data)
dataflow/prompts/prompt_generator.py:6
Method
chat_with_one_image_with_id
Same as `chat_with_one_image` but returns a tuple of (request_id, response). :param request_id: Arbitrary identifier for tracking th
dataflow/serving/api_vlm_serving_openai.py:256
Method
chntext2cardinal
(self)
dataflow/operators/core_audio/refine/cn_tn.py:757
Method
chntext2fraction
(self)
dataflow/operators/core_audio/refine/cn_tn.py:822
Method
chntext2percentage
(self)
dataflow/operators/core_audio/refine/cn_tn.py:921
Method
cleanup
Cleanup the generator and garbage collect all GPU/CPU memory.
dataflow/core/LLMServing.py:16
Method
cleanup
(self)
dataflow/serving/local_model_llm_serving.py:123
Method
cleanup
(self)
dataflow/serving/local_model_llm_serving.py:310
Method
cleanup
(self)
dataflow/serving/api_llm_serving_request.py:174
Method
cleanup
Clean up any resources (e.g., close HTTP connections).
dataflow/serving/api_vlm_serving_openai.py:496
Method
cleanup
Clear pipelines and free GPU memory.
dataflow/serving/local_image_gen_serving.py:248
Method
cleanup
Cleanup resources.
dataflow/serving/lite_llm_serving.py:396
Method
cleanup
(self)
dataflow/serving/local_model_vlm_serving.py:213
Method
cleanup
(self)
dataflow/serving/local_model_vlm_serving.py:447
Method
cleanup
(self)
dataflow/serving/api_image_gen_serving.py:749
Method
close
(self)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:350
Method
close
(self)
dataflow/operators/core_audio/filter/audio_ctc_forced_alignment_transcription_quality_filter.py:230
Method
close
(self)
dataflow/operators/core_audio/generate/audio_silero_voice_activity_detection_timestamps_generator.py:325
Method
compute_bleu_score
Calculate BLEU score.
dataflow/operators/core_vision/eval/general_text_answer_evaluator.py:84
Function
compute_correlation_uniquehuman
(pred, all_human_scores)
dataflow/utils/utils.py:52
Method
convert_chinese_to_pinyin
(text: str)
dataflow/operators/core_audio/eval/audio_ctc_forced_alignment_transcription_quality_evaluator.py:257
Function
copy_file
Copy a single file with path, with checking and asking about the existence.
dataflow/cli_funcs/copy_funcs.py:5
Function
copy_files_without_recursion
Copy files under a path without recursion, with checking and asking about the existence.
dataflow/cli_funcs/copy_funcs.py:23
Method
create
(cls, i, v)
dataflow/operators/core_audio/refine/cn_tn.py:457
Method
current_timestep
(self)
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:716
Method
deco
(func_or_class)
dataflow/utils/registry.py:96
Method
disable_vae_slicing
r""" Disable sliced VAE decoding. If `enable_vae_slicing` was previously enabled, this method will go back to computing decoding in on
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:617
Method
disable_vae_tiling
r""" Disable tiled VAE decoding. If `enable_vae_tiling` was previously enabled, this method will go back to computing decoding in one
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:634
Method
dtype
(self)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:350
Method
duration_sec
(self)
dataflow/operators/core_vision/filter/video_scene_filter.py:102
Function
em_cos_score
Compute EMScore. Args: - :param: `model` : a BERT model in `pytorch_pretrained_bert` - :param: `refs` (list of str): referen
dataflow/utils/utils.py:265
Method
embed_with_retry
(text: str, retry_times: int = 3)
dataflow/serving/lite_llm_serving.py:349
Method
enable_vae_slicing
r""" Enable sliced VAE decoding. When this option is enabled, the VAE will split the input tensor in slices to compute decoding in sev
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:609
Method
enable_vae_tiling
r""" Enable tiled VAE decoding. When this option is enabled, the VAE will split the input tensor into tiles to compute decoding and en
dataflow/serving/utils/diffusers/flux_kontext_pipeline.py:625
Method
encode_text_full
(self, text)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:372
Function
extract_clean_cot_logic
[For FunctionalRefiner] 仅返回清洗后的 CoT 文本
dataflow/statics/pipelines/gpu_pipelines/image_gcot_pipeline.py:44
Function
extract_clean_cot_logic
[For FunctionalRefiner] 仅返回清洗后的 CoT 文本
dataflow/statics/pipelines/api_pipelines/image_gcot_api_pipeline.py:47
Function
extract_keywords_logic
[For FunctionalRefiner] 提取并合并关键词
dataflow/statics/pipelines/gpu_pipelines/image_gcot_pipeline.py:48
Function
extract_keywords_logic
[For FunctionalRefiner] 提取并合并关键词
dataflow/statics/pipelines/api_pipelines/image_gcot_api_pipeline.py:51
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:93
Method
forward
Args: images_bnc: (B, N, C, H, W) preprocessed images Returns: scores: (B,) averaged aesthetic score per clip
dataflow/operators/core_vision/eval/video_aesthetic_evaluator.py:125
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:42
Method
forward
(self, x)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:68
Method
forward
(self, x)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:138
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:160
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:167
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:189
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:202
Method
forward
(self, x: torch.Tensor)
dataflow/operators/core_vision/eval/image_text/model/model_longclip.py:223
Method
generate_derivative_question
(self, fn: "MultimodalMathGenerator.MathFunction")
dataflow/operators/core_vision/generate/multimodal_math_generator.py:169
Method
generate_embedding_from_input
(self, texts: list[str])
dataflow/serving/local_model_llm_serving.py:119
Method
generate_embedding_from_input
Generate embeddings for a list of texts. Args: texts: List of text strings to embed Returns
dataflow/serving/lite_llm_serving.py:319
Method
generate_extremum_question
(self, fn: "MultimodalMathGenerator.MathFunction")
dataflow/operators/core_vision/generate/multimodal_math_generator.py:179
Method
generate_from_conversations
(self, conversations: list[list[dict]])
dataflow/serving/api_llm_serving_request.py:128
Method
generate_from_input
(self, *args, **kwargs)
test/test_data_selection.py:36
Method
generate_from_input
(self, user_inputs: list[str], system_prompt: str =
dataflow/serving/local_model_llm_serving.py:99
Method
generate_from_input
(self, user_inputs: list[str], system_prompt: str = "
dataflow/serving/local_model_llm_serving.py:285
← previous
next →
701–800 of 991, ranked by callers