diff options
author | Luck <git@lucko.me> | 2018-09-30 21:05:19 +0100 |
---|---|---|
committer | Luck <git@lucko.me> | 2018-09-30 21:05:19 +0100 |
commit | 32bc0480ca20b19dcb04ca62b8934913c8a938c5 (patch) | |
tree | 6115758919cc9c7d0e73b184419e4a99f32067c0 /spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java | |
parent | 272ad91f788f730d3e79a9d2b91cb5f276a92961 (diff) | |
download | spark-32bc0480ca20b19dcb04ca62b8934913c8a938c5.tar.gz spark-32bc0480ca20b19dcb04ca62b8934913c8a938c5.tar.bz2 spark-32bc0480ca20b19dcb04ca62b8934913c8a938c5.zip |
Implement basic heap dump functionality
Diffstat (limited to 'spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java')
-rw-r--r-- | spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java b/spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java index 27429b1..2432d55 100644 --- a/spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java +++ b/spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java @@ -150,6 +150,7 @@ public class Sampler implements Runnable { private void writeOutput(JsonWriter writer) throws IOException { writer.beginObject(); + writer.name("type").value("sampler"); writer.name("threads").beginArray(); List<Map.Entry<String, ThreadNode>> data = new ArrayList<>(this.dataAggregator.getData().entrySet()); |