diff options
author | Jesse Morgan <jesse@jesterpm.net> | 2014-03-24 21:38:02 -0700 |
---|---|---|
committer | Jesse Morgan <jesse@jesterpm.net> | 2014-03-31 19:39:30 -0700 |
commit | cfb2c5ef6582e51ae9cfdfff35e12b5b7fdc24fb (patch) | |
tree | 88df0d7004d73e113f6f9c95c599bd27ff91110f /src/com/p4square/grow/backend/db | |
parent | 44de44ac6a3879c78b7e31d7e460bb0125275237 (diff) |
Enabling the Feed and various bug fixes.
* Fixing thread ordering.
* Adding a limit of 5 threads per topic.
* Changing frontend /account references to UserRecord.
Diffstat (limited to 'src/com/p4square/grow/backend/db')
-rw-r--r-- | src/com/p4square/grow/backend/db/CassandraCollectionProvider.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/src/com/p4square/grow/backend/db/CassandraCollectionProvider.java b/src/com/p4square/grow/backend/db/CassandraCollectionProvider.java index cc11828..5e83247 100644 --- a/src/com/p4square/grow/backend/db/CassandraCollectionProvider.java +++ b/src/com/p4square/grow/backend/db/CassandraCollectionProvider.java @@ -7,7 +7,7 @@ package com.p4square.grow.backend.db; import java.io.IOException; import java.util.Collections; -import java.util.HashMap; +import java.util.LinkedHashMap; import java.util.Map; import com.netflix.astyanax.model.Column; @@ -45,21 +45,21 @@ public class CassandraCollectionProvider<V> implements CollectionProvider<String @Override public Map<String, V> query(String collection, int limit) throws IOException { - Map<String, V> result = new HashMap<>(); + Map<String, V> result = new LinkedHashMap<>(); ColumnList<String> row = mDb.getRow(mCF, collection); if (!row.isEmpty()) { int count = 0; for (Column<String> c : row) { + if (limit >= 0 && ++count > limit) { + break; // Limit reached. + } + String key = c.getName(); String blob = c.getStringValue(); V obj = decode(blob); result.put(key, obj); - - if (limit >= 0 && ++count > limit) { - break; // Limit reached. - } } } |