ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

fixed spelling errors in documentation

Browse source 
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
This commit is contained in:
Peter Klipfel 2014-12-14 00:01:16 -08:00 committed by Josh Rosen
parent ef84dab8c6
commit 2a2983f7c5
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaUtils.scala vendored
View file

@ -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