[FLINK-9194][history] Add convenience ArchivedJson constructor
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/4d5b00ec Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/4d5b00ec Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/4d5b00ec Branch: refs/heads/release-1.5 Commit: 4d5b00ec5bc5b736f838610bb10dfb99ef5fa4d2 Parents: c2e3d23 Author: zentol <[email protected]> Authored: Wed Apr 18 14:33:16 2018 +0200 Committer: Till Rohrmann <[email protected]> Committed: Tue May 15 07:51:46 2018 +0200 ---------------------------------------------------------------------- .../runtime/webmonitor/history/ArchivedJson.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/4d5b00ec/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java index a15dd52..9200248 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/history/ArchivedJson.java @@ -18,8 +18,14 @@ package org.apache.flink.runtime.webmonitor.history; +import org.apache.flink.runtime.rest.messages.ResponseBody; +import org.apache.flink.runtime.rest.util.RestMapperUtils; import org.apache.flink.util.Preconditions; +import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.ObjectMapper; + +import java.io.IOException; +import java.io.StringWriter; import java.util.Objects; /** @@ -30,6 +36,8 @@ import java.util.Objects; */ public class ArchivedJson { + private static final ObjectMapper MAPPER = RestMapperUtils.getStrictObjectMapper(); + private final String path; private final String json; @@ -38,6 +46,13 @@ public class ArchivedJson { this.json = Preconditions.checkNotNull(json); } + public ArchivedJson(String path, ResponseBody json) throws IOException { + this.path = Preconditions.checkNotNull(path); + StringWriter sw = new StringWriter(); + MAPPER.writeValue(sw, Preconditions.checkNotNull(json)); + this.json = sw.toString(); + } + public String getPath() { return path; }
