protected void setJobWatermark ( SourceState state , String watermark ) { state . setProp ( ComplianceConfigurationKeys . HIVE_PURGER_WATERMARK , watermark ) ; log . info ( "Setting job watermark for the job: " + watermark ) ; }
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 .