Repository: spark Updated Branches: refs/heads/branch-2.0 a804c9260 -> c2b4228d7
[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 <hol...@us.ibm.com> Closes #14274 from holdenk/minor-docfix-schema-of-csv-rather-than-parquet. (cherry picked from commit 1bf13ba3a24aa002bfaa660588490e527c5bf243) Signed-off-by: Sean Owen <so...@cloudera.com> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/c2b4228d Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/c2b4228d Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/c2b4228d Branch: refs/heads/branch-2.0 Commit: c2b4228d7dcd275909969f8e1a938cae02820326 Parents: a804c92 Author: Holden Karau <hol...@us.ibm.com> Authored: Thu Jul 21 09:17:38 2016 +0100 Committer: Sean Owen <so...@cloudera.com> Committed: Thu Jul 21 09:17:46 2016 +0100 ---------------------------------------------------------------------- docs/structured-streaming-programming-guide.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/c2b4228d/docs/structured-streaming-programming-guide.md ---------------------------------------------------------------------- diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index aac8817..8c14c3d 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 %} --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
