aggregate

0热度

2回答

我有一个MongoDB的集合，一个文件如 - { "_id" : ObjectId("5a187babdbf0a03cdca0d0bc"), "aggregationDate" : "2017-10-31", "ipaddress" : "10.65.66.184", "first" : { "count" : 3 }, "s

1热度

1回答

熊猫数据框重新取样的ms值

熊猫菜鸟在这里。我有以下格式的文件： SET, 0, 0, 0, 6938987, 0, 4 SET, 1, 1, 6938997, 128, 0, 0 SET, 2, 4, 6938998, 145, 0, 2 SET, 0, 9, 6938998, 147, 0, 0 SET, 1, 11, 6938998, 149, 0, 0 .... SET, 1, 30, 6946103,

0热度

1回答

春数据MongoDB的应用程序设计和数据聚合

我开发一个小应用程序与spring data mongo和angularjs。这里是模型： public class Lease { @Id private String id; private long created; private Lessor lessor; private Lessee lessee; } p

0热度

2回答

转换值一列单行的Python

我有一个熊猫数据框，看起来像这样： Area1 Area2 1 2 1 4 1 5 1 9 2 8 2 16 2 4 2 1 3 8 3 9 我如何转换“区域2”列，使之成为每个“区域1的值的列表“列所以输出我希望是： Area1 Area2 1 2, 4,

0热度

1回答

写一个UDAF来执行火花数据帧的滚动回归是否有意义？

我会尽我所能描述我的情况，然后我希望本网站上的其他用户可以告诉我我正在服用的课程是否合理，或者是否需要重新评估我的方法/选项。背景：我用pyspark，因为我最熟悉Python VS斯卡拉，java或R.我有一个从蜂巢表使用pyspark.sql查询表构成的火花数据帧。在这个数据框中，我有许多不同的'文件'。每个文件都由时间序列数据组成。我需要对每个“文件”的整个时间值对数据的子集执行滚动回归

0热度

2回答

如何领域比较成聚合函数

对不起，我的英语.. 我需要如果它们匹配比较user'param（MonthYear/6characters）与外地TxtDtVts（含7个或8个字符的日期）， { "_id" : ObjectId("59e66bdda00472964e6a950b"), "Pharma" : "HEA00001", "TxtDtVts" : 2012016, // Or 2201

1热度

1回答

总枢轴在SQL Server

我试试这个 declare @t as table (yea int, rating varchar(100)) insert into @t values (2012, 'US'), (2013, 'S'), (2014, 'G'), (2015, 'E'), (2016, 'E') --select * from @T select [2012], [20

0热度

2回答

Scala Spark - 计算Dataframe列中特定字符串的出现

如何计算df列中使用Spark分区的字符串出现次数id？例如在列查找值"test"的df 在SQL "name"是： def getCount(df: DataFrame): DataFrame = { val dfCnt = df.agg( .withColumn("cnt_test", count(col("name")==lit('test')) )

-1热度

4回答

MongoDB的总查询的Int64

让说我的MongoDB的数据存储一些数据与诠释编号：850531015931 编号：860338053336 编号：859923992712 现在我想查询聚合与正则表达式那些数字以85开头，我如何做到这一点与聚合函数？

0热度

1回答

Pyspark - 基于RDD中的一个键的总和和聚合

我有下面的RDD。 [[1,101,001,100,product1], [2,102,001,105,product2], [3,103,002,101,product3]] 预期成果是在度假心情 [('001', ['product1','100'],['product2','105']),('002',['product3','101'])]