class_docstr: The WatermarkStrategy defines how to generate Watermarks in the stream sources. The
  WatermarkStrategy is a builder/factory for the WatermarkGenerator that generates the watermarks
  and the TimestampAssigner which assigns the internal timestamp of a record.
  
  The convenience methods, for example forBoundedOutOfOrderness(Duration), create a
  WatermarkStrategy for common built in strategies.
class_docstr_tok: ["The","WatermarkStrategy","defines","how","to","generate","Watermarks","in","the","stream","sources",".","The","WatermarkStrategy","is","a","builder\/factory","for","the","WatermarkGenerator","that","generates","the","watermarks","and","the","TimestampAssigner","which","assigns","the","internal","timestamp","of","a","record",".","The","convenience","methods",",","for","example","forBoundedOutOfOrderness","(","Duration",")",",","create","a","WatermarkStrategy","for","common","built","in","strategies","."]
docstr: Creates a watermark strategy for situations where records are out of order, but you can
  place an upper bound on how far the events are out of order. An out-of-order bound B means
  that once the an event with timestamp T was encountered, no events older than (T - B) will
  follow any more.
docstr_tok: ["Creates","a","watermark","strategy","for","situations","where","records","are","out","of","order",",","but","you","can","place","an","upper","bound","on","how","far","the","events","are","out","of","order",".","An","out-of-order","bound","B","means","that","once","the","an","event","with","timestamp","T","was","encountered",",","no","events","older","than","(","T","-","B",")","will","follow","any","more","."]
code: def for_bounded_out_of_orderness(
      max_out_of_orderness: Duration,
  ) -> "WatermarkStrategy":
      """
      Creates a watermark strategy for situations where records are out of order, but you can
      place an upper bound on how far the events are out of order. An out-of-order bound B means
      that once the an event with timestamp T was encountered, no events older than (T - B) will
      follow any more.
      """
      JWaterMarkStrategy = (
          get_gateway().jvm.org.apache.flink.api.common.eventtime.WatermarkStrategy
      )
      return WatermarkStrategy(
          JWaterMarkStrategy.forBoundedOutOfOrderness(
              max_out_of_orderness._j_duration
          )
      )
  
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 6 for calling the WatermarkStrategy obj's underlying member method code with example usage: obj.for_bounded_out_of_orderness(max_out_of_orderness) and returns: WatermarkStrategy