class_docstr: Call a function periodically with the specified number of seconds
class_docstr_tok: ["Call","a","function","periodically","with","the","specified","number","of","seconds"]
code: def __init__(
      self, interval, function, args=None, kwargs=None
  ) -> None:
      threading.Thread.__init__(self)
      self._interval = interval
      self._function = function
      self._args = args if args is not None else []
      self._kwargs = kwargs if kwargs is not None else {}
      self._finished = threading.Event()
  
imports: import datetime
  import threading
  import time
  from collections.abc import Generator
  from functools import partial
  from typing import Any, Tuple, Dict, List
  from pyflink.common import Row
  from pyflink.fn_execution import pickle
  from pyflink.serializers import PickleSerializer
  from pyflink.table import functions
  from pyflink.table.udf import DelegationTableFunction, DelegatingScalarFunction, ImperativeAggregateFunction, PandasAggregateFunctionWrapper
label_desc: Use image node_id 1 to create a new PeriodicThread object from inherited base classes: threading with example: obj = PeriodicThread(interval, function, args, kwargs)