code: protected void setLowWatermark(SourceState state) {
      this.lowWatermark = getWatermarkFromPreviousWorkUnits(state, ComplianceConfigurationKeys.HIVE_PURGER_WATERMARK);
      log.info("Setting low watermark for the job: " + this.lowWatermark);
    }
docs: Sets the local watermark, which is a class variable. Local watermark is a complete partition name which act as the starting point for the creation of fresh work units.