Setting LIMIT() on Cassandra table in JavaRDD does not work

169 Views Asked by At

Cassandra 2.2.8. java8 I am using limit 100 but I get 600 rows

JavaRDD<TransByDate> originDateRDD = javaFunctions(sc).cassandraTable(" ")
                .select(" ")).limit((long)100);

long cnt1= originDateRDD.count();
System.out.println("originDateRDD.count: "+cnt1);  

=> Prints 600

Whatever limit I set I get 6 times the rows

0

There are 0 best solutions below