class_docstr: Handler which handles normal input data.
class_docstr_tok: ["Handler","which","handles","normal","input","data","."]
code: def process_element(self, value) -> Iterable:
      timestamp = value[0]
      watermark = value[1]
      data = value[2]
      self._advance_watermark(watermark)
      yield from _emit_results(
          timestamp,
          watermark,
          self._process_element_func(data, timestamp),
          self._has_side_output,
      )
  
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 2 for calling the RunnerInputHandler obj's underlying member method code with example usage: obj.process_element(value) without return types