Streaming (``runtime.streaming``)
==================================

Base
----

.. automodule:: pyspark_pipeline_framework.runtime.streaming.base
   :members:
   :show-inheritance:

Sources
-------

.. automodule:: pyspark_pipeline_framework.runtime.streaming.sources
   :members:
   :show-inheritance:

Sinks
-----

.. automodule:: pyspark_pipeline_framework.runtime.streaming.sinks
   :members:
   :show-inheritance:

Hooks
-----

.. automodule:: pyspark_pipeline_framework.runtime.streaming.hooks
   :members:
   :show-inheritance: