Attributes¶
Classes¶
spark_expectations.sinks.plugins.kafka_writer.SparkExpectationsKafkaWritePluginImpl
¶
Bases: SparkExpectationsSinkWriter
class helps to write the stats data into the NSP
Functions¶
writer(_write_args: Dict[Union[str], Union[str, bool, Dict[str, str], DataFrame]]) -> None
¶
The functions helps to write data into the kafka topic Args: _write_args:
Returns: