SparkSession spark = sparkMongoDao.getSession();
JavaSparkContext jsc = new JavaSparkContext(spark.sparkContext());
Map<String, String> readOverrides = new HashMap<String, String>();
readOverrides.put("collection", "stock_basic_info1");
readOverrides.put("readPreference.name", "secondaryPreferred");
ReadConfig readConfig = ReadConfig.create(jsc).withOptions(readOverrides);
Dataset<Row> implicitDS = MongoSpark.load(jsc,readConfig).toDF();
implicitDS.printSchema();
implicitDS.show();
我寫的如下但是，但是這行（ReadConfig readConfig = ReadConfig.create(jsc).withOptions(readOverrides); ）報錯：Ambiguous method call. Both create (JavaSparkContext) in ReadConfig and create (JavaSparkContext) in ReadConfig match 請問有遇到過嗎？
轉載請註明出處，本文鏈接：https://www.uj5u.com/qita/10958.html
標籤：Spark
上一篇：自動化部署
下一篇：tpm加解密