This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
The following commit(s) were added to refs/heads/trunk by this push:
new 4a274bc MINOR: JavaDoc improvements for RangeAssignor (#4079)
4a274bc is described below
commit 4a274bc9fd2ac3714788af0429fde8945a48636f
Author: Antony Stubbs <[email protected]>
AuthorDate: Sat Jan 27 06:35:54 2018 +1100
MINOR: JavaDoc improvements for RangeAssignor (#4079)
---
.../org/apache/kafka/clients/consumer/RangeAssignor.java | 15 +++++++++------
.../org/apache/kafka/streams/kstream/Transformer.java | 2 +-
2 files changed, 10 insertions(+), 7 deletions(-)
diff --git
a/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java
b/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java
index d8d72ee..5d5a268 100644
--- a/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java
+++ b/clients/src/main/java/org/apache/kafka/clients/consumer/RangeAssignor.java
@@ -26,17 +26,20 @@ import java.util.List;
import java.util.Map;
/**
- * The range assignor works on a per-topic basis. For each topic, we lay out
the available partitions in numeric order
+ * <p>The range assignor works on a per-topic basis. For each topic, we lay
out the available partitions in numeric order
* and the consumers in lexicographic order. We then divide the number of
partitions by the total number of
* consumers to determine the number of partitions to assign to each consumer.
If it does not evenly
* divide, then the first few consumers will have one extra partition.
*
- * For example, suppose there are two consumers C0 and C1, two topics t0 and
t1, and each topic has 3 partitions,
- * resulting in partitions t0p0, t0p1, t0p2, t1p0, t1p1, and t1p2.
+ * <p>For example, suppose there are two consumers <code>C0</code> and
<code>C1</code>, two topics <code>t0</code> and
+ * <code>t1</code>, and each topic has 3 partitions, resulting in partitions
<code>t0p0</code>, <code>t0p1</code>,
+ * <code>t0p2</code>, <code>t1p0</code>, <code>t1p1</code>, and
<code>t1p2</code>.
*
- * The assignment will be:
- * C0: [t0p0, t0p1, t1p0, t1p1]
- * C1: [t0p2, t1p2]
+ * <p>The assignment will be:
+ * <ul>
+ * <li><code>C0: [t0p0, t0p1, t1p0, t1p1]</code></li>
+ * <li><code>C1: [t0p2, t1p2]</code></li>
+ * </ul>
*/
public class RangeAssignor extends AbstractPartitionAssignor {
diff --git
a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
index 2eb4921..308fcad 100644
--- a/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
+++ b/streams/src/main/java/org/apache/kafka/streams/kstream/Transformer.java
@@ -24,7 +24,7 @@ import org.apache.kafka.streams.processor.StateStore;
import org.apache.kafka.streams.processor.TimestampExtractor;
/**
- * The {@code Transformer} interface for stateful mapping of an input record
to zero, one, or multiple new output
+ * The {@code Transformer} interface is for stateful mapping of an input
record to zero, one, or multiple new output
* records (both key and value type can be altered arbitrarily).
* This is a stateful record-by-record operation, i.e, {@link
#transform(Object, Object)} is invoked individually for
* each record of a stream and can access and modify a state that is available
beyond a single call of
--
To stop receiving notification emails like this one, please contact
[email protected].
