diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-04-08 22:43:27 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-04-08 22:43:27 +0200 |
commit | 10afef17237f7180547af531241cb509e93e1f47 (patch) | |
tree | 10fb8f016bfef71afe6606b3e7eac849c5b8c9a5 /metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java | |
parent | 62985a75aa1948334bfc248f0e8fe8526892c70f (diff) |
Revert "Revert "Use a PipedStream to process metrics as they flow in asynchronously.""
Diffstat (limited to 'metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java')
-rw-r--r-- | metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java index e43aab8b26f..20c2325e1f3 100644 --- a/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java +++ b/metrics-proxy/src/main/java/ai/vespa/metricsproxy/service/MetricsParser.java @@ -10,6 +10,7 @@ import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import java.io.IOException; +import java.io.InputStream; import java.util.Collections; import java.util.HashMap; import java.util.Iterator; @@ -32,6 +33,9 @@ public class MetricsParser { static Metrics parse(byte [] data) throws IOException { return parse(jsonMapper.createParser(data)); } + static Metrics parse(InputStream data) throws IOException { + return parse(jsonMapper.createParser(data)); + } private static Metrics parse(JsonParser parser) throws IOException { if (parser.nextToken() != JsonToken.START_OBJECT) { throw new IOException("Expected start of object, got " + parser.currentToken()); |