code: def load_aggregate_function(payload):
      if is_built_in_function(payload):
          built_in_function_class_name = payload[1:].decode("utf-8")
          cls = getattr(functions, built_in_function_class_name)
          return cls()
      else:
          return pickle.loads(payload)
  
imports: import datetime
  import threading
  import time
  from collections.abc import Generator
  from functools import partial
  from typing import Any, Tuple, Dict, List
  from pyflink.common import Row
  from pyflink.fn_execution import pickle
  from pyflink.serializers import PickleSerializer
  from pyflink.table import functions
  from pyflink.table.udf import DelegationTableFunction, DelegatingScalarFunction, ImperativeAggregateFunction, PandasAggregateFunctionWrapper
label_desc: Use image node_id 10 for calling a global function with example usage: load_aggregate_function(payload) and returns: cls, pickle