diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:09:52 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:09:52 +0530 |
| commit | 63addd93a8337f5181c0e7d64c86393cb519c661 (patch) | |
| tree | abbfc64c0d55a122dfc434d64e82a05d386d8520 /streaming | |
| parent | a289ded41d535f2b080ed2a9ccbe6d67e4f8178b (diff) | |
| download | spark-63addd93a8337f5181c0e7d64c86393cb519c661.tar.gz spark-63addd93a8337f5181c0e7d64c86393cb519c661.tar.bz2 spark-63addd93a8337f5181c0e7d64c86393cb519c661.zip | |
Fixed warning ClassManifest -> ClassTag
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala index e0f6351ef7..ba1312cbe8 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala @@ -95,7 +95,7 @@ class KafkaReceiver[T: ClassTag, D <: Decoder[_]: Manifest]( } // Handles Kafka Messages - private class MessageHandler[T: ClassManifest](stream: KafkaStream[T]) extends Runnable { + private class MessageHandler[T: ClassTag](stream: KafkaStream[T]) extends Runnable { def run() { logInfo("Starting MessageHandler.") for (msgAndMetadata <- stream) { |