diff options
author | Holden Karau <holden@us.ibm.com> | 2016-07-21 09:17:38 +0100 |
---|---|---|
committer | Sean Owen <sowen@cloudera.com> | 2016-07-21 09:17:38 +0100 |
commit | 1bf13ba3a24aa002bfaa660588490e527c5bf243 (patch) | |
tree | 12257987049ded0129f26e39d6e546e034297e78 | |
parent | cfa5ae84ed0f48b3b108d0614dbf6fcd79ef5179 (diff) | |
download | spark-1bf13ba3a24aa002bfaa660588490e527c5bf243.tar.gz spark-1bf13ba3a24aa002bfaa660588490e527c5bf243.tar.bz2 spark-1bf13ba3a24aa002bfaa660588490e527c5bf243.zip |
[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.
-rw-r--r-- | docs/structured-streaming-programming-guide.md | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index aac88171fe..8c14c3d220 100644 --- a/docs/structured-streaming-programming-guide.md +++ b/docs/structured-streaming-programming-guide.md @@ -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 %} |