code: def _emit_results(timestamp, watermark, results, has_side_output):
      if results:
          if has_side_output:
              for result in results:
                  if isinstance(result, tuple) and isinstance(
                      result[0], OutputTag
                  ):
                      yield cast(OutputTag, result[0]).tag_id, Row(
                          timestamp, watermark, result[1]
                      )
                  else:
                      yield DEFAULT_OUTPUT_TAG, Row(
                          timestamp, watermark, result
                      )
          else:
              for result in results:
                  yield Row(timestamp, watermark, result)
  
imports: from abc import ABC
  from enum import Enum
  from typing import cast, Iterable
  from pyflink.common import Row
  from pyflink.common.constants import DEFAULT_OUTPUT_TAG
  from pyflink.datastream.output_tag import OutputTag
  from pyflink.fn_execution.datastream.process.timerservice_impl import InternalTimerServiceImpl
label_desc: Use image node_id 1 for calling a global function with example usage: _emit_results(timestamp, watermark, results, has_side_output) without return types