summaryrefslogtreecommitdiff
path: root/src/com/p4square/grow/backend/db/CassandraCollectionProvider.java
diff options
context:
space:
mode:
authorJesse Morgan <jesse@jesterpm.net>2014-03-24 21:38:02 -0700
committerJesse Morgan <jesse@jesterpm.net>2014-03-31 19:39:30 -0700
commitadba5974bae4da0def1f13d47cfcf28a37e3cf7a (patch)
treee660c0090f942d4ac846666b0aabdfe83ea020e9 /src/com/p4square/grow/backend/db/CassandraCollectionProvider.java
parentbe16eedfb3570da2dcd3975948419ecc3d996253 (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/CassandraCollectionProvider.java')
-rw-r--r--src/com/p4square/grow/backend/db/CassandraCollectionProvider.java12
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.
- }
}
}