【发布时间】:2020-06-15 10:29:26
【问题描述】:
我想在我的本地机器上运行下面的代码。
from pyspark import SparkContext
from pyspark.sql.session import SparkSession
def quiet_logs( sc ):
logger = sc._jvm.org.apache.log4j
logger.LogManager.getLogger("org"). setLevel( logger.Level.ERROR )
logger.LogManager.getLogger("akka").setLevel( logger.Level.ERROR )
#Spark Data Frame Jobs
spark = SparkSession.builder.getOrCreate()
我的机器上没有安装spark。
这有意义吗?
我的目的是从本地机器加载数据到 hadoop?
提前致谢
【问题讨论】: