我正在尝试读取CSV文件，以便可以使用Spark SQL查询它。CSV如下所示： 16;10;9/6/2018 CSV文件不包含标题，但我们知道第一列是部门代码，第二列是建筑代码，第三列是m/d/YYYY格式的日期。我编写了以下代码来加载带有自定义模式的CSV filesv： StructType sch = DataTypes.createStructType(new StructField[] {(sch)
浏览 33提问于2019-06-04得票数 4
回答已采纳
2回答
我正在使用Scala中的Spark读取一个csv文件。模式是预定义的，我正在使用它进行阅读。session .appName("Parquet Converter")val dataFrame: DataFrame =
浏览 0提问于2018-11-14得票数 5
回答已采纳
我用AWS编写了一个脚本，用于从AWS S3读取CSV文件，对少数字段进行空检查，并将结果作为新文件存储回S3。问题是，当遇到字符串类型的字段时，如果值为null，则转换为空字符串。以下是到目前为止编写的脚本：spark = glueContext.spark_sessiondatasource_df = datasource.toDF()
datasource_df.cr
浏览 1提问于2017-10-03得票数 0
回答已采纳
在本例中，T是一个包含字段x: OptionBigDecimal的case类Exception in thread "main" org.apache.spark.sql.AnalysisException") .load(file)我的case类反映了使用Option[T]读取的表，该表用于
浏览 1提问于2018-03-26得票数 4
我希望将csv中缺少的值视为空字符串。如何在以csv格式读取文件的同时执行此操作？我曾尝试使用spark.read.csv()..option("treatEmptyValuesAsNulls"，"false")，但它将空值视为空值。
浏览 10提问于2019-12-03得票数 0
1回答
当使用spark SQL语句时，我得到了一些奇怪的结果，如：如果我把somecol设置为ABC如果我将它设置为XXX，它将返回一行。
但是，如果我将列保留为空，例如，在CSV数据中(因此该值被读取为null)，则它仍然不会返回任何内容，即使null不
浏览 2提问于2022-06-10得票数 0
我知道如何用pyspark读取csv文件，但我在加载正确格式的csv文件时遇到了很多问题。我的csv有3列，其中第一列和第二列是字符串，但第三列是字典列表。我无法加载这最后一列。
浏览 68提问于2019-09-26得票数 0
在读取带有推断模式的文件(使用Spark2.0)之后：spark = SparkSession.builder.appName('foo').getOrCreate()
所有列(string和numeric )都是可空的。但是，如果我
浏览 3提问于2017-09-14得票数 2
我正在尝试使用spark Scala分析CSV文件，但问题是我的CSV文件包含空值的列，所以当从CSV文件读取数据时，我得到的错误为java.lang.ArrayIndexOutOfBoundException:12
我在CSV文件中的总列数是13，但有1列包含空值。
浏览 7提问于2017-07-01得票数 0
1回答
我试图使用Scala和Spark从csv读取数据，但是列的值为null。def createDataSchema但它们作为包含空值的列表返回(值为</
浏览 0提问于2019-09-11得票数 2
我正在读取Spark 2.0中的CSV文件，并使用以下内容计算列中的非空值：当我使用spark-shell测试它时，它工作得很好。当我创建一个包含代码的jar文
浏览 5提问于2016-11-19得票数 2
我为我的spark代码指定了模式，但是结果都返回NULL。然而，当I inferSchema=True，header=True时，我得到了正确的结果。longitude", DoubleType(), True)
,StructField("country", StringType(), True)]) 当我应用模式将文件作为数据帧读入时，如下所示： testzip = spark.read.csv("adl:/
浏览 35提问于2020-01-12得票数 0
回答已采纳
我知道如何使用spark-csv ()将csv文件读取到spark中，但我已经将csv文件表示为字符串，并希望将此字符串直接转换为数据帧。这个是可能的吗？
浏览 4提问于2016-08-24得票数 7
回答已采纳
1回答
我正在使用spark的读取功能读取csv文件sparkSession.read.option("delimiter",",").schema(schema).csv("test.csv").as[Customclass]
问题是，当某一行在
浏览 14提问于2018-02-06得票数 0
回答已采纳
让我们考虑包含以下数据的csv文件 Id、职务、年份 1，,2000 CSV读卡器代码： var inputDFRdd = spark.emptyDataFrame.rdd .option("mode", "FAILFAST")
.option("delimiter\&qu
浏览 49提问于2021-09-16得票数 0
1回答
我在蓝色数据库中使用火花放电。并需要加载数千个文件作为文件的列表。使用“多深度分区”，这使得很难使用基本路径读取文件。因此，我们将所有内容作为文件列表来读取，我想知道当您使用以下方法读取文件时，性能是否相同：spark.read.format('csv').load('/mnt/article/2021/08/0
浏览 4提问于2021-09-01得票数 2
回答已采纳
1回答
当我试图从csv文件创建的DF中编写avro文件时，我面临着一个NullPointerException： SparkSession\sparkCsvToAvro\\src\\main\\resources"; Dataset<Row> csv= read.csv(path);
DataFrameWriter<Row>
浏览 7提问于2017-05-09得票数 0
回答已采纳
1回答
我是PySpark的新手，长话短说:我有一个拼花文件，我正在尝试阅读它并与SPARK一起使用它，但目前我可以： .schema(location_schema) \然后将所有内
浏览 2提问于2022-02-27得票数 0
我用谷歌搜索了一下，发现如何使用以下代码将csv文件读取到Spark DataFrame中from pyspark.sql import SparkSessionspark = SparkSession.builder.getOrCreate()p
浏览 3提问于2020-09-15得票数 0
14回答
我想在spark中读取CSV，并将它转换为DataFrame，然后用df.registerTempTable("table_name")存储在HDFS中。我试过：我发现的错误：
java.lang.RuntimeException: hdfs://&#
浏览 33提问于2015-04-17得票数 164
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
