Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- final List<Map<String,String>> jsonData = new ArrayList<>();
- DataFrame df = sqlContext.read().json("file:///home/dev/data-json/emp.json");
- JavaRDD<String> rdd = df.toJSON().toJavaRDD();
- rdd.foreach(new VoidFunction<String>() {
- @Override
- public void call(String line) {
- try {
- System.out.println(line);
- jsonData.add (new ObjectMapper().readValue(line, Map.class));
- } catch (IOException e) {
- e.printStackTrace();
- }
- }
- });
- System.out.println(jsonData.size());
- {"address":"noida","name":"karthik","occupation":"engg","salary":20000}
- {"address":"noida","name":"dev","occupation":"engg","salary":10000}
- -----other 98 records
- TypeReference<HashMap<String,String>> typeRef
- = new TypeReference<HashMap<String,String>>() {};
- jsonData.add (new ObjectMapper().readValue(line, typeRef));
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement