<commit_before>API
===

Stream
------

.. currentmodule:: streamz

.. autosummary::
   Stream

.. autosummary::
   accumulate
   buffer
   collect
   combine_latest
   connect
   delay
   destroy
   disconnect
   filter
   flatten
   map
   partition
   rate_limit
   sink
   sliding_window
   timed_window
   union
   unique
   pluck
   zip
   zip_latest

Sources
-------

.. autosummary::
   filenames
   from_kafka
   from_textfile

Definitions
-----------

.. autofunction:: accumulate
.. autofunction:: buffer
.. autofunction:: collect
.. autofunction:: connect
.. autofunction:: combine_latest
.. autofunction:: delay
.. autofunction:: destroy
.. autofunction:: disconnect
.. autofunction:: filter
.. autofunction:: flatten
.. autofunction:: map
.. autofunction:: partition
.. autofunction:: rate_limit
.. autofunction:: sink
.. autofunction:: sliding_window
.. autofunction:: Stream
.. autofunction:: timed_window
.. autofunction:: union
.. autofunction:: unique
.. autofunction:: pluck
.. autofunction:: zip
.. autofunction:: zip_latest

.. autofunction:: filenames
.. autofunction:: from_kafka
.. autofunction:: from_textfile
<commit_msg>Add dask functions to API docs<commit_after>API
===

Stream
------

.. currentmodule:: streamz

.. autosummary::
   Stream

.. autosummary::
   accumulate
   buffer
   collect
   combine_latest
   Stream.connect
   delay
   Stream.destroy
   Stream.disconnect
   filter
   flatten
   map
   partition
   rate_limit
   scatter
   sink
   sliding_window
   timed_window
   union
   unique
   pluck
   zip
   zip_latest

Sources
-------

.. autosummary::
   filenames
   from_kafka
   from_textfile

DaskStream
----------

.. currentmodule:: streamz.dask

.. autosummary::
   DaskStream
   gather


Definitions
-----------

.. currentmodule:: streamz

.. autofunction:: accumulate
.. autofunction:: buffer
.. autofunction:: collect
.. autofunction:: combine_latest
.. autofunction:: delay
.. autofunction:: filter
.. autofunction:: flatten
.. autofunction:: map
.. autofunction:: partition
.. autofunction:: rate_limit
.. autofunction:: sink
.. autofunction:: sliding_window
.. autofunction:: Stream
.. autofunction:: timed_window
.. autofunction:: union
.. autofunction:: unique
.. autofunction:: pluck
.. autofunction:: zip
.. autofunction:: zip_latest

.. autofunction:: filenames
.. autofunction:: from_kafka
.. autofunction:: from_textfile

.. currentmodule:: streamz.dask

.. autofunction:: DaskStream
.. autofunction:: gather

{'fraction_non_alphanumeric': 0.12878482034719418, 'fraction_numerical': 0.0, 'mean_word_length': 2.9839228295819935, 'pattern_counts': {'":': 0, '<': 3, '<?xml version=': 0, '>': 3, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '7087301', 'n_tokens_mistral': 782, 'n_tokens_neox': 780, 'n_words': 182}