code: def process_element(self, value, ctx: "KeyedProcessFunction.Context"):
      # retrieve the current count
      current = self.state.value()
      if current is None:
          current = 0
  
      # update the state's count
      current += value[2]
      self.state.update(current)
  
      # register an event time timer 2 seconds later
      ctx.timer_service().register_event_time_timer(
          ctx.timestamp() + 2000
      )
  
file_path: flink/flink-python/pyflink/examples/datastream/event_time_timer.py
imports: from pyflink.common import Time, WatermarkStrategy, Duration
  from pyflink.common.typeinfo import Types
  from pyflink.common.watermark_strategy import TimestampAssigner
  from pyflink.datastream import StreamExecutionEnvironment
  from pyflink.datastream.functions import KeyedProcessFunction, RuntimeContext
  from pyflink.datastream.state import ValueStateDescriptor, StateTtlConfig
label_desc: Use image node_id 3 for calling the Sum obj's underlying member method code with example usage: obj.process_element(value, ctx) without return types