假设我有两种类型的服务反应--积极的和消极的。它们有JSON格式。当我使用Jackson API创建相应的java对象时,我必须编写如下代码:
import com.fasterxml.jackson.databind.ObjectMapper;
private ObjectMapper objectMapper = new ObjectMapper();
String json = ... // JSON received from a service
ServiceResponse response = objectMapper.readValue(json, ServiceRespon
我正在使用Flink来处理来自某些数据源的一些JSON格式的数据。
现在,我的过程非常简单:从JSON格式的数据中提取每个元素,并将它们打印到日志文件中。
下面是我的一段代码:
// create proper deserializer to deserializer the JSON-format data into ObjectNode
PravegaDeserializationSchema<ObjectNode> adapter = new PravegaDeserializationSchema<>(ObjectNode.class, new JavaSeri