Repository: incubator-beam Updated Branches: refs/heads/master 0af145bba -> afedd68e8
[BEAM-1099] Minor typos in KafkaIO Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e9f254ef Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e9f254ef Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e9f254ef Branch: refs/heads/master Commit: e9f254ef2769a082c7fbb500c1c28c6224ac5a7f Parents: 0af145b Author: Jakob Homan <[email protected]> Authored: Tue Dec 6 16:59:50 2016 -0800 Committer: Davor Bonaci <[email protected]> Committed: Tue Dec 6 17:03:42 2016 -0800 ---------------------------------------------------------------------- .../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e9f254ef/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java ---------------------------------------------------------------------- diff --git a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java index 4212d59..c87d12b 100644 --- a/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java +++ b/sdks/java/io/kafka/src/main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java @@ -106,7 +106,7 @@ import org.slf4j.LoggerFactory; * metadata like topic-partition and offset, along with key and value associated with a Kafka * record. * - * <p>Although most applications consumer single topic, the source can be configured to consume + * <p>Although most applications consume a single topic, the source can be configured to consume * multiple topics or even a specific set of {@link TopicPartition}s. * * <p>To configure a Kafka source, you must specify at the minimum Kafka <tt>bootstrapServers</tt> @@ -250,8 +250,8 @@ public class KafkaIO { } /** - * Returns a new {@link Read} that reads from the topics. All the partitions are from each - * of the topics is read. + * Returns a new {@link Read} that reads from the topics. All the partitions from each + * of the topics are read. * See {@link UnboundedKafkaSource#generateInitialSplits(int, PipelineOptions)} for description * of how the partitions are distributed among the splits. */ @@ -1134,7 +1134,7 @@ public class KafkaIO { boolean isShutdown = false; - // Wait for threads to shutdown. Trying this a loop to handle a tiny race where poll thread + // Wait for threads to shutdown. Trying this as a loop to handle a tiny race where poll thread // might block to enqueue right after availableRecordsQueue.poll() below. while (!isShutdown) { @@ -1178,7 +1178,7 @@ public class KafkaIO { } /** - * Returns a new {@link Write} transform that write to given topic. + * Returns a new {@link Write} transform that writes to given topic. */ public Write<K, V> withTopic(String topic) { return new Write<K, V>(topic, keyCoder, valueCoder, producerConfig);
