class_docstr: Handler which handles normal input data.
class_docstr_tok: ["Handler","which","handles","normal","input","data","."]
code: def __init__(
      self,
      internal_timer_service: InternalTimerServiceImpl,
      process_element_func,
      has_side_output: bool,
  ):
      self._internal_timer_service = internal_timer_service
      self._process_element_func = process_element_func
      self._has_side_output = 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 1 to create a new RunnerInputHandler object from inherited base classes: ABC with example: obj = RunnerInputHandler(internal_timer_service, process_element_func, has_side_output)