class_docstr: Internal implementation of InternalTimerService.
code: def _set_timer(self, timer_operation_type, ts, key, namespace):
      from apache_beam.transforms import userstate
  
      bytes_io = BytesIO()
      self._namespace_serializer.serialize(namespace, bytes_io)
      encoded_namespace = bytes_io.getvalue()
  
      timer_operand_type_value = timer_operation_type.value
      timer_data = Row(
          timer_operand_type_value, -1, ts, key, encoded_namespace
      )
  
      timer = userstate.Timer(
          user_key=timer_data,
          dynamic_timer_tag="",
          windows=(self._global_window,),
          clear_bit=True,
          fire_timestamp=None,
          hold_timestamp=None,
          paneinfo=None,
      )
      self._timer_coder_impl.encode_to_stream(
          timer, self._output_stream, True
      )
      self._timer_coder_impl._key_coder_impl._value_coder._output_stream.maybe_flush()
  
imports: import collections
  import time
  from enum import Enum
  from io import BytesIO
  from pyflink.common import Row
  from pyflink.datastream import TimerService
  from pyflink.fn_execution.datastream.timerservice import InternalTimer, K, N, InternalTimerService
label_desc: Use image node_id 11 for calling the InternalTimerServiceImpl obj's underlying member method code with example usage: obj._set_timer(timer_operation_type, ts, key, namespace) without return types