docs: public void setPeriodicWatermarkAssigner(
  		AssignerWithPeriodicWatermarks<T> periodicWatermarkAssigner) {
  		this.periodicWatermarkAssigner = periodicWatermarkAssigner;
  		ClosureCleaner.clean(this.periodicWatermarkAssigner, true);
  	}