This is an automated email from the ASF dual-hosted git repository.
bhavanisudha pushed a commit to branch asf-site
in repository https://gitbox.apache.org/repos/asf/hudi.git
The following commit(s) were added to refs/heads/asf-site by this push:
new 9ec9ac9 [MINOR] Fix pyspark quickstart example (#2009)
9ec9ac9 is described below
commit 9ec9ac9f26f5ac3e789377291707b8e62c39f56a
Author: Balaji Varadarajan <[email protected]>
AuthorDate: Sat Aug 22 15:57:20 2020 -0700
[MINOR] Fix pyspark quickstart example (#2009)
---
docs/_docs/0.5.3/1_1_quick_start_guide.md | 2 +-
docs/_docs/1_1_quick_start_guide.md | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git a/docs/_docs/0.5.3/1_1_quick_start_guide.md
b/docs/_docs/0.5.3/1_1_quick_start_guide.md
index e5bb36a..696a8be 100644
--- a/docs/_docs/0.5.3/1_1_quick_start_guide.md
+++ b/docs/_docs/0.5.3/1_1_quick_start_guide.md
@@ -419,7 +419,7 @@ hudi_delete_options = {
from pyspark.sql.functions import lit
deletes = list(map(lambda row: (row[0], row[1]), ds.collect()))
-df = spark.sparkContext.parallelize(deletes).toDF(['partitionpath',
'uuid']).withColumn('ts', lit(0.0))
+df = spark.sparkContext.parallelize(deletes).toDF(['uuid',
'partitionpath']).withColumn('ts', lit(0.0))
df.write.format("hudi"). \
options(**hudi_delete_options). \
mode("append"). \
diff --git a/docs/_docs/1_1_quick_start_guide.md
b/docs/_docs/1_1_quick_start_guide.md
index c0894b8..003fafb 100644
--- a/docs/_docs/1_1_quick_start_guide.md
+++ b/docs/_docs/1_1_quick_start_guide.md
@@ -427,7 +427,7 @@ hudi_delete_options = {
from pyspark.sql.functions import lit
deletes = list(map(lambda row: (row[0], row[1]), ds.collect()))
-df = spark.sparkContext.parallelize(deletes).toDF(['partitionpath',
'uuid']).withColumn('ts', lit(0.0))
+df = spark.sparkContext.parallelize(deletes).toDF(['uuid',
'partitionpath']).withColumn('ts', lit(0.0))
df.write.format("hudi"). \
options(**hudi_delete_options). \
mode("append"). \
