Added print partition stats.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/c4d6f3cd Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/c4d6f3cd Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/c4d6f3cd Branch: refs/heads/ignite-1186 Commit: c4d6f3cddf0a7ef89d6126eff432775e713e797a Parents: 071498f Author: nikolay_tikhonov <[email protected]> Authored: Mon Feb 29 22:37:38 2016 +0300 Committer: nikolay_tikhonov <[email protected]> Committed: Mon Feb 29 22:37:38 2016 +0300 ---------------------------------------------------------------------- .../ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/c4d6f3cd/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java ---------------------------------------------------------------------- diff --git a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java index c9a4b9c..6c25ec0 100644 --- a/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java +++ b/modules/yardstick/src/main/java/org/apache/ignite/yardstick/cache/IgniteCacheAbstractBenchmark.java @@ -87,9 +87,11 @@ public abstract class IgniteCacheAbstractBenchmark<K, V> extends IgniteAbstractB List<Integer> primary = e.getValue().get1(); List<Integer> backup = e.getValue().get2(); - BenchmarkUtils.println(cfg, e.getKey().id() + " " + primary.size() + " " + primary.size() * 1. / - aff.partitions() + " " + backup.size() + " " - + backup.size() * 1. / (aff.partitions() * args.backups() == 0 ? 1 : args.backups()) + BenchmarkUtils.println(cfg, e.getKey().id() + " " + + primary.size() + " " + primary.size() * 1. /aff.partitions() + " " + + backup.size() + " " + + backup.size() * 1. / (aff.partitions() * (args.backups() == 0 ? 1 : args.backups())) + " " + + (primary.size() + backup.size()) + " " + (primary.size() + backup.size() * 1.) / (aff.partitions() * args.backups() + aff.partitions()) ); }
