以纯文本形式从hcfs读取json文件后，可以将其Map到 JSONObject 使用自定义Map器：

import org.apache.flink.api.java.DataSet;
import org.apache.sling.commons.json.JSONObject;

DataSet<JSONObject> jsonInput = 
    input
        .map(record -> record.f1.toString())
        .map(StringToJsonObject::new);
``` `JSONObject` 基于上面链接的示例的Map器代码：

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.sling.commons.json.JSONObject;

public class StringToJsonObject implements MapFunction<String, JSONObject> {
private static final long serialVersionUID = 4573928723585302447L;

public JSONObject map(String content) throws Exception {
    return new JSONObject(content);
}

}

如果需要，你可以绘制Map `String` 改为pojo而不是generic `JSONObject` 使用与此类似的Map器。