class_docstr: The AssignerWithPeriodicWatermarks assigns event time timestamps to elements, and generates
  low watermarks that signal event time progress within the stream. These timestamps and
  watermarks are used by functions and operators that operate on event time, for example event
  time windows.
class_docstr_tok: ["The","AssignerWithPeriodicWatermarks","assigns","event","time","timestamps","to","elements",",","and","generates","low","watermarks","that","signal","event","time","progress","within","the","stream",".","These","timestamps","and","watermarks","are","used","by","functions","and","operators","that","operate","on","event","time",",","for","example","event","time","windows","."]
code: def __init__(self, j_assigner_with_periodic_watermarks):
      self._j_assigner_with_periodic_watermarks = (
          j_assigner_with_periodic_watermarks
      )
  
file_path: flink/flink-python/pyflink/common/watermark_strategy.py
imports: import abc
  from typing import Any, Optional
  from pyflink.common.time import Duration
  from pyflink.java_gateway import get_gateway
label_desc: Use image node_id 1 to create a new AssignerWithPeriodicWatermarksWrapper object from inherited base classes: object with example: obj = AssignerWithPeriodicWatermarksWrapper(j_assigner_with_periodic_watermarks)