code: def __init__(
      self,
      open_func,
      close_func,
      process_element_func,
      on_timer_func=None,
  ):
      self._open_func = open_func
      self._close_func = close_func
      self._process_element_func = process_element_func
      self._on_timer_func = on_timer_func
  
imports: from pyflink.datastream import OutputTag
  from pyflink.datastream.window import WindowOperationDescriptor
  from pyflink.fn_execution import pickle
  from pyflink.fn_execution.coders import TimeWindowCoder, CountWindowCoder
  from pyflink.fn_execution.datastream import operations
  from pyflink.fn_execution.datastream.embedded.process_function import InternalProcessFunctionContext, InternalKeyedProcessFunctionContext, InternalKeyedProcessFunctionOnTimerContext, InternalWindowTimerContext, InternalBroadcastProcessFunctionContext, InternalBroadcastProcessFunctionReadOnlyContext, InternalKeyedBroadcastProcessFunctionContext, InternalKeyedBroadcastProcessFunctionReadOnlyContext, InternalKeyedBroadcastProcessFunctionOnTimerContext
  from pyflink.fn_execution.datastream.embedded.runtime_context import StreamingRuntimeContext
  from pyflink.fn_execution.datastream.embedded.side_output_context import SideOutputContext
  from pyflink.fn_execution.datastream.embedded.timerservice_impl import InternalTimerServiceImpl
  from pyflink.fn_execution.datastream.window.window_operator import WindowOperator
  from pyflink.fn_execution.embedded.converters import TimeWindowConverter, CountWindowConverter, GlobalWindowConverter
  from pyflink.fn_execution.embedded.state_impl import KeyedStateBackend
label_desc: Use image node_id 1 to create a new OneInputOperation object from inherited base classes: operations with example: obj = OneInputOperation(open_func, close_func, process_element_func, on_timer_func)