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
Parameters:
Name | Type | Description | Default |
---|---|---|---|
_write_args |
Dict[Union[str], Union[str, bool, Dict[str, str], DataFrame]]
|
|
required |