Adding commands for the AsyncConsistentTreeMap, commands relating to transaction…
…s are temporarily removed. Change-Id: Iec5b972fb9de2dbfdfbe315b330778139ba92c90
Showing
2 changed files
with
9 additions
and
9 deletions
This diff is collapsed. Click to expand it.
... | @@ -156,6 +156,13 @@ public final class AtomixConsistentMapCommands { | ... | @@ -156,6 +156,13 @@ public final class AtomixConsistentMapCommands { |
156 | } | 156 | } |
157 | 157 | ||
158 | @Override | 158 | @Override |
159 | + public String toString() { | ||
160 | + return MoreObjects.toStringHelper(getClass()) | ||
161 | + .add("value", value) | ||
162 | + .toString(); | ||
163 | + } | ||
164 | + | ||
165 | + @Override | ||
159 | public void writeObject(BufferOutput<?> buffer, Serializer serializer) { | 166 | public void writeObject(BufferOutput<?> buffer, Serializer serializer) { |
160 | super.writeObject(buffer, serializer); | 167 | super.writeObject(buffer, serializer); |
161 | serializer.writeObject(value, buffer); | 168 | serializer.writeObject(value, buffer); |
... | @@ -192,13 +199,6 @@ public final class AtomixConsistentMapCommands { | ... | @@ -192,13 +199,6 @@ public final class AtomixConsistentMapCommands { |
192 | public ContainsValue(byte[] value) { | 199 | public ContainsValue(byte[] value) { |
193 | super(value); | 200 | super(value); |
194 | } | 201 | } |
195 | - | ||
196 | - @Override | ||
197 | - public String toString() { | ||
198 | - return MoreObjects.toStringHelper(getClass()) | ||
199 | - .add("value", value) | ||
200 | - .toString(); | ||
201 | - } | ||
202 | } | 202 | } |
203 | 203 | ||
204 | /** | 204 | /** |
... | @@ -453,14 +453,14 @@ public final class AtomixConsistentMapCommands { | ... | @@ -453,14 +453,14 @@ public final class AtomixConsistentMapCommands { |
453 | } | 453 | } |
454 | 454 | ||
455 | /** | 455 | /** |
456 | - * KeySet query. | 456 | + * ValueSet query. |
457 | */ | 457 | */ |
458 | @SuppressWarnings("serial") | 458 | @SuppressWarnings("serial") |
459 | public static class Values extends MapQuery<Collection<Versioned<byte[]>>> { | 459 | public static class Values extends MapQuery<Collection<Versioned<byte[]>>> { |
460 | } | 460 | } |
461 | 461 | ||
462 | /** | 462 | /** |
463 | - * KeySet query. | 463 | + * EntrySet query. |
464 | */ | 464 | */ |
465 | @SuppressWarnings("serial") | 465 | @SuppressWarnings("serial") |
466 | public static class EntrySet extends MapQuery<Set<Map.Entry<String, Versioned<byte[]>>>> { | 466 | public static class EntrySet extends MapQuery<Set<Map.Entry<String, Versioned<byte[]>>>> { | ... | ... |
-
Please register or login to post a comment