This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch 1.0.x
in repository https://gitbox.apache.org/repos/asf/incubator-pekko.git
The following commit(s) were added to refs/heads/1.0.x by this push:
new e6009cab93 add partition operator in stream graph docs (#1093) (#1094)
e6009cab93 is described below
commit e6009cab93a9e1c11862fb60d9ae608546011916
Author: AndyChen(JingZhangChen) <[email protected]>
AuthorDate: Fri Feb 2 01:34:06 2024 +0800
add partition operator in stream graph docs (#1093) (#1094)
Signed-off-by: Andy.Chen <[email protected]>
---
docs/src/main/paradox/stream/stream-graphs.md | 1 +
1 file changed, 1 insertion(+)
diff --git a/docs/src/main/paradox/stream/stream-graphs.md
b/docs/src/main/paradox/stream/stream-graphs.md
index 6e1067e635..23cdabf907 100644
--- a/docs/src/main/paradox/stream/stream-graphs.md
+++ b/docs/src/main/paradox/stream/stream-graphs.md
@@ -39,6 +39,7 @@ Pekko Streams currently provide these junctions (for a
detailed list see the @re
* @scala[`Broadcast[T]`]@java[`Broadcast<T>`] – *(1 input, N outputs)*
given an input element emits to each output
* @scala[`Balance[T]`]@java[`Balance<T>`] – *(1 input, N outputs)* given
an input element emits to one of its output ports
+ * @scala[`Partition[T]]`]@java[`Partition<T>`] – *(1 input, N outputs)*
given an input element emits to specified output based on a partition function
* @scala[`UnzipWith[In,A,B,...]`]@java[`UnzipWith<In,A,B,...>`] – *(1
input, N outputs)* takes a function of 1 input that given a value for each
input emits N output elements (where N <= 20)
* @scala[`UnZip[A,B]`]@java[`UnZip<A,B>`] – *(1 input, 2 outputs)* splits
a stream of @scala[`(A,B)`]@java[`Pair<A,B>`] tuples into two streams, one of
type `A` and one of type `B`
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
