根据列当前值更新pyspark中的列
在pyspark中，可以使用withColumn()方法根据列当前值更新列。该方法接受两个参数，第一个参数是要更新的列名，第二个参数是一个表达式，用于计算新的列值。
以下是一个示例代码：
from pyspark.sql import SparkSession
from pyspark.sql.functions import col
# 创建SparkSession
spark = SparkSession.builder.getOrCreate()
# 创建示例数据
data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["Name", "Age"])
# 更新Age列，将Age值加上10
df = df.withColumn("Age", col("Age") + 10)
# 显示更新后的数据
df.show()输出结果为：
+-------+---+
| Name|Age|
+-------+---+
| Alice| 35|
| Bob| 40|
|Charlie| 45|
+-------+---+在上述示例中，我们使用withColumn()方法更新了Age列，将每个值加上了10。通过col("Age")获取了Age列的当前值，并使用加法运算符将其与10相加，得到新的列值。最后，我们将更新后的数据显示出来。
需要注意的是，withColumn()方法返回一个新的DataFrame，原始DataFrame并没有被修改。如果需要保留更新后的结果，需要将其赋值给一个新的变量。
相关·内容
5回答
查看新的spark API，还不清楚是否有可能修改DataFrame列。
如何更改数据文件的行x列y中的值？
在pandas中，这将是：
df.ix[x,y] = new_value
编辑：合并下面所说的内容，您不能修改现有的数据格式，因为它是不可变的，但是您可以返回一个新的数据格式，并进行所需的修改。
如果只想根据条件替换列中的值，如np.where
from pyspark.sql import functions as F
update_func = (F.when(F.col('update_col') == replace_val, new_value)
浏览 12提问于2015-03-17得票数 95
回答已采纳
在从dataframe中选择一些列的查询中，我有一个列类型: map，它有多个属性。我试图从该列中只选择几个属性，但这向我返回了一个错误，因为一些属性包含特殊字符，如'-‘，该列的其他属性工作正常
示例：
sqlContext.sql("select colA, colB.attribute1 from schema.table")
但是，如果我选择了一个包含-的属性，它将失败
sqlContext.sql("select colA, colB.4-TRANSPORT from schema.table")
=>失败
18/08/29 15:21:
浏览 0提问于2018-08-29得票数 1
我运行以下代码脚本 from pyspark.sql import Window
from pyspark.sql import functions as func
from pyspark.sql import SQLContext
from pyspark import SparkContext
sc = SparkContext.getOrCreate()
sqlContext = SQLContext(sc)
tup = [(1, "a"), (1, "a"), (2, "a"), (1, "b"), (2, "
浏览 19提问于2021-04-01得票数 1
回答已采纳
1回答
从mysql导入数据
、、、
我正在尝试将数据从mysql导入到pyspark。我能够将数据从mysql作为数据框架从pyspark获取。但是数据帧显示了daylightsavings时间内时间戳列的错误时间。
下面是一个表的数据，该表在日光节省tTme期间获得了数据。
MySQL Data
id Package_time System_time PACKAGE GROUP
1 3/12/2017 2:19:51 AM 2017-03-11 18:13:43.577 TEST_1 STATUS
浏览 7提问于2017-11-27得票数 1
回答已采纳
1回答
我需要用'modifiedDate‘列在Pyspark中创建delta表。行更新时，修改time的值应更改为当前时间。我曾想过要做一个触发器，但却找不到任何关于在带有delta表的Pyspark中使用触发器的信息。我该怎么做？
浏览 1提问于2022-01-30得票数 1
回答已采纳
1回答
理解窗口函数的一个示例
、、、
我正在运行代码脚本以获得以下结果。代码如下所示。我不明白为什么我会得到如图所示的xyz1列。例如，为什么xyz1的第一行是0。根据窗口函数，它对应的组应该是前两行，但为什么F.count(F.col("xyz")).over(w)在这里得到0。 import pyspark
from pyspark.sql import SparkSession
from pyspark.sql.window import Window
from pyspark.sql import functions as F
spark = SparkSession.builder.appName(&#
浏览 15提问于2021-04-03得票数 1
回答已采纳
1回答
在Postgres中，我有一个名为"mytable“的表，其中有两个列，id (bigint)和value (varchar(255))。
id使用nextval('my_sequence')从序列中获取其值。
PySpark应用程序接受一个dataframe并使用postgresql(PostgreSQL42.1.4.jar)将数据插入到"mytable“中。我使用以下方法创建id列：
df.withColumn('id', lit("nextval('my_sequence')"))
Postgres将该列解释
浏览 0提问于2018-01-21得票数 2
回答已采纳
给定两个列的表: DEVICEID和DEVICETYPE
如果DEVICEID中的字符串长度为5，如何更新列DEVICETYPE：
from pyspark.sql.functions import *
df.where(length(col("DEVICEID")) = 5).show()
浏览 1提问于2020-06-23得票数 3
回答已采纳
1回答
我正在尝试从Apache中的另一列中创建一个新列。
这些数据(大量缩写)看上去像
Date Day_of_Week
2018-05-26T00:00:00.000+0000 5
2018-05-05T00:00:00.000+0000 6
而且应该看起来像
Date Day_of_Week Weekday
2018-05-26T00:00:00.000+0000 5 Thursday
2018-05-05T00:00:00.000+0000 6 Friday
我尝试过 & & 手册中的建议
其结果是：
def int2da
浏览 0提问于2018-10-26得票数 0
回答已采纳
我正在尝试将csv读取到pyspark中，但问题是它有一个文本列，由于该列在数据中有一些坏行
此文本列还包含换行符，由于这些换行符，其他列中的数据将被损坏
我已经尝试使用pandas并使用一些额外的参数来加载我的csv
a = pd.read_csv("Mycsvname.csv",sep = '~',quoting=csv.QUOTE_NONE, dtype = str,error_bad_lines=False, quotechar='~', lineterminator='\n' )
它在pandas中工作得很好，但是我想在
浏览 1提问于2018-09-06得票数 0
我刚刚在ubuntu 16.04上安装了apache-spark 3.1.2。在安装和设置PATH、SPARK_HOME、PYSPARK_PYTHON环境变量后，当我尝试启动pyspark时，我得到以下错误： $ $SPARK_HOME/bin/pyspark
Python 3.5.2 (default, Jan 26 2021, 13:30:48)
[GCC 5.4.0 20160609] on linux
Type "help", "copyright", "credits" or "license" for more in
浏览 110提问于2021-08-10得票数 0
如何有效地在 DataFrame 中创建一个新列，该列是 spark 中其他行的函数
这是我描述的问题的spark实现
from nltk.metrics.distance import edit_distance as edit_dist
from pyspark.sql.functions import col, udf
from pyspark.sql.types import IntegerType
d = {
'id': [1, 2, 3, 4, 5, 6],
'word': ['cat', 'hat'
浏览 0提问于2018-01-09得票数 0
回答已采纳
1回答
我目前正在尝试对服务列进行一些聚合。我想将所有相似的服务分组并求和，如果可能的话，将其展平到一行中。
输入：
+------------------+--------------------+
| cid | Services|
+------------------+--------------------+
|845124826013182686| [112931, serv1]|
|845124826013182686| [146936, serv1]|
|845124826013182686| [32718, s
浏览 23提问于2018-06-15得票数 0
回答已采纳
我是PySpark的新手，正面临一个奇怪的问题。在加载CSV数据集时，我尝试将某些列设置为不可为空。我可以用一个非常小的数据集(test.csv)重现我的案例：
col1,col2,col3
11,12,13
21,22,23
31,32,33
41,42,43
51,,53
在第5行，第2列有一个空值，我不想在我的DF中获取该行。我将所有字段都设置为不可空(nullable=false)，但是我得到了一个所有三列都具有nullable=true的模式。即使我将所有三列都设置为不可空，也会发生这种情况！我运行的是Spark的最新版本，2.0.1。
代码如下：
from pyspark.sql
浏览 0提问于2016-10-07得票数 14
回答已采纳
1回答
我有一个表格，在第一个数字出现后，这个数字需要重复填入后面的所有列 下面是一个表格示例： student_id 2016Q1 2016Q2 2016Q3 2016Q4 2017Q1 2017Q2 2017Q3
1 1
2 1
3 1
4 1
5 1
6
浏览 15提问于2019-06-06得票数 1
1回答
下面是我的表格的图片。列Unit和Description具有ComboBox编辑器。我已经为Description列添加了一个item listener，当我选择一个不同的项目时，items for Unit列也会改变。
我的问题是，对于表的其他行，它会有不同的描述。与前一行相比，该行的Unit列也将具有不同的项。
当B列的ComboBox发生更改时，如何仅为该行填充A列的ComboBox？
浏览 2提问于2016-01-17得票数 1
我使用以下命令创建dataproc集群
gcloud dataproc clusters create datascience \
--initialization-actions \
gs://dataproc-initialization-actions/jupyter/jupyter.sh \
然而，当我提交我的PySpark作业时，我得到了以下错误
例外情况: worker中的Python版本与驱动程序3.7中的版本不同，PySpark无法运行不同的次要versions.Please检查环境变量PYSPARK_PYTHON和PYSPARK_DRIVER_PYTHON。
浏览 0提问于2018-07-19得票数 7
回答已采纳
1回答
我希望在将单个列中的列数连在一起之后创建一个列，但使用PySpark格式的字典格式。
我已经将数据连接到一个列中，但无法以字典格式存储数据。请找到下面所附的屏幕截图，以获得更多细节。如果需要更多的信息，请告诉我。
浏览 12提问于2022-06-29得票数 -1
回答已采纳
我试图根据pyspark数据格式中的ID列对列进行分组，并根据另一列的值对列进行求和。
为了举例说明，请考虑以下虚拟数据格式：
+-----+-------+---------+
| ID| type| amount|
+-----+-------+---------+
| 1| a| 55|
| 2| b| 1455|
| 2| a| 20|
| 2| b| 100|
| 3| null| 230|
+-----+-------+---------+
我想
浏览 1提问于2019-06-13得票数 0
回答已采纳
这个场景与这篇文章非常相似，但有一些变化：
我有这种格式的数据：
data.show()
+---------------+--------------------+--------------------+
| features| meta| telemetry|
+---------------+--------------------+--------------------+
| [seattle, 3]|[seattle, 3, 5344...|[[47, 1, 27, 92, ...|
| [miami, 1
浏览 0提问于2019-08-22得票数 0
1回答
当使用df.write.csv('path')输出到CSV文件时，是否有一种方法仅引用数据文件中的非数字列？
我知道您可以使用选项quoteAll=True来引用所有列，但我只想引用字符串列。
我使用的是PySpark 2.2.0。
浏览 0提问于2018-09-19得票数 1
我对pyspark是个新手。我有一个包含ID和BALANCE列的pyspark数据框。我尝试将列balance存储到100% (1-100%)的存储桶中，并计算每个存储桶中有多少个in。
我不能使用任何与RDD相关的东西，我只能使用Pyspark语法。我试过下面的代码
w = Window.orderBy(df.BALANCE)
test = df.withColumn('percentile_col',F.percent_rank().over(w))
我希望得到一个新的列，它可以自动计算平衡列中每个数据点的百分位数，并忽略缺少的值。
浏览 14提问于2019-07-11得票数 0
1回答
是否可以找到完整PySpark数据的哈希值(最好是散列256)。我不想找到单个行或列的散列。我知道pySpark中存在函数，用于从pyspark.sql.functions导入sha2进行列级哈希计算。
所需的是根据年份划分一个大数据，并为每年(小数据)查找散列值并将结果持久化到一个表中。
输入(产品，质量，商店，SoldDate)
读取数据中的数据，通过SoldDate进行分区，计算每个分区的散列，并将其写入文件/表。
输出：(日期，散列)
我这样做的原因是，我必须比较每天运行这个过程，然后检查哈希是否更改了以前的日期。
存在文件级别md5的可能性，但不希望生成文件，而是根据日期动态计算分区
浏览 8提问于2022-12-04得票数 0
我有一个MongoDB集合，如下所示：
{
"_id" : { "customerName" : "Bob", "customerPhone" : "123-456-7890"},
"purchases": ["A", "B", "C", "D"]
}
基本上，_id是关于客户的一对独特的密钥，而购买则是客户购买的商品的数组。
我还有一个PySpark DataFrame，我想把它推到这个集合中，其中包含我想要更新这个
浏览 2提问于2017-11-15得票数 3
我有一个PySpark DataFrame df，它有一些列，如下所示。hour列采用UTC时间，我想创建一个基于time_zone列的具有本地时间的新列。我如何在PySpark中做到这一点？
df
+-------------------------+------------+
| hour | time_zone |
+-------------------------+------------+
|2019-10-16T20:00:00+0000 | US/Eastern |
|2019-10-15T23:0
浏览 2提问于2019-12-03得票数 5
回答已采纳
我正在从下面的代码段读取CSV文件。
df_pyspark = spark.read.csv("sample_data.csv") df_pyspark
当我试图打印数据帧时，它的输出如下所示：
DataFrame[_c0: string, _c1: string, _c2: string, _c3: string, _c4: string, _c5: string]
对于每一列，dataType都显示“String”，尽管列包含不同的数据类型，如下所示：
df_pyspark.show()
|_c0| _c1| _c2|
浏览 5提问于2022-11-02得票数 1
回答已采纳
我的ipthon启动脚本如下所示
IPYTHON_OPTS="notebook --port 8889 \
--notebook-dir='/usr/hdp/2.3.2.0-2950/spark/' \
--ip='*' --no-browser" pyspark
它在老的Spark上运行得很好。但是当我切换到Spark2时，我得到以下错误：
在Spark 2.0+中删除了IPYTHON和IPYTHON_OPTS。将它们从环境中删除，并改为设置PYSPARK_DRIVER_PYTHON和PYSPARK_DRIVER_PYTHON_OPTS。
还不
浏览 7提问于2017-03-08得票数 4
2回答
在PySpark中，可以使用列对象和字符串来选择列。这两种方法返回相同的结果。有什么不同吗？什么时候应该使用列对象而不是字符串？例如，我可以使用column对象：
import pyspark.sql.functions as F
df.select(F.lower(F.col('col_name')))
# or
df.select(F.lower(df['col_name']))
# or
df.select(F.lower(df.col_name))
或者我可以使用字符串来代替，并得到相同的结果：
df.select(F.lower('col_n
浏览 0提问于2020-11-09得票数 0
1回答
我有一个SQL查询，我正试图将其转换为PySpark。在SQL查询中，我们连接两个表并更新条件匹配的列。SQL查询如下所示：
UPDATE [STUDENT_TABLE] INNER JOIN [COLLEGE_DATA]
ON ([STUDENT_TABLE].UNIQUEID = COLLEGE_DATA.PROFESSIONALID)
AND ([STUDENT_TABLE].[ADDRESS] = COLLEGE_DATA.STATE_ADDRESS)
SET STUDENT_TABLE.PROGRESS = "REGULAR"
WHERE (((STUDENT_T
浏览 1提问于2022-10-20得票数 0
回答已采纳
1回答
这个问题非常琐碎，但是我在PySpark的世界里是全新的，我面临着很多问题，即使是简单的任务。
假设我们有一个带有A列的dataframe df。
我想要创建另一个dataframe，它只包含最后一个值为A的一个列(这里的最后一个值是指列A底部的真正记录)。
我已经试过了
df["A"][-1]，但我错了。
请注意，如果可能的话，我希望可以为PySpark和Pyspark中的Python代码提供一个解决方案。
浏览 1提问于2019-06-21得票数 0
回答已采纳
2回答
我有以下数据结构：
列"s“和"d”表示"x“列中对象的转换。我想要做的是获取"x“列中的每个对象的转换字符串。例如，“新”栏如下：
有使用PySpark的好方法吗？
我使用PySpark尝试了以下udf代码，但它不起作用：
from pyspark.sql.functions import udf
from pyspark.sql.functions import array_distinct
from pyspark.sql.types import ArrayType, StringType
create_transition = u
浏览 13提问于2022-10-19得票数 1
回答已采纳
我在pyspark中有一个超过300列的数据框架。在这些列中，有一些列的值为null。
例如：
Column_1 column_2
null null
null null
234 null
125 124
365 187
and so on
当我想对column_1求和时，我得到的结果是一个空值，而不是724。
现在，我想用空格替换数据框所有列中的null。所以当我尝试对这些列求和时，我不会得到空值，但我会得到一个数值。
我们如何在pyspark中实现这一点呢？
浏览 1提问于2017-02-18得票数 56
回答已采纳
我一直无法确定时间表历史是如何存储的。如果您有一个包含多个nvarchar数据列和一个定期更新的库存数量列的表，那么SQL Server是否为库存数量的每一次更改存储静态列的副本，还是有一种面向对象的存储数据的方法？我希望将所有列都包含在历史记录中，因为可能会对nvarchar列进行很少的更改，但如果数百万qty更新重复其他列，则要注意表的历史记录大小。
浏览 0提问于2018-04-16得票数 2
回答已采纳
1回答
Spark SQL更新/删除
、、、、
目前，我正在做一个使用pySpark的项目，它读取一些Hive表，将它们存储为数据帧，并且我必须对它们执行一些更新/过滤。我正在不惜一切代价避免使用Spark语法来创建一个框架，该框架只接受参数文件中的SQL，该参数文件将使用我的pySpark框架运行。
现在的问题是，我必须在我的最终数据帧上执行更新/删除查询，是否有任何可能的工作来在我的数据帧上执行这些操作？
非常感谢!
浏览 7提问于2019-11-15得票数 1
我们正在使用spark来处理大型数据，并且最近获得了新的用例，我们需要使用spark更新Hive表中的数据。
下面是一个简单的例子:数据驻留在Hive表中，应用程序使用PySpark读取数据帧(比如PySpark)。例句:数据帧在列下面。
EmpNo名称年龄工资
1 aaaa 28 30000
2 bbbb 38 20000
3 cccc 26 25000
4dd 30 32000
需要添加更多的记录到表使用火花。
例如：
Action EmpNo名称年龄工资
加5 Add 30 32000
应用程序可以通过剥离Action列并附加到表中，将新数据读入第二个数据帧(例如df2)。它是笔直的，它
浏览 1提问于2019-03-29得票数 2
当我使用RegexTokenizer from pyspark.ml.feature来标记我的dataframe中的句子列以查找所有单词时，当python 包用于同一个句子时，我得到的结果正好相反。下面是示例代码：
from pyspark.sql import SparkSession
from pyspark.ml.feature import RegexTokenizer
spark = SparkSession.builder \
.master("local") \
.appName("Word list") \
浏览 3提问于2020-05-06得票数 1
回答已采纳
2回答
我有以下SAS代码：
data part1;
set current.part;
by DEVICE_ID part_flag_d
if first.DEVICE_ID or first.part_flag_d;
ITEM_NO = 0;
end;
else do;
ITEM_NO + 1;
end;
run;
我正在将它转换为PySpark，然后就卡住了。我有“part”DataFrame。我遇到的问题是试图转换以下代码行：
if first.DE
浏览 3提问于2019-11-05得票数 0
我需要帮助在pyspark数据帧主题。我有一个数据框架，比如1000+列和100000+ rows.Also，我有10000+ if elif条件，在每个if else条件下，只有很少的全局变量被一些值递增。现在我的问题是，我如何才能仅在pyspark中实现这一点。我读到了过滤器和where函数，它们根据条件返回行，我需要检查这些10000+ if else条件并执行一些操作。
任何帮助都将不胜感激。
如果你能给出一个小数据集的例子，那将会有很大的帮助。
谢谢你
浏览 0提问于2017-07-25得票数 0
1回答
如何使用吡火花API指定列名的？
举个例子，让我们假设我们
df = spark.range(10)
以下尝试失败：
>>> df.hint("rebalance", "id").explain()
...
pyspark.sql.utils.AnalysisException: REBALANCE Hint parameter should include columns, but id found
如果不按名称(即简单字符串)指定列，如何指定这些列？
使用别名的无论是>>> df.alias("df").h
浏览 15提问于2022-06-15得票数 0
回答已采纳
1回答
我的PipelinedRDD中有一列标称值，为了分类目的，我想将其转换为索引编码。
我曾经在pyspark.ml中使用pyspark.ml，这是非常容易使用的。然而，这一次我正在学习如何处理rdd而不是数据格式，而且在pyspark.mllib中没有这样的东西。
任何帮助都是非常感谢的。
浏览 0提问于2018-02-14得票数 1
回答已采纳
3回答
我有一个PySpark数据格式，我想根据某些列中的唯一值进行筛选。
from pyspark.sql import SparkSession
spark_session = SparkSession.builder.enableHiveSupport().getOrCreate()
columns = ["language","users_count","apple"]
data = [("Java", 1, 0.0), ("Scala", 4, -4.0), ("Java", 1, 0.0)]
浏览 15提问于2022-07-13得票数 1
1回答
在解析pyspark中不一致的数据类型时，我遇到了一个问题。如下面的示例文件所示，SA键总是包含一个字典，但有时它可以显示为string值。当我尝试获取列SA.SM.Name时，会得到如下所示的异常。
对于SA.SM.Name列，如何将null设置为除了JSONs之外的值的pyspark/hive。有人能帮帮我吗？
我试图转换成不同的数据类型，但是没有工作，或者我可能做错了什么。
输入文件内容: mypath
{"id":1，"SA":{"SM"：{"Name"："John"，"Email"：“Jo
浏览 6提问于2020-10-10得票数 0
1回答
当我使用UDF处理一列时，我不确定UDF处理是不是从这一列逐个处理元素？如果是的话，我不明白为甚麽会有问题。 import pyspark.sql.types as typ
from pyspark.sql.functions import udf,pandas_udf, PandasUDFType
def parse_model(v):
return v.split(' ')
Parse_model=pandas_udf(parse_model,typ.ArrayType(typ.StringType(),True))
sample_data_df.withColu
浏览 14提问于2019-05-20得票数 0
回答已采纳
我有一个PySpark Dataframe，它的StringType()列主要有15个字符。但是，有些行有11个字符。示例：
df =
+--------------+--------+
| code|state|
+--------------+--------+
|'334445532234553'|wa |
|'332452132234553'|mn |
|'45532234553' |fl |
|'679645532234553'|mo |
|'91853553223
浏览 1提问于2019-04-20得票数 3
1回答
我尝试从PySpark中的REST中提取不同的表。我跟踪了这个。我想要将不同的模式存储在一列中的中。下面是一个示例：
import pyspark.sql.functions as F
from pyspark.sql import Row
from pyspark.sql.types import *
A = [{"TableName": "Table1", "Schema": StructType([StructField("a", StringType()), StructField("b", Intege
浏览 16提问于2022-08-23得票数 0
回答已采纳
1回答
我想要创建火花数据框架的新列，其中包含已有列的四舍五入值。"em“列的类型为float。
我已经查过不同的帖子了，但搞不清楚。包括以下链接：
这是我的代码：
import pyspark.sql.functions as f
df = df.withColumn("rounded", f.round(f.col("em"), 3))
df.show()
新生成的列“四舍五入”与原始列"em“完全相同。我正在Cloudera集群上使用中的PyscemVersion2.3.0版本。
更新：
试过以下几点：
%pyspark
s2_em = s2.se
浏览 0提问于2019-07-09得票数 0
回答已采纳
我对pyspark完全是个新手。我在执行命令时遇到错误
from pyspark.sql import SparkSession
spark = SparkSession.builder.appName("basics").getOrCreate()
df = spark.read.csv("data.csv",inferSchema=True,header=True)
df.columns
我的数据有1,000,000行和50列。我得到了下面的错误。
ValueError Traceback (
浏览 0提问于2019-10-02得票数 0
1回答
我刚刚开始在非常大的csv文件上使用pyspark。我使用的是Spark版本2.1.0。我希望从一个.csv文件中读取数据，并将其加载到中，然后在过滤特定的行之后，使用matplotlib绘制2列(纬度和经度)，将其可视化。
这就是我到目前为止所做的：
进口包装：
from pyspark.sql import SparkSession
from pyspark.conf import SparkConf
from pyspark.sql.functions import *
import matplotlib.pyplot as plt
构建火花会话：
spark = SparkSessio
浏览 0提问于2017-06-28得票数 1
如何根据某些单元格之间的验证来更改列的值？我需要的是比较每个客户的(id)记录的千米值，以比较紧跟在千米值之后的记录是否更高。 fecha id estado id_cliente error_code kilometraje error_km
1/1/2019 1 A 1 10
2/1/2019 2 A ERROR 20
3/1/2019 1 D 1 ERROR
浏览 44提问于2019-07-04得票数 0
我正在对来自Teradata数据库的数据执行增量加载，并将其存储为一个拼花文件。因为Teradata中的表包含数十亿行，所以我希望我的PySpark脚本能够比较哈希值。
Teradata：
当前存储的Parquet文件：
我的PySpark脚本使用JDBC连接来调用teradata：
tdDF = return spark.read \
.format("jdbc") \
.option("driver", "com.teradata.jdbc.TeraDriver") \
.option("url", "jd
浏览 0提问于2019-01-16得票数 5
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
