Commit 06ebd237 authored by Jonathan Mace's avatar Jonathan Mace
Browse files

Log baggage after workload

parent ab815341
......@@ -73,6 +73,25 @@
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.3</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
<complianceLevel>1.8</complianceLevel>
</configuration>
</plugin>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-jar-plugin</artifactId>
<version>2.6</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
<plugin>
<groupId>net.alchim31.maven</groupId>
<artifactId>scala-maven-plugin</artifactId>
......
......@@ -147,6 +147,7 @@ public class SparkTPCDSBatchGenerator {
end = System.currentTimeMillis();
successful = true;
System.out.printf("%s completed successfully in %.1f seconds\n", query, (end-begin) / 1000.0);
xtrace.log(String.format("Completed in %.1f seconds", (end-begin)/1000.0), "Baggage", edu.brown.cs.systems.tracingplane.transit_layer.Baggage.take());
} catch (Exception e) {
end = System.currentTimeMillis();
System.out.println("Query " + query + " failed due to " + e.getClass().getSimpleName() + ": " + e.getMessage());
......
......@@ -129,7 +129,7 @@ public class SparkTPCDSWorkloadGenerator {
long postQ = System.currentTimeMillis();
System.out.printf("Load time: %d, Query time: %d\n", postLoad-preLoad, postQ-postLoad);
xtrace.log(String.format("Load time: %d, Query time: %d", postLoad-preLoad, postQ-postLoad));
xtrace.log(String.format("Load time: %d, Query time: %d", postLoad-preLoad, postQ-postLoad), "Baggage", edu.brown.cs.systems.tracingplane.transit_layer.Baggage.take());
}
}
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment