diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 16:39:13 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 16:39:13 +0530 |
| commit | 8f3ac240cbdd678c0c76155b080dcc461355452e (patch) | |
| tree | a35684b591baa426bd022e0a070d3d900ed2a6d0 /examples | |
| parent | 4b4a36ea7d7f9e1d9c9ee1d6738deea579dc1b4e (diff) | |
| download | spark-8f3ac240cbdd678c0c76155b080dcc461355452e.tar.gz spark-8f3ac240cbdd678c0c76155b080dcc461355452e.tar.bz2 spark-8f3ac240cbdd678c0c76155b080dcc461355452e.zip | |
Fixed Warning: ClassManifest -> ClassTag
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala b/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala index 3b847fe603..deb1c8511a 100644 --- a/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala +++ b/examples/src/main/scala/spark/streaming/examples/ActorWordCount.scala @@ -2,6 +2,7 @@ package spark.streaming.examples import scala.collection.mutable.LinkedList import scala.util.Random +import scala.reflect.ClassTag import akka.actor.Actor import akka.actor.ActorRef @@ -65,7 +66,7 @@ class FeederActor extends Actor { * * @see [[spark.streaming.examples.FeederActor]] */ -class SampleActorReceiver[T: ClassManifest](urlOfPublisher: String) +class SampleActorReceiver[T: ClassTag](urlOfPublisher: String) extends Actor with Receiver { lazy private val remotePublisher = context.actorFor(urlOfPublisher) |