You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/12/07 01:04:02 UTC
[1/2] incubator-beam git commit: [BEAM-1099] Minor typos in KafkaIO
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 <jg...@gmail.com>
Authored: Tue Dec 6 16:59:50 2016 -0800
Committer: Davor Bonaci <da...@google.com>
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);
[2/2] incubator-beam git commit: This closes #1524
Posted by da...@apache.org.
This closes #1524
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/afedd68e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/afedd68e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/afedd68e
Branch: refs/heads/master
Commit: afedd68e806830549724dfc0f2565d756cc6b46d
Parents: 0af145b e9f254e
Author: Davor Bonaci <da...@google.com>
Authored: Tue Dec 6 17:03:54 2016 -0800
Committer: Davor Bonaci <da...@google.com>
Committed: Tue Dec 6 17:03:54 2016 -0800
----------------------------------------------------------------------
.../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
----------------------------------------------------------------------