code: def data_collection_API_register():
      data_colection_API_names = [
          "stream",
          "unstream",
          "map",
          "filter",
          "zip",
          "batch",
          "rolling",
          # "flaten",
          "exception_safe",
          "safe",
          "fill_empty",
          "drop_empty",
          "pmap",
          "mmap",
          "set_parallel",
      ]
  
      # skip multiple threads tests for memory shortage
      skipped_API = []
  
      return data_colection_API_names, skipped_API
  
file_path: towhee/tests/testcases/test_main.py
imports: from operator import methodcaller
  from test_image_embedding import *
  from test_data_collection import *
  from test_command import *
label_desc: Use image node_id 7 for calling a global function with example usage: data_collection_API_register() and returns: data_colection_API_names,  skipped_API