[SPARK] Mongo Mysql foreachRDD Data to Mongo line_data.foreachRDD(new Function() { private static final long serialVersionUID = 1L; Mongo mongo = new Mongo("몽고URL", 27017); DB db = mongo.getDB("DB명"); public Void call(JavaRDD data) throws Exception { DBCollection collection = db.getCollection("컬렉션명"); if(data!=null){ Listresult = data.collect(); for (String temp :result) { //mongo DBObject dbObject = (DBObject) JSON.parse(tem.. 더보기 이전 1 ··· 79 80 81 82 83 84 85 ··· 98 다음