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:42:16 -0700 |
| commit | 83084d3b7bab09524dd85054c442abaf97d22fea (patch) | |
| tree | a75e777fa1b6e8e03660b01b641ee1f9a2187640 /streaming | |
| parent | ac164b79d12f5a269d9c05d04dced51a415e3b0e (diff) | |
| download | spark-83084d3b7bab09524dd85054c442abaf97d22fea.tar.gz spark-83084d3b7bab09524dd85054c442abaf97d22fea.tar.bz2 spark-83084d3b7bab09524dd85054c442abaf97d22fea.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]
Diffstat (limited to 'streaming')
| -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. |