英文: TypeError: 'Column' object is not callable when adding column to Struct 问题 我正在实现这里提到的答案。...
110评论apache-spark
pyspark
TypeError: 添加列到结构时，’Column’ 对象不可调用
110评论apache-spark
pyspark
110评论apache-spark
pyspark
在Pyspark中，在数据框中添加带有时间间隔的新时间戳列。
我正在尝试检查一个缩写是否不是一个单词的一部分。
英文: I'm trying to check if an abbreviation is not part of a word 问题 我正在尝试检查存储在abbr列中的缩写是否存在于同一实体...
95评论databricks
pyspark
处理嵌套的 JSON 结构
英文: handling nested Json structure 问题 假设我们有以下的JSON结构： { "positions": { "node": &...
83评论apache-spark
java
如何在Spark SQL中扩展内置的聚合函数（使用Scala）？
英文: How to extend built-in aggregate function in Spark SQL (using Scala)? 问题 以下是您要翻译的内容： "基本上最终...
89评论apache-spark
scala
How can I filter an rows in column of ArrayType(StringType) against items in another column in a separate dataframe using pyspark?
如何在PySpark中打印current_date()的结果？
英文: How to print the result of current_date() in PySpark? 问题 这是在Python中非常简单的，但我目前正在学习在Databricks中使用P...
113评论apache-spark
dataframe
将Spark Dataset列从UDT转换为Array。
英文: Convert a Spark Dataset column from a UDT to Array<String> 问题 I'm using the Spark OrientDB...
88评论apache-spark
scala
输出的Parquet文件在使用Spark中的列重新分区后非常大。
英文: Output Parquet file is very big in size after repartitioning with column in Spark 问题 我尝试根据列重新分区的...
92评论apache-spark
apache-spark-sql
在Databricks中使用Pyspark dataframe进行奇数列的”Unpivot”操作。
英文: Unpivot odd no of columns in Pyspark dataframe in databricks 问题 我有69列需要进行解封逆透视，我尝试了这种代码： from py...
84评论apache-spark
pyspark