| package edu.uci.ics.hyracks.storage.am.lsm.common.impls; |
| |
| import edu.uci.ics.hyracks.api.exceptions.HyracksDataException; |
| import edu.uci.ics.hyracks.storage.am.common.api.IndexException; |
| import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIOOperation; |
| import edu.uci.ics.hyracks.storage.am.lsm.common.api.ILSMIOOperationScheduler; |
| |
| public enum SynchronousScheduler implements ILSMIOOperationScheduler { |
| INSTANCE; |
| |
| @Override |
| public void scheduleOperation(ILSMIOOperation operation) throws HyracksDataException { |
| try { |
| operation.perform(); |
| } catch (IndexException e) { |
| throw new HyracksDataException(e); |
| } |
| } |
| } |