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
12-12-2022 10:44 PM
Is it a typo or are you really using reducByKey instead of reduceByKey ? 😅
never-displayed
Join our fast-growing data practitioner and expert community of 80K+ members, ready to discover, help and collaborate together while making meaningful connections.
Click here to register and join today!
Engage in exciting technical discussions, join a group with your peers and meet our Featured Members.