Skip to content

Attributes

spark_expectations.sinks.plugins.base_writer.SPARK_EXPECTATIONS_WRITER_PLUGIN = 'spark_expectations_writer_plugins' module-attribute

spark_expectations.sinks.plugins.base_writer.spark_expectations_writer_impl = pluggy.HookimplMarker(SPARK_EXPECTATIONS_WRITER_PLUGIN) module-attribute

spark_expectations.sinks.plugins.base_writer.writer_plugin_spec = pluggy.HookspecMarker(SPARK_EXPECTATIONS_WRITER_PLUGIN) module-attribute

Classes

spark_expectations.sinks.plugins.base_writer.SparkExpectationsSinkWriter

Functions

writer(_write_args: Dict[Union[str], Union[str, bool, Dict[str, str], DataFrame]]) -> None

function consist signature to write data into kafka etc. which will be implemented in the child class Args: _write_args:

Returns:

Source code in .venv/env/virtual/dev.py3.12/lib/python3.12/site-packages/spark_expectations/sinks/plugins/base_writer.py 
12
13
14
15
16
17
18
19
20
21
@writer_plugin_spec
def writer(self, _write_args: Dict[Union[str], Union[str, bool, Dict[str, str], DataFrame]]) -> None:
    """
    function consist signature to write data into kafka etc. which will be implemented in the child class
    Args:
        _write_args:

    Returns:

    """