[
https://issues.apache.org/jira/browse/KAFKA-7269?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16596582#comment-16596582
]
ASF GitHub Bot commented on KAFKA-7269:
---------------------------------------
guozhangwang closed pull request #5512: KAFKA-7269: Add docs for KStream.merge
URL: https://github.com/apache/kafka/pull/5512
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/docs/streams/developer-guide/dsl-api.html
b/docs/streams/developer-guide/dsl-api.html
index beb83a3970a..f61f052d5d0 100644
--- a/docs/streams/developer-guide/dsl-api.html
+++ b/docs/streams/developer-guide/dsl-api.html
@@ -591,7 +591,30 @@ <h2><a class="toc-backref" href="#id7">Overview</a><a
class="headerlink" href="#
</div>
</td>
</tr>
- <tr class="row-even"><td><p
class="first"><strong>Peek</strong></p>
+ <tr class="row-even"><td><p
class="first"><strong>Merge</strong></p>
+ <ul class="last simple">
+ <li>KStream → KStream</li>
+ </ul>
+ </td>
+ <td><p class="first">Merges records of two streams
into one larger stream.
+ (<a class="reference external"
+
href="../../../javadoc/org/apache/kafka/streams/kstream/KStream.html#merge-org.apache.kafka.streams.kstream.KStream-">details</a>)
+ <p>There is no ordering guarantee between records
+ from different streams in the merged stream.
Relative order is preserved within each input stream though (ie, records within
the same input stream are processed in order)</p>
+ <div class="last highlight-java">
+ <div class="highlight">
+ <pre>
+<span class="n">KStream</span><span class="o"><</span><span
class="kt">byte</span><span class="o">[],</span> <span
class="n">String</span><span class="o">></span> <span
class="n">stream1</span> <span class="o">=</span> <span class="o">...;</span>
+
+<span class="n">KStream</span><span class="o"><</span><span
class="kt">byte</span><span class="o">[],</span> <span
class="n">String</span><span class="o">></span> <span
class="n">stream2</span> <span class="o">=</span> <span class="o">...;</span>
+
+<span class="n">KStream</span><span class="o"><</span><span
class="kt">byte</span><span class="o">[],</span> <span
class="n">String</span><span class="o">></span> <span
class="n">merged</span> <span class="o">=</span> <span
class="n">stream1</span><span class="o">.</span><span
class="na">merge</span><span class="o">(</span><span
class="n">stream2</span><span class="o">);</span>
+ </pre>
+ </div>
+ </div>
+ </td>
+ </tr>
+ <tr class="row-odd"><td><p
class="first"><strong>Peek</strong></p>
<ul class="last simple">
<li>KStream → KStream</li>
</ul>
@@ -622,7 +645,7 @@ <h2><a class="toc-backref" href="#id7">Overview</a><a
class="headerlink" href="#
</div>
</td>
</tr>
- <tr class="row-odd"><td><p
class="first"><strong>Print</strong></p>
+ <tr class="row-even"><td><p
class="first"><strong>Print</strong></p>
<ul class="last simple">
<li>KStream → void</li>
</ul>
@@ -641,7 +664,7 @@ <h2><a class="toc-backref" href="#id7">Overview</a><a
class="headerlink" href="#
</div>
</td>
</tr>
- <tr class="row-even"><td><p
class="first"><strong>SelectKey</strong></p>
+ <tr class="row-odd"><td><p
class="first"><strong>SelectKey</strong></p>
<ul class="last simple">
<li>KStream → KStream</li>
</ul>
@@ -669,7 +692,7 @@ <h2><a class="toc-backref" href="#id7">Overview</a><a
class="headerlink" href="#
</div>
</td>
</tr>
- <tr class="row-odd"><td><p class="first"><strong>Table to
Stream</strong></p>
+ <tr class="row-even"><td><p class="first"><strong>Table to
Stream</strong></p>
<ul class="last simple">
<li>KTable → KStream</li>
</ul>
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
> KStream.merge is not documented
> -------------------------------
>
> Key: KAFKA-7269
> URL: https://issues.apache.org/jira/browse/KAFKA-7269
> Project: Kafka
> Issue Type: Improvement
> Components: documentation, streams
> Affects Versions: 1.0.0, 1.0.1, 1.0.2, 1.1.0, 1.1.1, 2.0.0
> Reporter: John Roesler
> Assignee: Luca Pette
> Priority: Major
> Labels: beginner, newbie
>
> If I understand the operator correctly, it should be documented as a
> stateless transformation atÂ
> https://kafka.apache.org/20/documentation/streams/developer-guide/dsl-api.html#stateless-transformations
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
