You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2015/03/04 17:21:20 UTC
incubator-ignite git commit: # ignite-394: ldr -> stmr at examples
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 <as...@gridgain.com>
Authored: Wed Mar 4 19:21:14 2015 +0300
Committer: Artem Shutak <as...@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)
}
/**