aboutsummaryrefslogtreecommitdiff
path: root/spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java
diff options
context:
space:
mode:
authorLuck <git@lucko.me>2018-09-30 21:05:19 +0100
committerLuck <git@lucko.me>2018-09-30 21:05:19 +0100
commit32bc0480ca20b19dcb04ca62b8934913c8a938c5 (patch)
tree6115758919cc9c7d0e73b184419e4a99f32067c0 /spark-common/src/main/java/me/lucko/spark/profiler/Sampler.java
parent272ad91f788f730d3e79a9d2b91cb5f276a92961 (diff)
downloadspark-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.java1
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());