From 1bf13ba3a24aa002bfaa660588490e527c5bf243 Mon Sep 17 00:00:00 2001 From: Holden Karau Date: Thu, 21 Jul 2016 09:17:38 +0100 Subject: [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 Closes #14274 from holdenk/minor-docfix-schema-of-csv-rather-than-parquet. --- docs/structured-streaming-programming-guide.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'docs') 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 %} -- cgit v1.2.3