diff options
author | Patrick Wendell <pwendell@gmail.com> | 2014-04-22 00:42:16 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-22 00:43:42 -0700 |
commit | 72aa131cb344a508a91f94183bc6b077e5f3a4b7 (patch) | |
tree | ac9aaae553c5d64602abe85d1befa15c717bf347 /streaming/src | |
parent | 0a731039e6fd0124dd743d3de549cd3fd0d53fbc (diff) | |
download | spark-72aa131cb344a508a91f94183bc6b077e5f3a4b7.tar.gz spark-72aa131cb344a508a91f94183bc6b077e5f3a4b7.tar.bz2 spark-72aa131cb344a508a91f94183bc6b077e5f3a4b7.zip |
SPARK-1496: Have jarOfClass return Option[String]
A simple change, mostly had to change a bunch of example code.
Author: Patrick Wendell <pwendell@gmail.com>
Closes #438 from pwendell/jar-of-class and squashes the following commits:
aa010ff [Patrick Wendell] SPARK-1496: Have jarOfClass return Option[String]
(cherry picked from commit 83084d3b7bab09524dd85054c442abaf97d22fea)
Signed-off-by: Patrick Wendell <pwendell@gmail.com>
Diffstat (limited to 'streaming/src')
-rw-r--r-- | streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala index daa5c69bba..6d9dc87a70 100644 --- a/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala +++ b/streaming/src/main/scala/org/apache/spark/streaming/StreamingContext.scala @@ -543,7 +543,7 @@ object StreamingContext extends Logging { * Find the JAR from which a given class was loaded, to make it easy for users to pass * their JARs to StreamingContext. */ - def jarOfClass(cls: Class[_]): Seq[String] = SparkContext.jarOfClass(cls) + def jarOfClass(cls: Class[_]): Option[String] = SparkContext.jarOfClass(cls) private[streaming] def createNewSparkContext(conf: SparkConf): SparkContext = { // Set the default cleaner delay to an hour if not already set. |