эл-та
возникает ошибка https://www.google.com/search?q=SPARK-5063&oq=SPARK-5063&aqs=chrome..69i57j0l6.345j0j7&client=ubuntu&sourceid=chrome&ie=UTF-8 , я понимаю почему, но не знаю как исправить
post_rdd =sc.parallelize(inputPosts).map(
lambda p: len(spark.sql("SELECT * FROM sport_dict where name in("+p.get('content').split(" ").join("','")+')') \
.rdd.collect())
)
Нельзя делать подзапрос внутри запроса
Обсуждают сегодня