I am running the following N1QL query.
val sqlcontext = new SQLContext(sc)
val vtapk = sc.couchbaseQuery(N1qlQuery.simple(query, N1qlParams.build().consistency(ScanConsistency.REQUEST_PLUS)))
I intentionally set the ScanConsistency level to the strictest REQUEST_PLUS and hope it can return similar results as the ViewQuery.from().stale(Stale.FALSE).
It turned out that I can get over 7+million records from the ViewQuery, but just 25k records from N1QL.
Is it expected for the N1QL to return just small portion of the data, or is there more configs or bucket flush needs to be done before making such queries.