依赖引入
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.38</version>
</dependency>
实体类
package com.beantech.base.pojo;
import lombok.Data;
import java.io.Serializable;
@Data
public class QueryCriteria implements Serializable {
private String id;
private String trackId;
private String vin;
private Integer status;
}
代码实现
JavaRDD<String> rdd1 = jsc.textFile("/input/data/queryCriteria");
JavaRDD<QueryCriteria> map = rdd1.map(s -> {
return JSONObject.parseObject(s, QueryCriteria.class);
});
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)