эл-та
                  
                  
                  возникает ошибка 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())
                  
                  
                          )
                  
                  
                
Нельзя делать подзапрос внутри запроса
Обсуждают сегодня