ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [09/40] incubator-ignite git commit: # ignite-394: "data loader" -> "data streamer" at scala
Date Thu, 12 Mar 2015 13:08:02 GMT
# 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/sprint-2
Commit: de3dcf011a1ef9c872fb44317f00550ff6a4abe5
Parents: 9f63999
Author: Artem Shutak <ashutak@gridgain.com>
Authored: Tue Mar 3 22:10:36 2015 +0300
Committer: Artem Shutak <ashutak@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)


Mime
View raw message