code: def process_element(self, value):
      results = self._main_operation.process_element(
          self._input_data_converter.to_internal(value)
      )
  
      results = self._process_elements(results)
  
      yield from self._output_elements(results)
  
file_path: flink/flink-python/pyflink/fn_execution/embedded/operations.py
imports: from pyflink.fn_execution.datastream.embedded.operations import extract_process_function
  from pyflink.fn_execution.embedded.converters import DataConverter
label_desc: Use image node_id 2 for calling the OneInputFunctionOperation obj's underlying member method code with example usage: obj.process_element(value) without return types