1、JSON檔案格式為：

{"key1":{"產地":"南京","外形尺寸":"50*50","型號":"dddd"},"code":"101331569"}

2、程式如下：

public class ExportData {

      public static void main(String[] args) {

                  SparkConf conf = new SparkConf()
                 .setMaster("local[*]")
                 .setAppName("hahhahaha");
                 JavaSparkContext jsc = new JavaSparkContext(conf);

                String atrr = "D:\\aaaa.txt";

               JavaRDD<String> atrrsInput = jsc.textFile(atrr);

               JavaPairRDD<String, String> modelPair = atrrsInput.mapPartitionsToPair(new AtrrsJson()).filter(new Function<Tuple2<String,String>, Boolean>() {
public Boolean call(Tuple2<String, String> tuple) throws Exception {
   return tuple._1.isEmpty() ? false : true;
}
});

     }

}

class AtrrsJson implements PairFlatMapFunction<Iterator<String>, String, String>{
    @Override
    public Iterator<Tuple2<String, String>> call(Iterator<String> lines) throws Exception {
    List<Tuple2<String, String>> resultList=new ArrayList<Tuple2<String, String>>();
        ObjectMapper mapper = new ObjectMapper();
        while(lines.hasNext()){
            String line = lines.next();
            try{
            JsonNode rootNode = mapper.readTree(line);
            String cmmdtyCode = rootNode.path("code").textValue();
            JsonNode rootNode2 = rootNode.get("key1");
            String model = rootNode2.path("型號").asText();
            resultList.add(new Tuple2<String, String>(cmmdtyCode, model));
            }catch(Exception e){
            resultList.add(new Tuple2<String, String>("", ""));
            }       
        }
        Iterator<Tuple2<String, String>> result = resultList.iterator();
        return result;
    }


}