08/11, 2011 - Created 09/27, 2011 - Updated compareTo to return Occurred
125126127128129130131132133134135
} @Override public synchronized boolean put(K key, V value, long scn) throws Exception { if(scn >= _hwmScn) { Clock clock; _store.put(key, value); clock = (scn == _hwmScn) ? _waterMarksClock.current() : _waterMarksClock.updateHWMark(_source, scn);
143144145146147148149150151152153
} @Override public synchronized boolean delete(K key, long scn) throws Exception { if(scn >= _hwmScn) { Clock clock; _store.delete(key); clock = (scn == _hwmScn) ? _waterMarksClock.current() : _waterMarksClock.updateHWMark(_source, scn);