You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2014/12/14 09:01:39 UTC
spark git commit: fixed spelling errors in documentation
Repository: spark
Updated Branches:
refs/heads/master ef84dab8c -> 2a2983f7c
fixed spelling errors in documentation
changed "form" to "from" in 3 documentation entries for Kafka integration
Author: Peter Klipfel <pe...@klipfel.me>
Closes #3691 from peterklipfel/master and squashes the following commits:
0fe7fc5 [Peter Klipfel] fixed spelling errors in documentation
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2a2983f7
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2a2983f7
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2a2983f7
Branch: refs/heads/master
Commit: 2a2983f7c5edce8e4d1d7592adcf227cbd462ae9
Parents: ef84dab
Author: Peter Klipfel <pe...@klipfel.me>
Authored: Sun Dec 14 00:01:16 2014 -0800
Committer: Josh Rosen <jo...@databricks.com>
Committed: Sun Dec 14 00:01:16 2014 -0800
----------------------------------------------------------------------
.../scala/org/apache/spark/streaming/kafka/KafkaUtils.scala | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/2a2983f7/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
----------------------------------------------------------------------
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
index b4ac929..df725f0 100644
--- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
+++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala
@@ -75,7 +75,7 @@ object KafkaUtils {
}
/**
- * Create an input stream that pulls messages form a Kafka Broker.
+ * Create an input stream that pulls messages from a Kafka Broker.
* Storage level of the data will be the default StorageLevel.MEMORY_AND_DISK_SER_2.
* @param jssc JavaStreamingContext object
* @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..)
@@ -93,7 +93,7 @@ object KafkaUtils {
}
/**
- * Create an input stream that pulls messages form a Kafka Broker.
+ * Create an input stream that pulls messages from a Kafka Broker.
* @param jssc JavaStreamingContext object
* @param zkQuorum Zookeeper quorum (hostname:port,hostname:port,..).
* @param groupId The group id for this consumer.
@@ -113,7 +113,7 @@ object KafkaUtils {
}
/**
- * Create an input stream that pulls messages form a Kafka Broker.
+ * Create an input stream that pulls messages from a Kafka Broker.
* @param jssc JavaStreamingContext object
* @param keyTypeClass Key type of RDD
* @param valueTypeClass value type of RDD
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org