diff --git a/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/CompositeEntityManager.java b/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/CompositeEntityManager.java index e9d0edfa7..802b3b4ab 100644 --- a/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/CompositeEntityManager.java +++ b/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/CompositeEntityManager.java @@ -632,6 +632,7 @@ private RowSliceQuery prepareQuery() { .setStart(endpoints[0]) .setEnd(endpoints[1]) .setLimit(columnLimit) + .setReversed(reverse) .build()); } diff --git a/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/NativeQuery.java b/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/NativeQuery.java index dd23bc630..c99eb0264 100644 --- a/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/NativeQuery.java +++ b/astyanax-entity-mapper/src/main/java/com/netflix/astyanax/entitystore/NativeQuery.java @@ -23,6 +23,7 @@ public abstract class NativeQuery { protected Collection columnNames; protected List predicates; protected int columnLimit = Integer.MAX_VALUE; + protected boolean reverse = false; /** * Refine query for row key @@ -98,6 +99,11 @@ public NativeQuery limit(int columnLimit) { return this; } + public NativeQuery reverse(boolean reverse) { + this.reverse = reverse; + return this; + } + private NativeQuery addPredicate(ColumnPredicate predicate) { if (predicates == null) { predicates = Lists.newArrayList();