小编Kon*_*ewa的帖子

如何计算pyspark中每行的某些列的最大值

我在pyspark中使用sqlContext.sql函数读取数据帧.这包含4个数字列,每个客户端包含信息(这是密钥ID).我需要计算每个客户端的最大值并将此值连接到数据框:

+--------+-------+-------+-------+-------+
|ClientId|m_ant21|m_ant22|m_ant23|m_ant24|
+--------+-------+-------+-------+-------+
|       0|   null|   null|   null|   null|
|       1|   null|   null|   null|   null|
|       2|   null|   null|   null|   null|
|       3|   null|   null|   null|   null|
|       4|   null|   null|   null|   null|
|       5|   null|   null|   null|   null|
|       6|     23|     13|     17|      8|
|       7|   null|   null|   null|   null|
|       8|   null|   null|   null|   null|
|       9|   null|   null|   null|   null|
|      10|     34|      2|      4|      0|
|      11|      0|      0|      0|      0|
|      12|      0|      0| …
Run Code Online (Sandbox Code Playgroud)

python pyspark

5
推荐指数
2
解决办法
2656
查看次数

java 8 可选列表收集以列出编译错误

我无法理解之间的区别

Stream<Optional<Integer>> optionalStream = Stream.of(
                Optional.of(1),
                Optional.empty(),
                Optional.of(5));

List<Optional<Integer>> optionalList = optionalStream.collect(Collectors.toList());
Run Code Online (Sandbox Code Playgroud)

效果很好并且:

List<Optional<Integer>> optionalList1 = Stream.of(
                Optional.of(1),
                Optional.empty(),
                Optional.of(5)).collect(Collectors.toList());
Run Code Online (Sandbox Code Playgroud)

我在哪里收到错误

Error:(138, 40) java: incompatible types: inference variable T has incompatible bounds
    equality constraints: java.util.Optional<java.lang.Integer>
    lower bounds: java.util.Optional<? extends java.lang.Object>
Run Code Online (Sandbox Code Playgroud)

java java-8

4
推荐指数
2
解决办法
2204
查看次数

标签 统计

java ×1

java-8 ×1

pyspark ×1

python ×1