From 895f5cca08de4584a4a711cbd091ad9e2e66b3eb Mon Sep 17 00:00:00 2001 From: Holden Karau Date: Tue, 19 Jul 2016 15:28:48 -0700 Subject: [PATCH 1/2] Minor fix (parquet -> csv) --- docs/structured-streaming-programming-guide.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index aac88171fe3a4..e13ab803a777d 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 %} From 534c53fd492a4baa3a81cfceb064e0cc090d91aa Mon Sep 17 00:00:00 2001 From: Holden Karau Date: Tue, 19 Jul 2016 16:57:14 -0700 Subject: [PATCH 2/2] Minor fix (parquet -> csv) --- docs/structured-streaming-programming-guide.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/docs/structured-streaming-programming-guide.md b/docs/structured-streaming-programming-guide.md index e13ab803a777d..8c14c3d220a23 100644 --- a/docs/structured-streaming-programming-guide.md +++ b/docs/structured-streaming-programming-guide.md @@ -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 %}