sparkDF = sqlContext.read.format('com.databricks.spark.csv').options(header='true').load('PR_DATA_35.csv')
Run Code Online (Sandbox Code Playgroud)
错误_ - - - - - - - - - - - - - - - - - - - - - - - - - -------------------------------------------------- -------------------------------------------------- Py4JJavaError () 中的回溯(最近一次调用最后一次)----> 1 SparkDF = sqlContext.read.format('com.databricks.spark.csv') .options(header='true').load('PR_DATA_35.csv ')
/home/ec2-user/spark/python/pyspark/sql/readwriter.pyc in load(self,path,format,schema,**options) 157 self.options(**options) 158 if isinstance(path,basestring) : --> 159 return self._df(self._jreader.load(path)) 160 elif 路径不是 None: 161 if type(path) != list:
/home/ec2-user/spark/python/lib/py4j-0.10.4-src.zip/py4j/java_gateway.py调用中(self,*args) 1131 答案 = self.gateway_client.send_command(命令) 1132 return_value = get_return_value( -> 1133 答案, self.gateway_client, self.target_id, self.name) …