pyspark.pipelines.create\_sink
==============================

.. currentmodule:: pyspark.pipelines

.. autofunction:: create_sink