1回答
我想通过将concepts的值作为参数值传递给UDF has_any_concept来执行以下查询。以下是环境中的内容['CREATININE_QUANTITATIVE_24_HOUR_DIALYSIS_FLUID_OBSTYPE', 'CREATININE_QUANTITATIVE_SERUM_OBSTYPE
浏览 21提问于2021-03-09得票数 0
回答已采纳
我尝试了以下几种方法：%%pysparkselect * from silver.employee_dim
浏览 23提问于2021-06-02得票数 0
我正试图确定是否可以通过JDBC从Spark将这些查询传递给Postgres。qry = """cr
浏览 5提问于2020-02-06得票数 1
回答已采纳
在我的项目中，我必须选择多个值并将其传递给查询。例如，page1包含复选框。我正在将选中的复选框id存储到一个数组中。我正在对该数组进行混洗，并随机获取这些值。现在，我需要将这些随机值传递给一个查询。在数据库中使用IN操作符，我可以静态地传递这些值，但是如何将这些值动态地传递给查询呢？对于ex：(静态传值)
SELECT * F
浏览 1提问于2012-09-03得票数 2
回答已采纳
我正在读一个描述超过256个字符的源码。我想把它们写到红移上。根据这一点：在创建数据帧时指定模式应该是一种变通方法。我不能让它工作。如何使用varchar(max)指定模式？
浏览 9提问于2018-09-06得票数 1
回答已采纳
2回答
创建DataFrame后，我可以将其保存为avro、csv或拼板格式。
在dataframe或rdd中是否有其他格式可用于在Hadoop中保存数据？
浏览 2提问于2017-12-21得票数 1
我有一个名为datetime的列，它是一个表单字符串。因为日志是如此接近的时间。TZ是可选的，因为它们都在同一个时区，但理想情况下，它们也想捕捉到这一点。试过formatw = 'MMM dd yyyy H:mm:ss,SSS a z'from table
Errorin SQL</e
浏览 1提问于2019-03-19得票数 0
回答已采纳
我想使用spark向数据库发送一个查询。现在我用的是 .option('url',database_url)但是，还有另一种方法可以在pyspark中激发查询，称为两人都在返回数据格式。
浏览 0提问于2018-04-06得票数 0
回答已采纳
我刚开始使用sql。我正在寻找数组(Named_struct())。但是，当我将 SQL查询数据转换为JSON时，它将显示如下 "id":1, "Product":[ 2512,"sdsf" ]我使用下面的查询作为内部查询。)
浏览 0提问于2021-06-15得票数 0
1回答
我已经创建了一个UDF，用于获取XML字符串、命名空间字典、x路径语法和XML中键值对的键，并返回一个值数组，以便稍后使用withColumn(col,explode(col))爆炸。现在，我正试图使用Pyspark在Databricks中包含XML字符串的列在dataframe上迭代此函数，并使用返回的数组创建一个新列。到目前为止，我已经使用作为我最初方法的想法，并在将<
浏览 6提问于2020-04-10得票数 0
2回答
) | | |-- vendor: string (nullable = true)df3 = sqlContext.sql("select vendorTags.vendor from globalcontacts")
如何在PySpark中查询如下所示的where子句中的<
浏览 0提问于2016-03-15得票数 16
回答已采纳
|我试着：from pyspark.sql import types as st
from pyspark.
浏览 1提问于2020-01-30得票数 3
回答已采纳
我正在尝试使用SPARK调用一个带有来自Python文件的单元查询的.SQL文件。它给出了错误-- AttributeError：'Builder‘对象没有属性'SparkContext’sc = SparkSession.SparkConte
浏览 2提问于2022-02-14得票数 0
我正在为存储库构建SQL查询生成器。此生成器将找到查询所需的所有字段，并创建SQL文本。为此，我使用了Format()过程。但是，我在运行时很难创建必须传递给格式化过程的TVarRec数组。使用格式(‘’%s，%s'，'AString'，‘AnotherString’)等常量构建这个数组很容易。但是，我们必须如何在运
浏览 4提问于2015-11-22得票数 2
回答已采纳
处理HABTM关系，并需要编写我可以通过ActiveRecord::Base.connection.execute(my_query)运行的sql查询字符串。一个SQL WHERE...IN子句需要一个整数ids数组，如下所示："DELETE from contacts_tags where tag_id = 99 AND contact_id IN (1,2, 3, 4)
我有一个想要传递给IN子句的I数组，但似乎不能以SQL</e
浏览 2提问于2016-04-19得票数 4
回答已采纳
1回答
我有一个Hive查询，它以这种格式返回数据：1.2.3.4, X, 51.2.3.4, Y, 21.2.3.4, Z, 9在PySpark中，我通过hive_context.sql(my_query).rdd获得这个{
浏览 2提问于2018-06-25得票数 2
回答已采纳
我想删除pyspark dataframe列中的一些重复的单词。基于 2.4.5 test_df = spark.createDataFrame([("I like this Book and this book be DOWNLOADED
浏览 0提问于2020-09-15得票数 2
我以拼图格式存储了一个pyspark sql dataframe。现在，我还想将其保存为xml格式。我该怎么做呢？直接将pyspark sql dataframe保存在xml中或将拼图转换为xml的解决方案，对我来说什么都行。提前谢谢。
浏览 0提问于2016-06-21得票数 0
我试图通过vbscript将一个字符串数组传递给powershell。我得到了file.ps1脚本中的params： [string[]]$target我试图通过vbscript调用file.ps1。我想让$target = @('c:\dev','d:\lib')被传进来。\file.ps1 -target1 """ & target & ""&quo
浏览 4提问于2021-02-05得票数 1
回答已采纳
PySpark的文档在示例中包括以下内容：from pyspark.sql.functions import *from datetime import date, timedelta, datetime
我不认识或理解最后两行的语法。(具体来说：import *from.)请有人向我解释
浏览 5提问于2022-06-15得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
