Skip to content

Commit

Permalink
fix malform docstring in SparkStreamingDataSet
Browse files Browse the repository at this point in the history
Signed-off-by: Nok Chan <[email protected]>
  • Loading branch information
noklam committed Jun 13, 2023
1 parent 49f3414 commit 0feaaf4
Showing 1 changed file with 9 additions and 8 deletions.
17 changes: 9 additions & 8 deletions kedro-datasets/kedro_datasets/spark/spark_streaming_dataset.py
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,16 @@ class SparkStreamingDataSet(AbstractDataSet):
`YAML API <https://kedro.readthedocs.io/en/stable/data/\
data_catalog.html#use-the-data-catalog-with-the-yaml-api>`_:
.. code-block:: yaml
raw.new_inventory:
type: streaming.extras.datasets.spark_streaming_dataset.SparkStreamingDataSet
filepath: data/01_raw/stream/inventory/
file_format: json
save_args:
output_mode: append
checkpoint: data/04_checkpoint/raw_new_inventory
header: True
load_args:
type: spark.SparkStreamingDataSet
filepath: data/01_raw/stream/inventory/
file_format: json
save_args:
output_mode: append
checkpoint: data/04_checkpoint/raw_new_inventory
header: True
load_args:
schema:
filepath: data/01_raw/schema/inventory_schema.json
"""
Expand Down

0 comments on commit 0feaaf4

Please sign in to comment.