# 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 <ashu...@gridgain.com> Authored: Tue Mar 3 22:10:36 2015 +0300 Committer: Artem Shutak <ashu...@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)
