protected void setLowWatermark ( SourceState state ) { this . lowWatermark = getWatermarkFromPreviousWorkUnits ( state , ComplianceConfigurationKeys . HIVE_PURGER_WATERMARK ) ; log . info ( "Setting low watermark for the job: " + this . lowWatermark ) ; }
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 .