我想为一个数据帧中的多个项目创建偶然表并运行chisq.test()等。 各种尝试都导致了“表中的错误(y$x，y$q2)：所有参数必须具有相同的长度”。我认为下面的例子集中在我的中心问题上，尽管最终我会编写一个更复杂的函数。我会对我的特定功能或整体方法的解决方案感兴趣。谢谢!
浏览 14提问于2020-09-16得票数 1
回答已采纳
1回答
我使用Spark窗口函数row_number()为具有嵌套结构的复杂DataFrame生成ID。然后，我提取DataFrame的一部分以创建多个表作为输出，其中包括这个键。但是，Spark只会在操作被触发时物化该表，所以当提取的表保存到HDFS中时，它最终会生成ID。因为我从单个DataFrame生成多个表，所以我需要ID列在所有表中保持一致，这
浏览 1提问于2017-11-21得票数 1
2回答
我正在创建一个火花作业，它要求使用用python编写的函数将列添加到dataframe中。其余的处理是使用Scala完成的。我已经找到了如何从pyspark调用Java/Scala函数的示例：
我发现用另一种方式发送数据的唯一例子是使用pipe。我是否可以将整个dataframe发送到python函数，让函数操作数据并添加其他列，然后将结果数据返回给调
浏览 3提问于2017-09-15得票数 5
1回答
用*args填充函数的输入参数
、、、、
如果我有一个支持变量参数号的函数，即使用*args，我如何从循环/列表理解中填充参数？假设函数需要多个列表作为参数，而我有一个表/dataframe，并且希望使用每个列作为输入参数，为什么这不起作用？funName([df[iCol].values for iCol in df.columns])funName(col1, col2, co
浏览 0提问于2016-04-26得票数 2
回答已采纳
3回答
嗨，我有下面的dataframe，它有countries列和多个其他列，并且有多个缺少的行。我想编写一个泛型函数(因为在多个地方使用)，它可以在with列中使用来创建一个新列。|
下面是我的代码，当我把countries列传递给函数时，无法用字符串计算列。如何从列中提取值并使用指定的字符串值进行计算，并希望以<
浏览 2提问于2020-07-16得票数 1
回答已采纳
我有两个表sales和purchase。我想创建一个触发器，通过从purchase表中减去sales表的售出数量，将最终数量存储在STOCK表中。有一个kikkat，名称n数量分别为10，15，这两个数量应该从采购数量表中减去，并保存在stock表中。
这是我的
浏览 7提问于2015-07-06得票数 0
我对SQL Server很陌生，我想问一个查询，假设我有一个函数，它返回四个值，比如。set @RetValue=@PendingFlag + @Status + @BTFound + @ValueDate和RETURN @RetValue.现在假设im从另一个函数调用这个函数，比如：请帮助我通过调用第一个函数，将返回的值分别存储在第二个函数中。
浏览 6提问于2014-01-03得票数 0
回答已采纳
1回答
在Postgres中，我有一个名为"mytable“的表，其中有两个列，id (bigint)和value (varchar(255))。我使用以下方法创建id列：Postgres将该列解释为“变化的字符”。我可以看到，在读取数据()时可以调用Postgres方法，但我不确定如何调用Postgres函数</e
浏览 0提问于2018-01-21得票数 2
回答已采纳
1回答
我有一个dataframe，它包含来自Hive的属性表和主表。我想删除列，然后应用掩蔽逻辑(SHA2)。将postgre中的属性配置读取为Spark/scala作业中的Dataframe。主蜂箱表输出应该是任何人，请帮助我用Spark/Scala编写代码。我无法转换ListString并将其
浏览 0提问于2021-03-26得票数 0
回答已采纳
我正在从hive表构建dataframe，在该表中，我需要基于dataframe中的多个列来转换列，因为我构建了udf并传递了kwargs，但是，由于顺序很重要，所以我怀疑kwargs的顺序是否会改变。因此，我决定使用List，但我正在探索如何从dataframe转换中将多个列作为列表传递。
浏览 2提问于2020-08-06得票数 0
回答已采纳
我正在尝试用python编写不同的表名，这些表名是根据groupby函数为两列创建的不同数据帧来编写的。list_dfs=[]for group,name in TT:writer= pd.ExcelWriter('output.xlsx')
def dt(_
浏览 31提问于2019-04-15得票数 0
1回答
因此，我有一个很好的想法，即创建一个函数，它可以根据列的值和给定的列数创建几个图(只是一个基本的直方图列，以查看数据是如何分布的)。我有点了解如何处理这个问题(对于循环，子图函数，根据图的数量改变地块的位置)，但是我不知道从哪里开始，当我试图这样做的时候，我冻结了。我假设告诉列的位置，我想要绘制的列的名称将是我的参数。
浏览 7提问于2022-02-23得票数 -1
回答已采纳
为了将Spark、SQL查询组合在一起，我需要调用Dataframe.registerTempTable函数来创建一个内存表来存储我的中间结果。然后，我可以对它执行其他SQL查询。如果我只是使用Dataframe，我可以使用DSL编写一个新的dataframe，然后在不显式创建临时表的情况下对该中间结果执行多个操作。
在这两种情况下，有可能有相同的表现吗？换句话说，临时表的创建是懒
浏览 1提问于2016-03-16得票数 1
回答已采纳
我有两个数据帧，每个数据帧都有一个公共列。我希望df2中基于df1列1中的值匹配的行被放入一个单独的数据帧中，并通过df2循环，直到在df1的col1中的每个条件都有新的数据帧为止。Dataframes
columns=['col 1', 'col 2'])
df2 = pd.Data
浏览 0提问于2020-09-17得票数 0
1回答
我一直在寻找使用函数调用dataset中列的正确方法。问题是，我有多个列，每个月的日期和时间都在一个单元格内。因此，我想编写一个函数来拆分它们，只需在函数中输入参数。因此，我不必每次都编写该代码，而只编写函数。我写下了列名和下面的函数。(DataFrame，SourceColumn：数据存储在列中的位置，TargetDate：日期需要去哪里，TargetTime：
浏览 2提问于2015-03-12得票数 1
1回答
在的基础上，如何将数据格式的所有列都写到一个卡夫卡主题中。目前我有一个带有一些列的dataframe，我应该用一个键将它写到kafka，因此我从旧的一个创建了一个新的dataframe，并指定了键和值： .option("kafka.bootstrap.servers", "test:8808")
.o
浏览 0提问于2019-08-13得票数 1
回答已采纳
要将多个变量传递给一个普通的python函数，您只需编写如下代码： do something....column_A'].map(a_function)# return date.year
我想知道的是，就像您可以将多个数据片段传递给单个函数一样(如上面的第一个示例所示)，您是否可以在创建新的pand
浏览 2提问于2015-05-22得票数 6
2回答
我正在尝试使用一个单元格值作为新列中字符串的切片。例如，如果我创建了这个表。This is a title -5data['Test'] = data.Name.str[:data.Number.item()]0 This is a title -5 This is a
当我有多行时，问题就会发生，所以如果我创建了下
浏览 14提问于2022-07-05得票数 1
回答已采纳
假设表中有2列我想要计算第三列的值，名为“总计”。在Server的transact-sql中，我可以简单地编写或者，我可以编写一个使用过的定义函数CalcTotal，然后编写如何在R中编写函数以将类似
浏览 5提问于2020-11-09得票数 0
回答已采纳
1回答
我已经编写了一个函数，在给出文件夹的方向后，将它中的所有excel文件合并到一个数据框架中，并进行一些适当的修改。不过，我有两件小事想补充一下，但我很难做到：
每个文件的名称中都有一个国家代码，我希望函数在数据框架" country“中创建一个额外的列，在该列中，每个观察都将被分配给这样的国家代码。BGR_CO2_May12Each名称示例：文件由多个工作表组成，每个工作表代表年份；这些工作表也被这些年调用
浏览 4提问于2019-10-24得票数 0
回答已采纳
云服务器
ICP备案
对象存储
实时音视频
云直播
腾讯云开发者
