Repository: incubator-ignite Updated Branches: refs/heads/ignite-394 6f649413c -> a8f173867
# ignite-394: ldr -> stmr at examples Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/a8f17386 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/a8f17386 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/a8f17386 Branch: refs/heads/ignite-394 Commit: a8f1738671b6e209dad839219099d4650bf7e42c Parents: 6f64941 Author: Artem Shutak <ashu...@gridgain.com> Authored: Wed Mar 4 19:21:14 2015 +0300 Committer: Artem Shutak <ashu...@gridgain.com> Committed: Wed Mar 4 19:21:14 2015 +0300 ---------------------------------------------------------------------- .../ignite/examples/datagrid/CacheDataStreamerExample.java | 8 ++++---- .../ignite/examples/datagrid/CachePopularNumbersExample.java | 8 ++++---- .../scalar/examples/ScalarCachePopularNumbersExample.scala | 6 +++--- 3 files changed, 11 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a8f17386/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java index e5db76d..1193f27 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java @@ -63,13 +63,13 @@ public class CacheDataStreamerExample { long start = System.currentTimeMillis(); - try (IgniteDataStreamer<Integer, String> ldr = ignite.dataStreamer(CACHE_NAME)) { + try (IgniteDataStreamer<Integer, String> stmr = ignite.dataStreamer(CACHE_NAME)) { // Configure loader. - ldr.perNodeBufferSize(1024); - ldr.perNodeParallelLoadOperations(8); + stmr.perNodeBufferSize(1024); + stmr.perNodeParallelLoadOperations(8); for (int i = 0; i < ENTRY_COUNT; i++) { - ldr.addData(i, Integer.toString(i)); + stmr.addData(i, Integer.toString(i)); // Print out progress while loading cache. if (i > 0 && i % 10000 == 0) http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a8f17386/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java index 7cf4ef9..e43eb55 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePopularNumbersExample.java @@ -92,14 +92,14 @@ public class CachePopularNumbersExample { * @throws IgniteException If failed. */ private static void streamData(final Ignite ignite) throws IgniteException { - try (IgniteDataStreamer<Integer, Long> ldr = ignite.dataStreamer(CACHE_NAME)) { + try (IgniteDataStreamer<Integer, Long> stmr = ignite.dataStreamer(CACHE_NAME)) { // Set larger per-node buffer size since our state is relatively small. - ldr.perNodeBufferSize(2048); + stmr.perNodeBufferSize(2048); - ldr.updater(new IncrementingUpdater()); + stmr.updater(new IncrementingUpdater()); for (int i = 0; i < CNT; i++) - ldr.addData(RAND.nextInt(RANGE), 1L); + stmr.addData(RAND.nextInt(RANGE), 1L); } } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/a8f17386/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala ---------------------------------------------------------------------- diff --git a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala index 69b67c2..594ade1 100644 --- a/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala +++ b/examples/src/main/scala/org/apache/ignite/scalar/examples/ScalarCachePopularNumbersExample.scala @@ -92,13 +92,13 @@ object ScalarCachePopularNumbersExample extends App { def streamData() { // Set larger per-node buffer size since our state is relatively small. // Reduce parallel operations since we running the whole ignite cluster locally under heavy load. - val ldr = dataStreamer$[Int, Long](CACHE_NAME, 2048) + val smtr = dataStreamer$[Int, Long](CACHE_NAME, 2048) // TODO IGNITE-44: restore invoke. - (0 until CNT) foreach (_ => ldr.addData(Random.nextInt(RANGE), 1L)) + (0 until CNT) foreach (_ => smtr.addData(Random.nextInt(RANGE), 1L)) - ldr.close(false) + smtr.close(false) } /**
