code: def time_window(self, window_width_ms):
          
          op = Operator(
              _generate_uuid(),
              OpType.TimeWindow,
              "TimeWindow",
              num_instances=self.env.config.parallelism,
              other=window_width_ms)
          return self.__register(op)
docs: Applies a system time window to the stream.
  
          Attributes:
               window_width_ms (int): The length of the window in ms.