reduceByKey에 대해 "오류 : 잘못된 표현식 시작이 잘못되었습니다"는 이유는 무엇입니까?

Question

저는 scala와 spark를 처음 사용하고 reduceByKey를 구현하는 동안 아래 오류가 발생했습니다.

var redRdd = filterRdd.reduceByKey((acc , val) => if (acc > val) acc else val) 
<console>:1: error: illegal start of simple expression 
var redRdd = filterRdd.reduceByKey((acc , val) => if (acc > val) acc else val) 

filterRdd는 (order_id, Amount) 튜플입니다.

scala> filterRdd.first 
res10: (Int, Double) = (1,299.98) 

우선 파티션 당 최대 값을 얻고 모든 파티션의 출력을 줄이려고합니다. 누군가이 오류가 발생하는 이유를 이해하는 데 도움을 줄 수 있습니까?

Answer 1

val은 스칼라의 키워드이며 val이라는 변수는 가질 수 없습니다. v가 작동 할 것으로 변경하십시오.

var redRdd = filterRdd.reduceByKey((acc , v) => if (acc > v) acc else v) 

작동합니다.

if else 대신 math.max(acc,v)을 사용할 수 있습니다.