diff options
| author | Peter Klipfel <peter@klipfel.me> | 2014-12-14 00:01:16 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@databricks.com> | 2014-12-14 00:01:46 -0800 |
| commit | 6eec4bc3be2ded61236cb5c2b158283571128a42 (patch) | |
| tree | 75c91c4c73ab195fbc033edc004ae105d532d5c1 /external | |
| parent | c82e99d87a8c37a1c4c2b24ed54e6295decf9117 (diff) | |
| download | spark-6eec4bc3be2ded61236cb5c2b158283571128a42.tar.gz spark-6eec4bc3be2ded61236cb5c2b158283571128a42.tar.bz2 spark-6eec4bc3be2ded61236cb5c2b158283571128a42.zip | |
fixed spelling errors in documentation
changed "form" to "from" in 3 documentation entries for Kafka integration
Author: Peter Klipfel <peter@klipfel.me>
Closes #3691 from peterklipfel/master and squashes the following commits:
0fe7fc5 [Peter Klipfel] fixed spelling errors in documentation
(cherry picked from commit 2a2983f7c5edce8e4d1d7592adcf227cbd462ae9)
Signed-off-by: Josh Rosen <joshrosen@databricks.com>
Diffstat (limited to 'external')
| -rw-r--r-- | external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala | 6 |
1 files changed, 3 insertions, 3 deletions
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 b4ac929e0c..df725f0c65 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 |