File tree Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Expand file tree Collapse file tree 1 file changed +1
-3
lines changed Original file line number Diff line number Diff line change @@ -21,7 +21,7 @@ $ bin/pyspark --jars <path-to>/spark-redis-<version>-jar-with-dependencies.jar -
21
21
``` python
22
22
df = spark.read.json(" examples/src/main/resources/people.json" )
23
23
df.write.format(" org.apache.spark.sql.redis" ).option(" table" , " people" ).option(" key.column" , " name" ).save()
24
- loadedDf = spark.read.format(" org.apache.spark.sql.redis" ).option(" table" , " people" ).load()
24
+ loadedDf = spark.read.format(" org.apache.spark.sql.redis" ).option(" table" , " people" ).option( " key.column " , " name " ). load()
25
25
loadedDf.show()
26
26
```
27
27
@@ -31,8 +31,6 @@ loadedDf.show()
31
31
127.0.0.1:6379> hgetall people:Justin
32
32
1) " age"
33
33
2) " 19"
34
- 3) " name"
35
- 4) " Justin"
36
34
```
37
35
38
36
The self-contained application can be configured in the following manner:
You can’t perform that action at this time.
0 commit comments