sql >> Databasteknik >  >> NoSQL >> MongoDB

Varför trycker inte Spark Mongo-kontakten ned filtren?

Det är inte GreaterThan det är det som orsakar ditt problem, det är det faktum att filtret är på ett kapslat fält. Ditt filter på doc_type fungerar eftersom det inte är kapslat. Detta är tydligen ett problem med Catalyst-motorn i Spark, inte Mongo-kontakten. Det påverkar predikat pushdowns i t.ex. Parkett också.

Se följande diskussioner i Spark Jira för mer information.

Spark 19638

Spark 17636




  1. Långsam paginering över massor av poster i mongodb

  2. Ändra variabelvärde i dokument efter en tid?

  3. find({}) returnerar en tom arraymangust

  4. python flask hur man skickar en dynamisk parameter till en dekoratör