aboutsummaryrefslogtreecommitdiff
path: root/streaming/src/main
diff options
context:
space:
mode:
authorShixiong Zhu <shixiong@databricks.com>2015-12-21 22:28:18 -0800
committerReynold Xin <rxin@databricks.com>2015-12-21 22:28:18 -0800
commit93da8565fea42d8ac978df411daced4a9ea3a9c8 (patch)
tree7608a6e3f600ecbea1876df6ee290156ce674ddc /streaming/src/main
parent0a38637d05d2338503ecceacfb911a6da6d49538 (diff)
downloadspark-93da8565fea42d8ac978df411daced4a9ea3a9c8.tar.gz
spark-93da8565fea42d8ac978df411daced4a9ea3a9c8.tar.bz2
spark-93da8565fea42d8ac978df411daced4a9ea3a9c8.zip
[MINOR] Fix typos in JavaStreamingContext
Author: Shixiong Zhu <shixiong@databricks.com> Closes #10424 from zsxwing/typo.
Diffstat (limited to 'streaming/src/main')
-rw-r--r--streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala8
1 files changed, 4 insertions, 4 deletions
diff --git a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
index 8f21c79a76..7a50135025 100644
--- a/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
+++ b/streaming/src/main/scala/org/apache/spark/streaming/api/java/JavaStreamingContext.scala
@@ -695,9 +695,9 @@ object JavaStreamingContext {
*
* @param checkpointPath Checkpoint directory used in an earlier JavaStreamingContext program
* @param factory JavaStreamingContextFactory object to create a new JavaStreamingContext
- * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactor.
+ * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactory.
*/
- @deprecated("use getOrCreate without JavaStreamingContextFactor", "1.4.0")
+ @deprecated("use getOrCreate without JavaStreamingContextFactory", "1.4.0")
def getOrCreate(
checkpointPath: String,
factory: JavaStreamingContextFactory
@@ -718,7 +718,7 @@ object JavaStreamingContext {
* @param factory JavaStreamingContextFactory object to create a new JavaStreamingContext
* @param hadoopConf Hadoop configuration if necessary for reading from any HDFS compatible
* file system
- * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactor.
+ * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactory.
*/
@deprecated("use getOrCreate without JavaStreamingContextFactory", "1.4.0")
def getOrCreate(
@@ -744,7 +744,7 @@ object JavaStreamingContext {
* file system
* @param createOnError Whether to create a new JavaStreamingContext if there is an
* error in reading checkpoint data.
- * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactor.
+ * @deprecated As of 1.4.0, replaced by `getOrCreate` without JavaStreamingContextFactory.
*/
@deprecated("use getOrCreate without JavaStreamingContextFactory", "1.4.0")
def getOrCreate(