[MINOR][DOCS][STREAMING] Minor docfix schema of csv rather than parquet in comments
## What changes were proposed in this pull request? Fix parquet to csv in a comment to match the input format being read. ## How was this patch tested? N/A (doc change only) Author: Holden Karau <holden@us.ibm.com> Closes #14274 from holdenk/minor-docfix-schema-of-csv-rather-than-parquet.
This commit is contained in:
parent
cfa5ae84ed
commit
1bf13ba3a2
|
@ -449,7 +449,7 @@ val userSchema = new StructType().add("name", "string").add("age", "integer")
|
|||
val csvDF = spark
|
||||
.readStream
|
||||
.option("sep", ";")
|
||||
.schema(userSchema) // Specify schema of the parquet files
|
||||
.schema(userSchema) // Specify schema of the csv files
|
||||
.csv("/path/to/directory") // Equivalent to format("csv").load("/path/to/directory")
|
||||
{% endhighlight %}
|
||||
|
||||
|
@ -476,7 +476,7 @@ StructType userSchema = new StructType().add("name", "string").add("age", "integ
|
|||
Dataset[Row] csvDF = spark
|
||||
.readStream()
|
||||
.option("sep", ";")
|
||||
.schema(userSchema) // Specify schema of the parquet files
|
||||
.schema(userSchema) // Specify schema of the csv files
|
||||
.csv("/path/to/directory"); // Equivalent to format("csv").load("/path/to/directory")
|
||||
{% endhighlight %}
|
||||
|
||||
|
|
Loading…
Reference in a new issue