我正在尝试估计数据块上pyspark 3.0.1中数学分数的比例。某些情况下，我的total_marks是0。所以我写了以下代码 df_oversees2=SQLContext.sql("select A.total_marks=0 then 0 else (maths_marks/total_marks) end as prop_maths from myTable A ")
浏览 114提问于2021-02-15得票数 0
回答已采纳
在使用registerDataFrameAsTable时有问题。根据文档，它似乎在sqlContext类中，因此我自然地尝试了这样的方法：但这导致了这个错误：AttributeError: 'SparkSession' object has no attribute 'registerDataFrameAsTable' from py
浏览 0提问于2018-09-25得票数 1
现在，我正在为我的课程做一个项目，并发现一个将pandas dataframe转换为pyspark dataframe的问题。我制作了一只名为data_org的熊猫数据图，如下所示。所以我的代码是spark_df = SQLContext.createDataFrame(data_org)
然而，它出了问题TypeError: createDataFrame()缺少</
浏览 0提问于2018-03-29得票数 1
回答已采纳
我正在尝试使用pyspark在databricks中创建一个列。我需要检查是否在其他两个日期列之间找到了日期列，如果它是1，则不是0。我想把这个称为基本事实，因为它会告诉我在日期上它是在两个日期列之间找到的。这就是我到目前为止所知道的： df = (df .withColumn("Ground_truth_IE"，when(col("ReadingDateTime").between(col("EventStartDat
浏览 14提问于2020-10-22得票数 0
回答已采纳
很抱歉，之前我试图读取postgresql脚本并导入到SQL server数据库，但我一直在错误的TypeError: read_sql()中缺少一个必需的位置参数：“con”
如果我的脚本有任何错误，
浏览 3提问于2022-09-27得票数 -2
我在Azure上用pyspark编写了简单的代码(遵循这个链接-)x='x'data = pd.DataFrame({'a':[1,2,3,41,2,6,2,3,56,1,2,5,1,2,45,1,3,2DecisionTree.trainClassifier(data, numClasses=2, categoricalFeaturesInfo={},impurity='gini', maxDepth=5, maxBins=32
浏览 0提问于2019-04-02得票数 1
我尝试将比较属性和$set属性绑定到一个变量中，并在mongodb中呈现更新函数。但是它给了我以下的错误
from pymongo import MongoClientnUpserted" : 0, "nModified" : 1 })
回溯(最近一次调用)：
浏览 1提问于2019-08-11得票数 2
回答已采纳
我的代码如下所示：plt.show()追溯(最近一次调用)在()中TypeError:分散()缺少一个必需的位置参数：'y‘
如何纠正此错误？
浏览 1提问于2017-01-13得票数 0
我在谷歌上搜索了这个问题，但没有直接回答与spark-2.2.0-bin-hadoop2.7相关的问题。我正在尝试从本地目录读取文本文件，但我总是得到缺少name参数的错误消息。这是jupyter notebook中使用Python3的代码：data = sc.textFile("/home/bigdata/test.txt")
当我运行单元
浏览 2提问于2017-12-06得票数 5
回答已采纳
为了排名，我需要让row_number是一个pyspark数据帧。我看到在pyspark的窗口函数中有row_number函数，但这是使用HiveContext所必需的。我尝试用HiveContext替换sqlContext self.sc = pyspark.SparkContext()
#self.sqlContext = pyspark.sql
浏览 0提问于2016-10-30得票数 2
1回答
我刚认识蟒蛇，我需要你的帮助。我想从数据库中查询数据，这是我的代码，它有一个typeError。TypeError: query_data()缺少2个必需的位置参数：
浏览 3提问于2022-04-04得票数 0
我正在升级到1.10.2，从1.9.0，在python2.7，我遇到了airflow/contrib/operators/bigquery_operator.py的麻烦，更确切地说，bql参数的降级有利于sql`@apply_defaults
def __init__(sql=None, bql=None, ...):i
浏览 1提问于2019-06-27得票数 0
回答已采纳
2回答
谁能给我解释一下如何在Django URL中传递参数TypeError at /time/plus/2/ hours_ahead()
浏览 0提问于2020-09-18得票数 0
send_mail()缺少一个必需的位置参数：'recipient_list‘EMAIL_HOST = 'smtp.gmail.comjshrijit@gmail.com'
然后<
浏览 1提问于2019-05-24得票数 0
当我在数据库中运行一个数据文件时，我得到了一个上面提到的错误。我不知道如何解决这个问题，也不知道哪里出了问题。NonTargeted_count")),F.sum(F.when(df_promodata_daypart.type=="Targeted").alias("Targeted_count")))
在这里，我还需要得到类型列的计数，如dataframe中提到的那样。
浏览 2提问于2020-02-11得票数 1
回答已采纳
代码出现以下错误: LogisticRegression.predict_proba(X)
TypeError: predict_proba()缺少一个必需的位置参数：'X‘
我不明白为什么，我读了文档，也不知道我错过了什么论点。
浏览 3提问于2020-05-02得票数 0
1回答
我使用sklearn的tfidfvectorizer在进行数据清理和标记化之后，从tweet标记创建了一个稀疏tfidf矩阵。有没有人能帮我一下？--------------------------------------------------------------------------- 372 g = jac(x, *args)
TypeErrorof type
浏览 1提问于2020-02-13得票数 0
当我尝试在url中传递字符串时，出现错误: View_by_Course_list()缺少一个必需的位置参数：'course_code_and_name‘@csrf_exempt我收到错误:k return view_func(*args，**kwargs)
浏览 2提问于2021-06-04得票数 0
在scala中，当我有一个类似于：List(("a",1),("a",2),("b",3),("b",4),("b",5),("a",6))的RDD列表时，我想要计算每个字符的avg数。pyspark/worker.py"，21/12/24 01:27:02错误执行器:任务0.0中的异常(TID 6) org.a
浏览 5提问于2021-12-24得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
