# ignite-sprint-4 reduce test output
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b39aa56f Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b39aa56f Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b39aa56f Branch: refs/heads/ignite-424 Commit: b39aa56fc140dae157d07c8ff48c755c6f831b24 Parents: 8b3e02e Author: sboikov <sboi...@gridgain.com> Authored: Tue Apr 14 10:24:04 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Tue Apr 14 10:24:04 2015 +0300 ---------------------------------------------------------------------- .../processors/cache/GridCachePutAllTask.java | 23 ++++++++++++++++---- 1 file changed, 19 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b39aa56f/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java index 58e7ccb..479ff9c 100644 --- a/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java +++ b/modules/core/src/test/java/org/apache/ignite/internal/processors/cache/GridCachePutAllTask.java @@ -32,6 +32,9 @@ import java.util.*; * Puts all the passed data into partitioned cache in small chunks. */ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>, Void> { + /** */ + private static final boolean DEBUG_DATA = false; + /** Number of entries per put. */ private static final int TX_BOUND = 30; @@ -73,7 +76,10 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>, Void> private Ignite ignite; @Override public Object execute() { - log.info("Going to put data: " + data); + if (DEBUG_DATA) + log.info("Going to put data: " + data); + else + log.info("Going to put data [size=" + data.size() + ']'); IgniteCache<Object, Object> cache = ignite.cache(cacheName); @@ -91,7 +97,10 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>, Void> putMap.put(val, val); if (++cnt == TX_BOUND) { - log.info("Putting keys to cache: " + putMap.keySet()); + if (DEBUG_DATA) + log.info("Putting keys to cache: " + putMap.keySet()); + else + log.info("Putting keys to cache [size=" + putMap.size() + ']'); cache.putAll(putMap); @@ -104,11 +113,17 @@ class GridCachePutAllTask extends ComputeTaskAdapter<Collection<Integer>, Void> assert cnt < TX_BOUND; assert putMap.size() == (data.size() % TX_BOUND) : "putMap.size() = " + putMap.size(); - log.info("Putting keys to cache: " + putMap.keySet()); + if (DEBUG_DATA) + log.info("Putting keys to cache: " + putMap.keySet()); + else + log.info("Putting keys to cache [size=" + putMap.size() + ']'); cache.putAll(putMap); - log.info("Finished putting data: " + data); + if (DEBUG_DATA) + log.info("Finished putting data: " + data); + else + log.info("Finished putting data [size=" + data.size() + ']'); return data; }
