private void updateDeltaFieldConfig ( String srcColumnName , String tgtColumnName ) { if ( this . workUnitState . contains ( ConfigurationKeys . EXTRACT_DELTA_FIELDS_KEY ) ) { String watermarkCol = this . workUnitState . getProp ( ConfigurationKeys . EXTRACT_DELTA_FIELDS_KEY ) ; this . workUnitState . setProp ( ConfigurationKeys . EXTRACT_DELTA_FIELDS_KEY , watermarkCol . replaceAll ( srcColumnName , tgtColumnName ) ) ; } }
Update water mark column property if there is an alias defined in query