pyspark code error
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-12-2022 09:24 PM
rdd4 = rdd3.reducByKey(lambda x,y: x+y)
AttributeError: 'PipelinedRDD' object has no attribute 'reducByKey'
Pls help me out with this
Labels:
- Labels:
-
Apache spark
-
Object
-
Pyspark
Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
12-12-2022 10:44 PM
Is it a typo or are you really using reducByKey instead of reduceByKey ? 😅
Uma Mahesh D