code: def create_one_input_user_defined_data_stream_function_from_protos(
      function_infos,
      input_coder_info,
      output_coder_info,
      runtime_context,
      function_context,
      timer_context,
      side_output_context,
      job_parameters,
      keyed_state_backend,
      operator_state_backend,
  ):
      serialized_fns = [
          pare_user_defined_data_stream_function_proto(proto)
          for proto in function_infos
      ]
      input_data_converter = from_type_info_proto(
          parse_coder_proto(input_coder_info).raw_type.type_info
      )
      output_data_converter = from_type_info_proto(
          parse_coder_proto(output_coder_info).raw_type.type_info
      )
  
      function_operation = OneInputFunctionOperation(
          serialized_fns,
          input_data_converter,
          output_data_converter,
          runtime_context,
          function_context,
          timer_context,
          side_output_context,
          job_parameters,
          keyed_state_backend,
          operator_state_backend,
      )
  
      return function_operation
  
file_path: flink/flink-python/pyflink/fn_execution/embedded/operation_utils.py
imports: from pyflink.fn_execution.embedded.operations import OneInputFunctionOperation, TwoInputFunctionOperation
  from pyflink.fn_execution.embedded.converters import from_type_info_proto, from_schema_proto
label_desc: Use image node_id 6 for calling a global function with example usage: create_one_input_user_defined_data_stream_function_from_protos(function_infos, input_coder_info, output_coder_info, runtime_context, function_context, timer_context, side_output_context, job_parameters, keyed_state_backend, operator_state_backend) and returns: function_operation