summaryrefslogtreecommitdiff
path: root/src/com/p4square/grow/backend/db
diff options
context:
space:
mode:
authorJesse Morgan <jesse@jesterpm.net>2014-05-23 22:40:39 -0700
committerJesse Morgan <jesse@jesterpm.net>2014-05-23 22:40:39 -0700
commitd90c6f8ef2c9b630a39f7e6cbf65897dc2f62011 (patch)
tree422e40c724c56088af0bca376baa7a56634f9251 /src/com/p4square/grow/backend/db
parentef862e30975db691339fd143d2c4d60eb5132a3e (diff)
Adding dynamo support.
Diffstat (limited to 'src/com/p4square/grow/backend/db')
-rw-r--r--src/com/p4square/grow/backend/db/CassandraProviderImpl.java10
1 files changed, 1 insertions, 9 deletions
diff --git a/src/com/p4square/grow/backend/db/CassandraProviderImpl.java b/src/com/p4square/grow/backend/db/CassandraProviderImpl.java
index 9d896e7..da5a9f2 100644
--- a/src/com/p4square/grow/backend/db/CassandraProviderImpl.java
+++ b/src/com/p4square/grow/backend/db/CassandraProviderImpl.java
@@ -26,20 +26,12 @@ public class CassandraProviderImpl<V> extends JsonEncodedProvider<V> implements
@Override
public V get(CassandraKey key) throws IOException {
String blob = mDb.getKey(key.getColumnFamily(), key.getId(), key.getColumn());
- if (mClazz == String.class) {
- return (V) blob;
- }
return decode(blob);
}
@Override
public void put(CassandraKey key, V obj) throws IOException {
- String blob;
- if (mClazz == String.class) {
- blob = (String) obj;
- } else {
- blob = encode(obj);
- }
+ String blob = encode(obj);
mDb.putKey(key.getColumnFamily(), key.getId(), key.getColumn(), blob);
}
}