hatadan aşağıya iniyorum. Neye sebep olduğuna dair bir fikrin var mı? import findspark
findspark.init()
hatası: Bunun nedeni SPARK_HOME ortam değişkeni büyük olasılıkla IndexError Traceback
Dahili hesaplamaları için bir java nesnesi kullanan pyspark python'da kullanılacak bir UDF oluşturmam gerekiyor. ben böyle bir şey yapar basit bir piton olsaydı: def f(x):
return 7
fudf = pyspar