spark dataframe 中write 方法，求大神指点下，不胜感激

dataframe的write方法将spark分析后的结果放到pg数据库，结果表中有个自曾字段，而那个write方法不能指定添加那几个字段只能全部添加，怎么办，求大神指导换种思路也行，不胜感激，小弟欲哭无泪啊

写回答
好问题 0 提建议
追加酬金
关注问题
分享
邀请回答
编辑收藏删除结题
收藏举报

1条回答

关注

码龄粉丝数原力等级 --

被采纳

被点赞

采纳率
devmiao 2016-02-22 14:44
关注
http://www.open-open.com/lib/view/open1452259673808.html

解决无用
评论打赏
分享
举报

评论

按下Enter换行，Ctrl+Enter发表内容

报告相同问题？

关注问题

求大神指教！！！python dataframe apply 函数报错 python
2019-09-23 00:20

回答 1 已采纳 unit没有定义，感觉应该就是除以quantity
求大神指点Python温度转换代码报错原因,拜托了 python
2019-01-30 15:06

回答 5 已采纳楼主你的F=(eval(temp[0,-1])-32)/1.8写错了，temp[0,-1]修改为temp[0:-1]，截取最后一个字符的前的所有字符
根据条件向dataframe中增加行 python
2022-05-04 15:46

回答 1 已采纳 import pandas as pd import numpy as np def copy(df, row, exist): # 自定义函数，用以根据计算结果进行行的复制任务 idx
Spark DataFrame isin方法使用
2021-06-19 15:44

董可伦的博客总结如何使用Spark DataFrame isin 方法需求查询DataFrame某列在某些值里面的内容，等于SQL IN ,如 where year in(‘2017’,‘2018’) 代码示例 isin 方法只能传集合类型，不能直接传DataFame或Column package ...
dataframe中的数据清洗问题(二） python
2022-03-22 11:44

回答 2 已采纳第一个问题如果把所有的nan 都替换为0就这样 cashflow.fillna(0,inplace=True) 如果只是把A,B,C三列替换，就这样 cashflow.fillna(value={'
DataFrame中查找指定的值所在的位置的问题 python 数据分析有问必答
2022-12-30 11:09

回答 2 已采纳 column = ['A', 'A', 'B', 'A', 'C', 'B'] dict={} a=0 b=0 c=0 for i in range(len(column)): if co
如何将dataframe中的text列表下数据的中括号给去除掉？ python
2021-11-02 13:35

回答 2 已采纳 list1=[['a','b'],['c','d']] list2=[] for i in list1: list2.append( ','.join(i)) print(list2)
[spark] dataframe的cache方法
2023-12-26 14:51

言之。的博客方法用于将 DataFrame 的计算结果缓存到内存中，以便在后续的操作中能够更快地访问这些数据。这对于在多个阶段使用相同的 DataFrame 数据时是非常有用的，可以避免重复计算。需要注意的是，缓存操作可能会导致额外的...
Dataframe中的数据筛选 python
2023-01-04 14:19

回答 2 已采纳可以通过pandas条件筛选完成，以下为参考代码 filtered_stock = stock[stock['ts_code'].str.endswith(('SH', 'SZ'))] 其中条件部分
DataFrame求内积 python 深度学习
2023-03-22 20:30

回答 2 已采纳笨一点的方法就是不断循环切片，还有一种就是利用pandas中的shift函数实现数据偏移
dataframe中存在列表数据无法输出，如何解决？ python
2022-12-16 09:20

回答 2 已采纳 data是个什么数据，excel 还是csv ？可以使用pands 读取获取数据 import pandas sd pd df=pd.read_csv('file_path') regions_da
spark dataframe过滤查询filter
2021-03-17 16:08

别说话写代码的博客 filter过滤条件直接写sql的条件就行 ordDF.filter("pin_ct <= 5 AND ratio > 0.6 AND adowner_ct <= 5").orderBy(desc("ratio"))
python: 两个csv的dataframe中数值比较 python 有问必答
2021-04-10 07:00

回答 2 已采纳试下下面的代码, 两个表都是二维的表, 思路: 两个循环, 第1层循环第1个表的每个值, 第2个循环是在第2个表中按列循环判断是否为最小值,获取索引 import pandas as pd im
Spark DataFrame中的join使用
2018-07-02 15:31

大数据教学笔记的博客 Spark DataFrame中join与SQL很像，都有inner join, left join, right join, full join; 那么join方法如何实现不同的join类型呢？看其原型 def join(right : DataFrame, usingColumns : Seq[String], joinType : ...
Spark Dataframe 的创建方法与存储
2019-02-19 17:13

Code_LT的博客创建方法一、通过 toDF()函数创建 // sc is an existing SparkContext. val sqlContext = new org.apache.spark.sql.SQLContext(sc) // this is used to implicitly convert an RDD or Seq to a DataFrame. ...
没有解决我的问题, 去提问

悬赏问题

¥50 如何用脚本实现输入法的热键设置
¥20 我想使用一些网络协议或者部分协议也行，主要想实现类似于traceroute的一定步长内的路由拓扑功能
¥30 深度学习，前后端连接
¥15 孟德尔随机化结果不一致
¥15 apm2.8飞控罗盘bad health，加速度计校准失败
¥15 求解O-S方程的特征值问题给出边界层布拉休斯平行流的中性曲线
¥15 谁有desed数据集呀
¥20 手写数字识别运行c仿真时，程序报错错误代码sim211-100
¥15 关于#hadoop#的问题
¥15 (标签-Python|关键词-socket)