spark 读取 mongodb:
1 | ./spark-shell --conf "spark.mongodb.input.uri=mongodb://127.0.0.1:27017/db.input" --conf "spark.mongodb.output.uri=mongodb://127.0.0.1:27017/db.output" --packages org.mongodb.spark:mongo-spark-connector_2.11:2.2.0 |
spark 读取 mongodb:
1 | ./spark-shell --conf "spark.mongodb.input.uri=mongodb://127.0.0.1:27017/db.input" --conf "spark.mongodb.output.uri=mongodb://127.0.0.1:27017/db.output" --packages org.mongodb.spark:mongo-spark-connector_2.11:2.2.0 |