Skip to content

Commit 32f1b0d

Browse files
committed
fxes limit query in cassandra
1 parent eea6874 commit 32f1b0d

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

cassandra-driver/src/main/java/org/eclipse/jnosql/diana/cassandra/column/QueryExecutorType.java

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -83,11 +83,10 @@ public Stream<ColumnEntity> execute(String keyspace, ColumnQuery query, DefaultC
8383
public Stream<ColumnEntity> execute(String keyspace, ColumnQuery query, ConsistencyLevel level,
8484
DefaultCassandraColumnFamilyManager manager) {
8585

86-
final Select cassandraSelect = QueryUtils.select(query, keyspace);
87-
86+
Select cassandraSelect = QueryUtils.select(query, keyspace);
8887

8988
if (query.getLimit() > 0 && query.getSkip() == 0) {
90-
cassandraSelect.limit((int) query.getLimit());
89+
cassandraSelect = cassandraSelect.limit((int) query.getLimit());
9190
}
9291

9392
SimpleStatement select = cassandraSelect.build();

0 commit comments

Comments
 (0)