code: protected void setJobWatermark(SourceState state, String watermark) {
      state.setProp(ComplianceConfigurationKeys.HIVE_PURGER_WATERMARK, watermark);
      log.info("Setting job watermark for the job: " + watermark);
    }
docs: Sets Job Watermark in the SourceState which will be copied to all WorkUnitStates. Job Watermark is a complete partition name.
  During next run of this job, fresh work units will be created starting from this partition.