diff options
author | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 18:14:25 +0530 |
---|---|---|
committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-04-29 18:14:25 +0530 |
commit | d3518f57cd833f6297860c6344e685b9bf0210f5 (patch) | |
tree | b2b01e59779b4806860afbc0d568ba5dccf441e4 /streaming | |
parent | 8f3ac240cbdd678c0c76155b080dcc461355452e (diff) | |
download | spark-d3518f57cd833f6297860c6344e685b9bf0210f5.tar.gz spark-d3518f57cd833f6297860c6344e685b9bf0210f5.tar.bz2 spark-d3518f57cd833f6297860c6344e685b9bf0210f5.zip |
Fixed warning: erasure -> runtimeClass
Diffstat (limited to 'streaming')
-rw-r--r-- | streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala b/streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala index 962ba6619d..aa1a8b6ba2 100644 --- a/streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala +++ b/streaming/src/main/scala/spark/streaming/PairDStreamFunctions.scala @@ -457,7 +457,7 @@ extends Serializable { prefix: String, suffix: String )(implicit fm: ClassTag[F]) { - saveAsHadoopFiles(prefix, suffix, getKeyClass, getValueClass, fm.erasure.asInstanceOf[Class[F]]) + saveAsHadoopFiles(prefix, suffix, getKeyClass, getValueClass, fm.runtimeClass.asInstanceOf[Class[F]]) } /** @@ -487,7 +487,7 @@ extends Serializable { prefix: String, suffix: String )(implicit fm: ClassTag[F]) { - saveAsNewAPIHadoopFiles(prefix, suffix, getKeyClass, getValueClass, fm.erasure.asInstanceOf[Class[F]]) + saveAsNewAPIHadoopFiles(prefix, suffix, getKeyClass, getValueClass, fm.runtimeClass.asInstanceOf[Class[F]]) } /** @@ -509,7 +509,7 @@ extends Serializable { self.foreach(saveFunc) } - private def getKeyClass() = implicitly[ClassTag[K]].erasure + private def getKeyClass() = implicitly[ClassTag[K]].runtimeClass - private def getValueClass() = implicitly[ClassTag[V]].erasure + private def getValueClass() = implicitly[ClassTag[V]].runtimeClass } |