저장소 배열에서 주어진 항목을 몇 개의 저장소가 포함하는지에 대한 목록을 만들려고합니다. stores 배열의 개별 객체에는 여러 속성 (이름, 위치 등)이 포함될 수 있지만 인벤토리 (실제 주식 번호가 아닌 항목 유형의 배열)를 선택하려고합니다. ['hammers', 'wrenches', 'screw drivers'), 각 항목이 포함 된 속성으로 개체를
내 문제는 기본적으로 List을 연결된 목록으로 축소하는 것으로 요약되지만 reduce 함수의 유추 된 유형은 올바르게 보이지 않습니다. 내 목록 내가 각에서이 작업을 수행하는 기능을 감소 예상이 [0, 1, 2]
모양을가 null // identity (a Node)
Node(0, null) // Node a = null, int
내가 스파크에서 간단한 MR 작업을하려고하고있다가, 여기에 코드입니다 reduceByKey (_ + _)의 결과가 초과 어떤 경우 :지도 단계에서 val testRDD = someRDD.map((_, 1)).reduceByKey(_+_)
, 값은 지능이다 , 감축 단계에서 값이 너무 커서 Int 범위를 초과하면 어떻게됩니까? 나는 이런 식으로 할 수있다
간단한 단어 카운트 유형을 수행하기 위해 스캘링을 사용하고 있습니다. 튜플을 확장하기 위해 부분 함수를 사용할 때 오류가 발생합니다. 정확한 오류 메시지는 다음과 같습니다. Error:(15, 14) missing parameter type for expanded function
The argument types of an anonymous functio
이봐, 내가 REPL에서이 작업을 실행하려고 경우이 값을 대신 반환 0 배 : (1 to 100).toList.reduce(_*_)
을 그리고 그것은 나를 0 나는이 문제를 이해하지 못했다 반환. Int가 오버플로 된 경우 음수 또는 양수가 반환되어야합니다. 그것은 저를 반환 (1 to 100).toList.fold(1)((a,b) => { printl
다음과 같은 RDD 항목을 포함하고 있습니다. 항목 유사성으로 그룹화하려는 항목이 있습니다 (동일한 집합의 항목은 유사하게 간주됩니다.) 유사성은 전이적이고 atleast가있는 집합의 모든 항목 하나 개의 공통 항목은 입력 RDD)과 유사한 것으로 간주됩니다 Set(w1, w2)
Set(w1, w2, w3, w4)
Set(w5, w2, w6)
Set(
나는 RDD (세션 ID, 세션 시작 시간, 세션 길이)를 가지고있다. 세션 ID로이 RDD를 줄이면서 대응 세션 시작 시간과 길이의 배열을 생성해야한다. 잘. 누군가가 스칼라로 코드를 작성하는 방법을 가르쳐 줄 수 있습니까? 그래서 내가 어떻게 할 수 RDD [(세션 ID, 서열 [(세션 시작 시간, 세션 길이)]) 에 RDD [(세션 ID, 세션 시작