===================
Available operators
===================

Transformation operators
------------------------

.. toctree::
   :maxdepth: 1
    
   buffer_count
   buffer_while
   flatten
   left_join
   map
   merge
   reverse
   sort

Filtering operators
-------------------

.. toctree::
   :maxdepth: 1
    
   distinct
   filter
   skip
   take
   takeUntil

Asserting operators
-------------------

.. toctree::
   :maxdepth: 1
    
   if_empty
   overflow

Error handling operators
------------------------

.. toctree::
   :maxdepth: 1
    
   finalize

Utility operators
-----------------

.. toctree::
   :maxdepth: 1
    
   tap