We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 3747d8b commit 4425ad4Copy full SHA for 4425ad4
1 file changed
streamz/core.py
@@ -957,12 +957,12 @@ class partition(Stream):
957
Maximum partition size
958
timeout: int or float, optional
959
Number of seconds after which a partition will be emitted,
960
- even if it's size is less than ``n``. If ``None`` (default),
961
- a partition will be emitted only when it's size reaches ``n``.
+ even if its size is less than ``n``. If ``None`` (default),
+ a partition will be emitted only when its size reaches ``n``.
962
key: hashable or callable, optional
963
Emit items with the same key together as a separate partition.
964
If ``key`` is callable, partition will be identified by ``key(x)``,
965
- otherwise by ``key[x]``. Defaults to ``None``.
+ otherwise by ``x[key]``. Defaults to ``None``.
966
967
Examples
968
--------
0 commit comments