natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

post-fix for: Provide option for cassandra-stress to dump all settings 

patch by Ben Slater; reviewed by Robert Stupp for CASSANDRA-11914
This commit is contained in:
Ben Slater 2016-08-25 13:02:03 +02:00 committed by Robert Stupp
parent 03659d7b94
commit df0cd441e2
1 changed files with 20 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

28
tools/stress/src/org/apache/cassandra/stress/StressProfile.java
View File

@ -106,14 +106,26 @@ public class StressProfile implements Serializable
out.printf(" Table Name: %s%n", tableName);
out.printf(" Table CQL: %n***%n%s***%n%n", tableCql);
out.printf(" Extra Schema Definitions: %s%n", extraSchemaDefinitions);
out.printf(" Generator Configs:%n");
columnConfigs.forEach((k,v)->out.printf(" %s: %s%n", k, v.getConfigAsString()));
out.printf(" Query Definitions:%n");
queries.forEach((k,v)->out.printf(" %s: %s%n", k, v.getConfigAsString()));
out.printf(" Token Range Queries:%n");
tokenRangeQueries.forEach((k,v)->out.printf(" %s: %s%n", k, v.getConfigAsString()));
out.printf(" Insert Settings:%n");
insert.forEach((k,v)->out.printf(" %s: %s%n", k, v));
if (columnConfigs != null)
{
out.printf(" Generator Configs:%n");
columnConfigs.forEach((k, v) -> out.printf(" %s: %s%n", k, v.getConfigAsString()));
}
if(queries != null)
{
out.printf(" Query Definitions:%n");
queries.forEach((k, v) -> out.printf(" %s: %s%n", k, v.getConfigAsString()));
}
if (tokenRangeQueries != null)
{
out.printf(" Token Range Queries:%n");
tokenRangeQueries.forEach((k, v) -> out.printf(" %s: %s%n", k, v.getConfigAsString()));
}
if (insert != null)
{
out.printf(" Insert Settings:%n");
insert.forEach((k, v) -> out.printf(" %s: %s%n", k, v));
}
PartitionGenerator generator = newGenerator(stressSettings);
Distribution visits = stressSettings.insert.visits.get();