Mercurial > hg > Database > Alice

comparison src/alice/datasegment/LocalDataSegmentManager.java @ 225:bc061ee5f31f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
bitonic sort work but data is not sorted
author sugi
date Thu, 28 Mar 2013 18:10:24 +0900
parents 409d7679cf7b
children ca1c9c477f54
comparison
equal deleted inserted replaced
224:409d7679cf7b 225:bc061ee5f31f
63 63
64 @Override 64 @Override
65 public void put(String key, Value val) { 65 public void put(String key, Value val) {
66 DataSegmentKey dataSegmentKey = getDataSegmentKey(key); 66 DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
67 Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, null, reverseKey); 67 Command cmd = new Command(CommandType.PUT, null, key, val, 0, 0, null, null, reverseKey);
68 addCommand(dataSegmentKey, cmd); 68 submitCommand(dataSegmentKey, cmd);
69 if (logger.isDebugEnabled()) 69 if (logger.isDebugEnabled())
70 logger.debug(cmd.getCommandString()); 70 logger.debug(cmd.getCommandString());
71 } 71 }
72 72
73 public void putObject(String key, Object obj) { 73 public void putObject(String key, Object obj) {
74 DataSegmentKey dataSegmentKey = getDataSegmentKey(key); 74 DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
75 Command cmd = new Command(CommandType.PUT, null, key, obj, 0, 0, null, null, reverseKey); 75 Command cmd = new Command(CommandType.PUT, null, key, obj, 0, 0, null, null, reverseKey);
76 addCommand(dataSegmentKey, cmd); 76 submitCommand(dataSegmentKey, cmd);
77 if (logger.isDebugEnabled()) 77 if (logger.isDebugEnabled())
78 logger.debug(cmd.getCommandString()); 78 logger.debug(cmd.getCommandString());
79 } 79 }
80 80
81 /** 81 /**
83 */ 83 */
84 @Override 84 @Override
85 public void update(String key, Value val) { 85 public void update(String key, Value val) {
86 DataSegmentKey dataSegmentKey = getDataSegmentKey(key); 86 DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
87 Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey); 87 Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey);
88 addCommand(dataSegmentKey, cmd); 88 submitCommand(dataSegmentKey, cmd);
89 if (logger.isDebugEnabled()) 89 if (logger.isDebugEnabled())
90 logger.debug(cmd.getCommandString()); 90 logger.debug(cmd.getCommandString());
91 } 91 }
92 92
93 public void updateObject(String key, Object val) { 93 public void updateObject(String key, Object val) {
94 DataSegmentKey dataSegmentKey = getDataSegmentKey(key); 94 DataSegmentKey dataSegmentKey = getDataSegmentKey(key);
95 Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey); 95 Command cmd = new Command(CommandType.UPDATE, null, key, val, 0, 0, null, null, reverseKey);
96 addCommand(dataSegmentKey, cmd); 96 submitCommand(dataSegmentKey, cmd);
97 if (logger.isDebugEnabled()) 97 if (logger.isDebugEnabled())
98 logger.debug(cmd.getCommandString()); 98 logger.debug(cmd.getCommandString());
99 } 99 }
100 100
101 @Override 101 @Override