diff --git a/doc/python.md b/doc/python.md index 4569b7fd..3260a39c 100644 --- a/doc/python.md +++ b/doc/python.md @@ -21,7 +21,7 @@ $ bin/pyspark --jars /spark-redis--jar-with-dependencies.jar - ```python df = spark.read.json("examples/src/main/resources/people.json") df.write.format("org.apache.spark.sql.redis").option("table", "people").option("key.column", "name").save() -loadedDf = spark.read.format("org.apache.spark.sql.redis").option("table", "people").load() +loadedDf = spark.read.format("org.apache.spark.sql.redis").option("table", "people").option("key.column", "name").load() loadedDf.show() ``` @@ -31,8 +31,6 @@ loadedDf.show() 127.0.0.1:6379> hgetall people:Justin 1) "age" 2) "19" -3) "name" -4) "Justin" ``` The self-contained application can be configured in the following manner: