群聚合PySpark中的算术减法
群聚合（GroupBy）是一种在数据处理中常用的操作，它将数据集按照指定的键进行分组，并对每个组进行聚合计算。PySpark是Apache Spark的Python API，提供了强大的分布式数据处理能力。
算术减法是群聚合中的一种操作，它用于计算每个组中的数值型数据的差值。具体而言，对于每个组，算术减法将组内的数值进行减法运算，得到一个减法结果。
群聚合中的算术减法可以应用于各种场景，例如：
- 销售数据分析：可以使用算术减法计算每个地区的销售额差异，从而了解不同地区的销售情况。
- 用户行为分析：可以使用算术减法计算每个用户在不同时间段内的行为差异，例如购买金额的变化。
- 股票数据分析：可以使用算术减法计算每只股票在不同时间点的价格变化，从而进行趋势分析。
在PySpark中，可以使用groupBy()方法进行群聚合操作，并结合agg()方法进行算术减法计算。以下是一个示例代码：
from pyspark.sql import SparkSession
from pyspark.sql.functions import col
# 创建SparkSession
spark = SparkSession.builder.getOrCreate()
# 读取数据集
data = spark.read.csv("data.csv", header=True, inferSchema=True)
# 按照键进行分组，并计算每个组的算术减法结果
result = data.groupBy("key").agg(col("value1") - col("value2"))
# 显示结果
result.show()在腾讯云的产品中，可以使用腾讯云的云服务器（CVM）来运行PySpark程序。腾讯云还提供了弹性MapReduce（EMR）服务，可以方便地进行大规模数据处理和分析。您可以通过以下链接了解更多关于腾讯云的相关产品：
请注意，以上答案仅供参考，实际应用中可能需要根据具体情况进行调整和优化。
相关·内容
我有两个dataframes，我正在尝试编写一个函数来比较这两个dataframes，这样它将返回受影响的列的净更改。
DF1：
+---------------+------+------+-------+----------+
| City | Temp | Zone | Score | Activity |
+---------------+------+------+-------+----------+
| Atlanta | 10 | 1 | 100 | 400 |
+---------------+------+------+
浏览 3提问于2022-02-21得票数 1
回答已采纳
1回答
我有一个PySpark DataFrame，它有一个列作为一个热编码向量。我想在群后通过矢量加法来聚合不同的热编码向量。
例如df[userid,action] Row1: ["1234","[1,0,0]] Row2: ["1234", [0 1 0]]
我希望输出为row：["1234", [ 1 1 0]]，因此向量是由userid分组的所有向量的总和。
我怎样才能做到这一点？PySpark和聚合操作不支持向量加法。
浏览 4提问于2016-12-07得票数 12
我试图将用户定义的聚合函数应用于星火数据，以应用加性平滑，请参见下面的代码：
import findspark
findspark.init()
import pyspark as ps
from pyspark.sql import SQLContext
from pyspark.sql.functions import col, col, collect_list, concat_ws, udf
try:
sc
except NameError:
sc = ps.SparkContext()
sqlContext = SQLContext(sc)
df = sq
浏览 1提问于2018-01-29得票数 3
回答已采纳
1回答
为什么在星火中需要折叠行动？
、、、、
我有一个愚蠢的问题涉及到fold和PySpark中的减缩。我理解这两种方法之间的区别，但是，如果两者都需要应用函数是一个可交换的幺半群，我就无法找到一个fold cannot be substituted by约简的例子。
此外，在PySpark的fold实现中使用acc = op(obj, acc)，为什么使用这个操作顺序而不是acc = op(acc, obj)？(对于我来说，这第二个订单听起来更接近leftFold )
干杯
托马斯
浏览 3提问于2015-12-30得票数 5
请考虑这个猪脚本的例子。
我有一个小的数据集如下。被称为
student_details.txt
001、Rajiv、Reddy、21、9848022337、海得拉巴、89 002、siddarth、Battacharya、22 9848022338、Kolkata、78 003、Rajesh、Khanna、22 9848022339、德里、90004、Preethi、Agarwal、21,9848022330、Pune、93 005、Trupthi、Mohanthy、23 9848022336、布万瓦尔、75 006、Archana、Mishra、23 9848022335、Chennai
浏览 2提问于2016-03-14得票数 0
回答已采纳
我知道我们可以实现覆盖标准算术运算符的特征。我们也可以创建自己的特征来重载自定义操作符吗？我已经真正喜欢上了Haskell定义运算符的系统。
浏览 3提问于2013-05-25得票数 15
回答已采纳
2回答
是一种标准的数学结构，它描述可以添加和乘以的对象。C#和Java签名的long是否服从环的所有属性？例如，Long.MIN_VALUE的乘法总是相联的和分布的吗？假设我们处于未检查的上下文中。
(从维基百科复制的定义)
环是具有二进制运算+和·满足以下三组公理的集合R，称为环公理。
R是一个附加的阿贝尔群，这意味着
(a + b) +c=a+ (b + c)对于R (+是结合的)中的所有a，b，c。
A+b=b+a对于R中的所有a，b (+是可交换的)。
R中有一个元素0，使得对于R中的所有a，a+0=a (0是加性恒等式)。
对于R中的每个a，R中都存在−a，使得a+ (
浏览 0提问于2015-05-11得票数 4
回答已采纳
如果我谈到2'complement，MSB被用作符号位。例如，在8位2'complement signed符号中，01111111是+127，11111111是-128。但恰恰相反，11111111在unsigned notation中是255。处理器如何知道数字是signed还是unsigned？是否有其他位用于此目的？编译器做了些什么？
浏览 0提问于2016-07-20得票数 0
1回答
我试图从C++中的一个大双数中减去一个小的双数。这是我的密码
int main()
{
double a=166666166667000000.000000;
double b=1.0;
double c=4.0;
double d=10.0;
double ans_b=a-b;
double ans_c=a-c;
double ans_d=a-d;
printf("%f\n%f\n%f\n",ans_b,ans_c,ans_d);
return 0;
}
这个代码给了我以下输出-
166666166667000000.000000
166666166667000000.
浏览 4提问于2014-11-17得票数 1
回答已采纳
我试着把一些物体放在屏幕上的任意位置。
我使用arc4random()生成一个新的随机数。
但是这个函数似乎不能正常工作，下面是代码和跟踪结果：
Code :
UIView *stateView = [[UIView alloc] initWithFrame:CGRectMake( (arc4random()%700)-100 , (20 * 91) + 378 + ((arc4random()%600)+200), 325 , 188)];
NSLog(@"Note %d : X = %f , Y = %f",i,stateView.frame.origin.x,stat
浏览 0提问于2012-09-30得票数 0
回答已采纳
我使用DataBricks连接在远程群集上运行PySpark应用程序。当我试图检索一个列的最小值时，当另一个列有一个特定值时，我会遇到一个问题。运行以下代码行时：
feat_min = df.filter(df['target'] == 1).select(
F.min(F.col('feat')).alias('temp')).first().temp
我得到了这个错误：
Exception has occurred: Py4JJavaError
An error occurred while calling o5043
浏览 18提问于2021-11-26得票数 0
我对火星雨很陌生，我正在尝试把我的熊猫代码转换成火星雨。有一件事我有问题，那就是聚集我的群。
这是熊猫的代码：
df_trx_m = train1.groupby('CUSTOMER_NUMBER')['trx'].agg(['mean', 'var'])
我在AnalyticsVidhya上看到了这个例子，但我不知道如何将它应用于上面的代码：
train.groupby('Age').agg({'Purchase': 'mean'}).show()
Output:
+-----+-
浏览 0提问于2018-04-04得票数 3
回答已采纳
1回答
int main(int argc, char **argv)
{
unsigned char a = 10, b = 100;
std::cout<<sizeof(a-b)<<endl;
return 1;
}
输出：4
返回的数据类型是什么？
浏览 0提问于2011-05-08得票数 6
回答已采纳
因此，我有两个列EnrollmentStartDate和EligibilityStartDate，我需要得到两者之间的差异(注册- elibil)，然后获得客户端从合格日期开始活动所需的平均天数。
问题是其中一个表中的EnrollmentStartDate是datetime2格式的，而另一个表中的EligibilityStartDate是日期格式的。
我得到了以下错误
Msg 8117、级别16、状态1、第16行操作数类型datetime2对于减法运算符无效。
有办法把彼此转化成另一个吗？我该怎么做？
select clientid, avg(EnrollmentStartDate -
浏览 0提问于2019-06-14得票数 0
我有一个连续的表单，有两个字段，weight和rate。对于每条记录，我希望找到(weight/sum of all weight)*rate，然后将它们相加。我可以在页脚中放置一个TotalWeight控件，并且计算出的每条记录的控件显示正确。但是当我试图在另一个页脚控件中做最后的求和时，它给出了一个#错误，并且计算出的控件显示为#Type。我做错了什么？
浏览 2提问于2020-06-19得票数 0
当我和Lua一起在TIC-80上工作时，我一直在和//接线员一起工作。但是，我一直找不到关于它的任何文档。我通常看到的这个用例如下所示：
n = t%60//30*2
此函数的输入/输出表如下：
t|n
0 |0
15|0
30|2
45|2
60|0
75|0
etc...
这经常被用来在设定的速率下在精灵之间切换，我理解它产生了什么，我只是不明白它是如何产生的。
浏览 2提问于2018-03-29得票数 0
我在docs中看到聚合和注释函数可以用于在查询中创建一个新列，因此如果我编写如下内容：
my_object = ...objects.filter(something).annotate(extra_column=Avg(value))
内部查询将提供一个额外的列。
, AVG(value) AS "extra_column" ...
现在，在我看来，它似乎只能用于像计数，avg，max和min这样的函数.我能做一些简单的+/-某个数字吗？
我正在尝试.annotate(extra_column=another_column+1)或.annotate(extra_column=
浏览 0提问于2018-01-26得票数 0
回答已采纳
2回答
扩展Scala聚合中的表达式
、、、、
我正在尝试将一个简单的聚合代码从PySpark转换到Scala。
数据文件：
# PySpark
from pyspark.sql import functions as F
df = spark.createDataFrame(
[([10, 100],),
([20, 200],)],
['vals'])
// Scala
val df = Seq(
(Seq(10, 100)),
(Seq(20, 200)),
).toDF("vals")
聚合展开-在PySpark中确定：
df2 = df.agg(
*
浏览 9提问于2022-06-30得票数 2
回答已采纳
1回答
将重复值转换为两个不同的列
、、、、
我将以下数据导入到PySpark数据框架中：
from pyspark.sql import SparkSession
from pyspark.sql.functions import *
from pyspark.sql.types import *
spark = SparkSession.builder.master("local[4]").appName("pyspark").getOrCreate()
df = spark.read.csv("example.csv")
df.show()
#+--+------+
#|id|ans
浏览 10提问于2022-05-05得票数 1
回答已采纳
为什么在MapReduce中需要Reduce？如果一项任务(如计算书籍中的单词数量)在服务器群上由单个进程或MapReduced执行时会产生相同的结果，那么必须删除重复项的可能性有多大？我假设Reduce步骤，至少在本例中，将简单地将每个工作进程的结果相加，并提供书中的总字数。我不明白什么东西的复制品会出现在图片中。
浏览 0提问于2012-03-02得票数 1
回答已采纳
我已经部署了一个新的安装了Spark2.1的HDInsight 3.6集群。我之前使用过HDInsight 3.5集群和Spark1.6。
在这个新集群上，我无法从Spark UI访问executor日志。通常，在我之前的集群(3.5 / 1.6)中，我转到Executors选项卡，然后单击stderr获取来自单个执行器的标准输出日志。
什么配置可能导致此问题，或者是否有解决方法？如果有什么不同的话，我会提交一个pyspark应用程序。谢谢!
浏览 0提问于2017-11-29得票数 0
我使用以下命令在Spark2.3集群中运行一个PySpark作业。
spark-submit
--deploy-mode cluster
--master yarn
--files ETLConfig.json
PySpark_ETL_Job_v0.2.py
ETLConfig.json有一个传递给PySpark脚本的参数。我在主块中引用这个config json文件，如下所示：
configFilePath = os.path.join(SparkFiles.getRootDirectory(), 'ETLConfig.json')
with open(configF
浏览 0提问于2018-09-16得票数 2
回答已采纳
2回答
SELECT users.xp, users.clan, clans.name,
SUM(CASE WHEN users.clan = clans.name
THEN users.xp
END) AS total
FROM users, clans
WHERE users.clan = clans.name
为什么这个SQL查询在存在多个类群时只输出一条记录，而在这些类群中有几个使用xp的用户。它确实打印出它所显示的给定家族中xp的正确和，但我需要其余的部族。
浏览 6提问于2016-12-13得票数 1
回答已采纳
编辑：解决了问题，我认为问题在于Elmo推理生成的多维数组。我对所有向量进行平均，然后使用句子中所有单词的最后平均向量作为输出，它现在用于转换为数据帧。现在，我必须使它更快，将检查回使用线程。
尝试使用ElmoForManyLangs经过预先训练的模型，从github中为一个吡火花数据帧中的句子生成Elmo嵌入。但是，我无法将结果对象转换为dataframe。
import sys
from pyspark.sql.functions import split
import pandas as pd
import numpy as np
from pyspark.sql.functions
浏览 1提问于2019-09-30得票数 0
1回答
我正在阅读pyspark文档中的示例代码。
在一个示例代码中，它创建了如下所示的数据
df = spark.createDataFrame([('2015-04-08',)], ['dt'])
df.select(add_months(df.dt, 1).alias('next_month')).collect()
[Row(next_month=datetime.date(2015, 5, 8))]
我想知道为什么在“2015-04-08”之后必须有一个逗号，而只有一列。我觉得这可能与元组类型有关，但我想学得更多。
浏览 2提问于2019-09-25得票数 2
回答已采纳
1回答
环境: Spark 2.4.4 我正在尝试将以下代码从Scala Spark转换为PySpark： test.registerTempTable("test")
val df = sqlContext.sql("select cluster as _1, count(*) as _2 from test group by cluster, label order by cluster desc")
import org.apache.spark.sql.expressions.Window
val w = Window.partitionBy("
浏览 27提问于2019-12-29得票数 0
回答已采纳
我理解，当同时使用聚合函数和组中没有提到的单个列时，就会产生“非单个组函数”错误消息。然而，我仍然不能理解“单群群功能”这个神秘的词。这些词是如何表达它们的目的的？
浏览 0提问于2021-04-13得票数 0
回答已采纳
1回答
我想添加一个模式到我的游戏中，玩家需要完成游戏的时间是跟踪的。
我目前的解决方案是:我有四个变量(出于各种原因)来跟踪时间：
int timerMilliseconds_= 0;
int timerSeconds_ = 0;
int timerMinutes_ = 0;
int timerHours_ = 0;
每当我更新游戏时，我都会将timerMilliseconds_增加到当前的增量时间，并更新值。看起来是这样的：
timerMilliseconds_ += dt.asMilliseconds();
if (timerMilliseconds_ >= 1000) {
whi
浏览 2提问于2016-04-11得票数 0
回答已采纳
1回答
我在shell中导出了两个变量var1和var2。
var1=root
var2=webserver
我想要一个jq查询，它可以用JSON文件中的给定值替换JSON键。像这样的东西，
jq -r --arg var1 $var1 --arg var2 $var2 '(.[].appId=$var1-$var2)' service.json
它给出的错误是var1和var2不能相减。但我希望将该变量替换为字符串形式的$var1-$var2。
我尝试使用"-"，但它给出了编译错误。
下面是service.json的内容。
[ {
"appId&
浏览 23提问于2018-03-01得票数 1
回答已采纳
我有下一个代码 打印以下代码 为什么？据我所知，操作add.cc.u32 r1，0，0必须将进位标志设置为0。我的印象是subc.u32操作使用与CC.CF相反的操作。但从文档来看，它不应该是这样的。
浏览 35提问于2021-02-28得票数 0
回答已采纳
2回答
在groupBy.agg()中创建字典是可能的吗？下面是一个玩具示例：
import pyspark
from pyspark.sql import Row
import pyspark.sql.functions as F
sc = pyspark.SparkContext()
spark = pyspark.sql.SparkSession(sc)
toy_data = spark.createDataFrame([
Row(id=1, key='a', value="123"),
Row(id=1, key='b', v
浏览 0提问于2019-03-22得票数 6
1回答
我们真的需要1s补足吗？
、、、、
为什么我们真的需要赞扬？
我们可以简单地把一个数字变成负数或正数，只要翻转一点就可以了！味精吗？为什么我们要翻转所有的位
浏览 5提问于2022-06-03得票数 0
9回答
我必须使用WinForms在VS2008 .net 3.5中执行以下代码：
byte percent = 70;
byte zero = 0;
Bitmap copy = (Bitmap)image1.Clone();
...
Color oColor = copy.GetPixel(x, y);
byte oR = (byte)(oColor.R - percent < zero ? zero : oColor.R - percent);
当我把"(byte)“从最后一行代码中去掉时，我得到一个编译器错误，说它”无法隐式地将类型'int‘转换为’byte‘“。如果所
浏览 81提问于2009-05-29得票数 16
回答已采纳
给定以下包含两个数组的json：
{"zones":["dev01","dev02","dev03","dev04","dev05","dev06","dev07","dev08","dev09","dev10","dev11","dev12","dev13","dev14","dev15","dev16","dev1
浏览 5提问于2017-07-01得票数 0
回答已采纳
2回答
我查找了任何类似于熊猫df.groupby(upc)['store'].unique()的火花放电的参考资料，其中df是熊猫中的任何数据。
请使用这段代码在Pyspark中创建数据帧。
from pyspark.sql.types import StructType,StructField, StringType, IntegerType
from pyspark.sql import *
from datetime import date
import pyspark.sql.functions as F
spark = SparkSession.builder.appNa
浏览 5提问于2021-12-13得票数 0
回答已采纳
如何在databricks中编写pyspark/python代码以删除在azure存储帐户中超过X天的文件。
浏览 5提问于2022-04-21得票数 0
在pyspark程序中，我阅读了下面这行代码。这行代码到底想要达到什么目的？在pyspark中，sqlmax和max有什么不同？ df.groupBy('groupId').agg(sqlmax('Time').alias('MaxTime')).withColumnRenamed('groupid1','groupid2')
浏览 9提问于2021-04-05得票数 0
回答已采纳
我有三张桌子：
ITEMS
+----+--------------------------+----------+
| id | nome | quantity |
+----+--------------------------+----------+
| 1 | Pantaloni beige | 10 |
| 2 | Camicia cotone e seta | 1 |
| 3 | Camicia da notte | 5 |
| 4 | Completo
浏览 3提问于2016-10-17得票数 0
回答已采纳
1回答
所以，在过去的几个月里，我一直在努力学习计算机，并真正详细地了解它们是如何工作的。我最近在学习减法器，我想知道..
首先，据我所知，减法器使用两个人的恭维来得到结果。但是，为什么它要减去呢？例如，两个人的5 (0101)的恭维是1011。但是，这也是一个正11。即使这个数字被取反了，是什么让减法器把它当作一个负数而不是另一个正数呢？如果问题是8- 5，是什么阻止它做8 +11？是什么让它识别有符号位和无符号位？我听过程序运行时的决定，但接下来的问题是，是什么赋予了程序决定加或减的能力，以及如何解释给CPU和AlU。
此外，我还了解到AlU使用一个在加法和减法之间切换的电路。这个电路是怎么工作的
浏览 4提问于2013-07-24得票数 0
在scala中，当我有一个类似于：List(("a",1),("a",2),("b",3),("b",4),("b",5),("a",6))的RDD列表时，我想要计算每个字符的avg数。
与a一样，它以1+2+6 = 9的值显示了3次，因此我希望得到的结果是(a, 3)。
在Scala中，我可以编写如下代码：
val newRdd = rdd.aggregateByKey((0,0))((t,v) => {(t._1 + v, t._2 + 1)}, (t1, t2) => {(t1._
浏览 5提问于2021-12-24得票数 0
回答已采纳
我在Matlab中创建了一个来自matlab.mixin.Heterogeneous类的异构对象数组。我的数组现在包含超类Cells的对象和子类，如Neuron、Astrocyte等。我要分配给子类的方法应该根据不同的刺激来模拟它们的行为。为了计算行为，我需要对象来执行数学操作。但是，当我在类的方法中定义一个使用运算符的函数时，Matlab告诉我，例如：
未定义的运算符'-‘类型的输入参数’单元格‘。
然后，我尝试用多个继承( Cells < matlab.mixin.Heterogeneous & double )构造我的超类，但随后出现了这个错误：
使用单元
浏览 1提问于2017-04-06得票数 0
回答已采纳
4回答
假设A和B是有符号正整数，那么对于A-B，它是使用A+2的B补码来计算的。
例如，在4位二进制系统中，对于有符号整数，我们有7-3=0111-0011=0111+1101=(1)0100，括号中的1是进位位。根据带符号整数的溢出规则，我们知道没有溢出，因此结果是正确的。
但是，对于无符号整数，如果我们计算7-3会发生什么？如果我们使用上面提到的相同方式：
7-3=0111-0011=0111+1101=(1)0100
然后，根据无符号整数的溢出规则，由于进位而存在溢出。换句话说，0100是错误的，因为存在溢出。但实际上，我们知道结果0100是正确的。
如果我的分析是正确的，那么使用加法器来执行
浏览 1提问于2011-11-08得票数 5
回答已采纳
1回答
我不确定在执行聚合操作时是否应该增加或减少分区的数量。假设我使用的是火花放电数据格式。pyspark 1.6.1。
我知道，典型的行转换需要更多的分区。将数据保存到磁盘通常需要fewere分区。
但是，对于聚合来说，我不清楚在pyspark中应该做什么？？
增加分区数量的论据:由于为了聚合，我们必须对数据进行洗牌，所以您需要对周围的数据进行洗牌，从而增加分区的数量，以减小分区的大小。
减少分区数量的参数:在每个分区上收集和计算需要大量的开销。因此，过多的分区将导致过多的开销，而pyspark作业可能会超时。
是哪一个？
资料来源：
浏览 1提问于2017-08-10得票数 1
回答已采纳
1回答
我正在研究 stuck 方法，并坚持了如何实现以下结果。
星星之火sql (这很有效)
q = """
select breed,
avg(weight) as avg_wt,
avg(weight) filter (where age > 1) avg_wt_age_gt1
from cats
group by breed
order by breed
"""
spark.sql(q).show()
问:如何使用方法获得相同的结果？
我的尝试
(sdf.groupBy("breed").
浏览 2提问于2020-07-23得票数 0
回答已采纳
我正在将坐标转换成另一种格式，但是出现了一个错误
longitude = (lon - 4294967295) / 6356752.3142 * (180/math.pi)
unsupported operand type(s) for -: 'list' and 'int'
我将非常感谢你的建议
浏览 8提问于2022-01-28得票数 0
回答已采纳
1回答
我在Python中有一个函数，我想适应PySpark。我对PySpark还很陌生，所以找到一种方法来实现它--无论是使用自定义框架还是在PySpark中实现--都是一个挑战。
本质上，它对按数据帧分组的数据执行一系列numpy计算。我不完全确定在PySpark中做这件事的最好方法
Python代码：
data = [
[1, "a", 10, 23, 33],
[1, "b", 11, 25, 34],
[1, "c", 12, 35, 35],
[1, "d", 13, 40, 36],
浏览 1提问于2021-03-13得票数 0
如果我想在二进制中使用-3，我可以使用有符号位，或者1补码，或者2的补码，对吗？
然而，什么时候使用方法是合适的呢？为什么？
让我们只使用8位：
带签名的-3只是10000011
带有ones的-3就是11111100
带有twos的-3就是11111101
浏览 1提问于2011-04-06得票数 0
回答已采纳
我编写了一些代码来检查类型是否具有模块化表示：
#include <iostream>
#include <limits>
using namespace std;
int main( )
{
cout << "Whether float objects have a modulo representation: "
<< numeric_limits<float>::is_modulo << endl;
cout << "Whether doubl
浏览 2提问于2015-08-26得票数 4
回答已采纳
我想把下面的熊猫代码翻译成PySpark代码
pd_df.groupby(['colA']).agg(newCol1 = ('colB', 'count'),
newCol2 = ('colC', 'mean'))
newCol3 = ('colD', 'any')).reset_index()
等效的PySpark代码将是
import pyspark.sql.funct
浏览 5提问于2019-11-25得票数 0
回答已采纳
我有一个HDP 2.5集群，我正在使用ZEPPELIN的%pyspark解释器来生成代码。
我想使用一个库来帮助在python、java和scala中使用Spark中的时间序列分析，这里指定了：
问题是我不知道如何导入和使用这个库到我的ZEPPELIN %pyspark解释器中。
首先，我下载了名为“.jar -0.2.0-jar-with-Dependencies.jar”的jar文件。接下来，我将它保存在ZEPPELIN正在工作的集群节点的/opt/目录中。
然后，我尝试使用%dep，但它在我当前版本的HDP中被弃用，所以我在ZEPPELIN的“解释器”菜单中添加了一个依赖项，如下所示：
浏览 1提问于2016-11-30得票数 4
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
