Author: [email protected]
Date: Mon Oct 17 09:39:49 2011
New Revision: 1519
Log:
[AMDATUCASSANDRA-111] Implemented updateToken
Modified:
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
Modified:
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
==============================================================================
---
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
(original)
+++
trunk/amdatu-cassandra/cassandra-store-token/src/main/java/org/amdatu/cassandra/store/token/service/CassandraTokenStorageProviderImpl.java
Mon Oct 17 09:39:49 2011
@@ -112,6 +112,13 @@
m_pm.setValue(CF_TOKEN, rowKey, null, C_PROPERTIES,
mapToString(token.getProperties()));
}
+ public void updateToken(Token token) {
+ if (token == null) {
+ return;
+ }
+ addToken(token); // in Cassandra add and update are one and the same...
+ }
+
public boolean hasToken(final String token) {
if (token == null) {
return false;
_______________________________________________
Amdatu-commits mailing list
[email protected]
http://lists.amdatu.org/mailman/listinfo/amdatu-commits
