我在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) 我无法理解之间的区别
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)