sql >> Database teknologi >  >> NoSQL >> MongoDB

Sådan konfigureres Java Spark gnistsession samplesize

Det er spark.mongodb.input.sampleSize

SparkSession spark = SparkSession.builder()
                .master("local[2]")
                .appName("SparkReadMgToHive")
                .config("spark.sql.warehouse.dir", warehouseLocation)
                .config("spark.mongodb.input.uri", "mongodb://localhost:27017/test.testcollection")
                .config("spark.mongodb.input.sampleSize", 50000)
                .enableHiveSupport()
                .getOrCreate();



  1. Hvordan bruger du $set i MongoDB til at opdatere en indlejret værdi/indlejret dokument?

  2. Samtidsoptælling ved hjælp af Mongo-aggregationsramme

  3. Få alle felter og værdier af hash-nøgle ved hjælp af redis i node

  4. FindAndUpdate Sådan kontrollerer du, om dokumentet virkelig blev opdateret