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/03 20:10:11 UTC
incubator-ignite git commit: # ignite-394: "data loader" -> "data
streamer" at scala
Repository: incubator-ignite
Updated Branches:
refs/heads/ignite-394 9f63999a2 -> de3dcf011
# ignite-394: "data loader" -> "data streamer" at scala
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/de3dcf01
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/de3dcf01
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/de3dcf01
Branch: refs/heads/ignite-394
Commit: de3dcf011a1ef9c872fb44317f00550ff6a4abe5
Parents: 9f63999
Author: Artem Shutak <as...@gridgain.com>
Authored: Tue Mar 3 22:10:36 2015 +0300
Committer: Artem Shutak <as...@gridgain.com>
Committed: Tue Mar 3 22:10:36 2015 +0300
----------------------------------------------------------------------
.../scalar/examples/ScalarCachePopularNumbersExample.scala | 8 ++++----
.../src/main/scala/org/apache/ignite/scalar/scalar.scala | 2 +-
2 files changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/de3dcf01/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 98d9637..69b67c2 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
@@ -17,15 +17,15 @@
package org.apache.ignite.scalar.examples
-import java.util.Timer
-
import org.apache.ignite.IgniteException
import org.apache.ignite.examples.datagrid.CacheNodeStartup
import org.apache.ignite.scalar.scalar
import org.apache.ignite.scalar.scalar._
+import java.util.Timer
+
+import scala.collection.JavaConversions._
import scala.util.Random
-import collection.JavaConversions._
/**
* Real time popular number counter.
@@ -92,7 +92,7 @@ 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 = dataLoader$[Int, Long](CACHE_NAME, 2048)
+ val ldr = dataStreamer$[Int, Long](CACHE_NAME, 2048)
// TODO IGNITE-44: restore invoke.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/de3dcf01/modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala
----------------------------------------------------------------------
diff --git a/modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala b/modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala
index b12c679..cdbf574 100644
--- a/modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala
+++ b/modules/scalar/src/main/scala/org/apache/ignite/scalar/scalar.scala
@@ -292,7 +292,7 @@ object scalar extends ScalarConversions {
* @param bufSize Per node buffer size.
* @return New instance of data streamer.
*/
- @inline def dataLoader$[K, V](
+ @inline def dataStreamer$[K, V](
@Nullable cacheName: String,
bufSize: Int): IgniteDataStreamer[K, V] = {
val dl = ignite$.dataStreamer[K, V](cacheName)