spark scala中的配分函数
DF:
ID col1 . .....coln.... Date
1 1991-01-11 11:03:46.0
1 1991-01-11 11:03:46.0
1 1991-02-22 12:05:58.0
1 1991-02-22 12:05:58.0
1 1991-02-22 12:05:58.0
我正在创建一个新的列“identify”，以查找（ID、日期）的分区，并通过“identify”选择排序最靠前的组合
预期DF：
ID col1 . .....coln.... Date . identify
1 1991-01-11 11:03:46.0 . 1
1 1991-01-11 11:03:46.0 1
1 1991-02-22 12:05:58.0 . 2
1 1991-02-22 12:05:58.0 . 2
1 1991-02-22 12:05:58.0 . 2
代码1：
var window = Window.partitionBy("ID").orderBy("DATE")
df = df.orderBy($"DATE").withColumn("identify", row_number().over(window))
我的作品：
ID col1 . .....coln.... Date . identify
1 1991-01-11 11:03:46.0 . 1
1 1991-01-11 11:03:46.0 2
1 1991-02-22 12:05:58.0 . 3
1 1991-02-22 12:05:58.0 . 4
1 1991-02-22 12:05:58.0 . 5
代码尝试2：
var window = Window.partitionBy("ID","DATE").orderBy("DATE")
df = df.orderBy($"DATE").withColumn("identify", row_number().over(window))
我的作品：
ID col1 . .....coln.... Date . identify
1 1991-01-11 11:03:46.0 . 1
1 1991-01-11 11:03:46.0 2
1 1991-02-22 12:05:58.0 . 1
1 1991-02-22 12:05:58.0 . 2
1 1991-02-22 12:05:58.0 . 3
关于如何调整代码以获得所需OP的任何建议都将是有帮助的
共有1个答案
var window = Window.partitionBy("ID").orderBy("DATE")
df = df.orderBy($"DATE").withColumn("identify", dense_rank().over(window))
-
对于下面的代码：（1）“main”调用函数“f1”。（2）函数“f1”进行一些数字运算；使用malloc创建一个“char”数组，然后将数组的指针返回到main（无需取消分配-free-数组）。 我有3个与此案例相关的问题：（1）我假设，虽然函数“f1”已经终止，但分配的char数组仍然保持分配状态，直到主程序完全终止。也就是说，分配的内存仍然属于main，没有其他进程可以从外部访问（我的意思是干
-
4. 分配内存的函数 除了malloc之外，C标准库还提供了另外两个在堆空间分配内存的函数，它们分配的内存同样由free释放。 #include <stdlib.h> void *calloc(size_t nmemb, size_t size); void *realloc(void *ptr, size_t size); 返回值：成功返回所分配内存空间的首地址，出错返回NULL calloc
-
问题内容： 假设我有一个功能 现在，我想将函数分配给一个名为的变量，这样，如果我使用，它将再次调用该函数。如果我只是做作业，它就会返回。 问题答案： 您根本不调用该函数。 括号告诉蟒蛇，你调用的函数，所以当你把它们放在那里，它调用的功能，并指定值 返回 的（在这种情况下）。
-
我正在尝试运行下面的程序，在该程序中，我使用一个名为Reserve的函数动态地为变量分配内存。当我运行应用程序时，由于在一个单独的函数中为一个空指针分配内存，我会得到分段错误，但是如果我想在主函数中分配内存，我不会得到这个错误。那我做错了什么？ 代码如下：
-
这是来自3.7.4.2的N3797: 全局操作符delete[]只有两个参数，第二个参数的类型是std::size_t，这是一个常见的解除分配函数。37 37）此解除分配函数排除使用分配函数空运算符new（std::size_t，std::size_t）作为位置分配函数 这个说明对我来说不清楚。我想看看这种排除的真正例子。编译器将引发警告，或者我们遇到运行时错误？我一直在尝试编写如下内容： 我不知
-
我有一个func添加两个NO并返回(a+B)。然后我创建了一个指向func的func指针。希望为该函数指针的数组分配内存并访问它们。代码如下。 我的问题是使用malloc的下面一行： 编译时，sizeof(add_2nos*)和sizeof(add_2nos)没有任何区别。如果有什么区别？？另外，如果类型转换是必要的，而我正在分配相同类型的内存…？