使用GSON将JSON转换为Java时抛出错误

Question

在我的spark代码中有gson，它存储在字符串RDD中，我将其转换为键和值。

JavaPairRDD<String, ArrayList<Guid>> docPairRDD = docRDD.mapToPair(SparkCustomFunctions.generateKeyValuePair());

    /**
     * @return new Tuple with key is of type String and value is of type ArrayList<DocId>
     */
    public static PairFunction<String, String, ArrayList<DocId>> generateKeyValuePair() {
        return new PairFunction<String, String, ArrayList<DocId>>(){

        private static final long serialVersionUID = 9086064488812696200L;
        public Tuple2<String, ArrayList<DocId>> call(String t)
                    throws Exception {

            GsonBuilder gson = new GsonBuilder();
            Document tempObj = gson.create().fromJson(t, Document.class);

        return new Tuple2<String, ArrayList<DocId>>(tempObj.getKey(),(ArrayList<DocId>) tempObj.getEventFields());
            }
        };
    }
}

(1).

public class Document implements Serializable {
private static final long serialVersionUID = 1L;
     @SerializedName("key")
    String key;
     @SerializedName("eventFields")
    List<DocId> eventFields= new ArrayList<DocId>();

    public Document (String key, List<DocId> eventFields) {
        super();
        this.key = key;
        this.eventFields= eventFields;
    }

Its setter and getter
}

(2).

public class DocId implements Serializable {
    private static final long serialVersionUID = 1L;
    String DocId = "";
    String cType = "";
    String events;
    public DocId(String docId, String cType, String eType){
        super();
        this.DocId = docId;
        this.cType = cType;
        this.events = eType;
    }
their setters and getters
}

但我收到了以下错误消息。谷歌。格森。JsonSyntaxException:java。伊奥。EOFEException：com第1行第2列的输入结束。谷歌。格森。格森。com上的fromJson（Gson.java:813）。谷歌。格森。格森。com上的fromJson（Gson.java:768）。谷歌。格森。格森。com上的fromJson（Gson.java:717）。谷歌。格森。格森。fromJson（Gson.java:689）

我是gsona和spark的新手。所以请让我知道我做错了什么？

我将以下类型的json存储到RDD中

{
  "key": "01key",
  "eventFields": [
    {
      "guid": "abc12",
      "contentType": "dummyContent",
      "events": "dummyEvents"
    }
  ]
}

Answer 1

所以我发现了这个问题，在存储我的响应之前，我正在进行预打印，所以json会被拆分为多行，在阅读这个json时，我假设每行都是完整的json，所以我得到了错误。我删除了预打印，我的代码开始正常工作。