, classOf[BSONObject], config)
2014-08-06 0:43 GMT+04:00 Dmitriy Selivanov :
> Hello, I have issue when try to use bson file as spark input. I use
> mongo-hadoop-connector 1.3.0 and spark 1.0.0:
> val sparkConf = new SparkConf()
> val sc = new SparkContext(sparkConf)
>
can solve this issue?
I have no problems with com.mongodb.hadoop.MongoInputFormat when use
mongodb collection as input.
And moreover seems there is no problem with java api:
https://github.com/crcsmnky/mongodb-spark-demo/blob/master/src/main/java/com/mongodb/spark/demo/Recommender.java
I'm not professional java/scala developer, please help.
--
Regards
Dmitriy Selivanov