나는 두 개의 rdd를 가지고있다. 첫 번째는 x 좌표 (한 열)를 가지고 두 번째는 y 좌표 (한 열)를가집니다. 결과를 하나의 rdd (x, y) 형식의 한 열로 나타내 려합니다. 어떤 해결책이 있습니까? 예를 들어 : 제 RDD을 갖는다 : 제 1,2,3 RDD을 갖는다 : 4,5,6 결과, (1,4), (2,5), (3,6) 사전에 덕분에
저는 스칼라를 처음 접했고 외부 소스에 의해 문자열로 된 열거 형에서 가져온 올바른 대소 문자 클래스 (형질)를 만드는 "scala"방법을 찾고 있습니다. 소스가 외부에 있기 때문에 입력이 올 바르고 올바른 입력이 주어진 경우 올바른 대소 문자 클래스를 돌려 줄 수 있는지 확인해야합니다. 나는이 지정된 특성의 선택 사양 인 경우 클래스를 반환하는 "공장"으
저는 Bitcoin 블록 체인을 가지고 스칼라와 유용한 라이브러리를 배우려고합니다. 현재 디코딩하고 SCodec으로 블록을 인코딩하려고하는데 내 문제는 vectorOfN 함수가 크기를 Int로 사용한다는 것입니다. 크기 필드에 긴 필드를 사용하는 방법은 무엇입니까 전체 값을 그대로 유지하는 . 즉, vectorOfLongN 함수가 있습니까? object B
내 사용자 정의 프로파일을 매끄럽게 사용하려고 시도하면 예외가 발생합니다. 이유는 내가 그것을 사용하려는 이유는 JSON을 내 postgresql 데이터베이스에 보관하기 때문입니다. 따라서 pg-slick을 사용하고 있습니다. 예외 설명 : slick.jdbc.PostgresProfile $을 (를) util.ExtendedPostgresProfile에 캐
현재 11,000 개의 파일을 작업 중입니다. 각 파일은 이전 프레임과 통합 될 데이터 프레임을 생성합니다. 아래 코드는 다음과 같습니다. var df1 = sc.parallelize(Array(("temp",100))).toDF("key","value").withColumn("Filename", lit("Temp"))
files.foreach(file
저는 Slick에 처음 왔고, 저를 일으키는 몇 가지 문제로 어려움을 겪고 있습니다. 내 데이터베이스에 내 이메일 주소로 사용자를 저장했습니다. 그러나이 메서드를 실행할 때 (DAO에서 구현 됨) : def getByEmail(email: String): Future[Option[User]] = {
println(s":${email}:")
def Perm_Function(xs: List[(Int,Int)], Dimensions: Int): Double = {
var sum=0.0
for(i <- 1 to Dimensions)
{
sum=sum+(Perm_help(xs,i))
}
} 필요 내가 위의 코드를 작성하지만이 오류를주고있다 : 발견 필요한 단위
kafka의 데이터를 null 형식의 형식으로 수신합니다. null,val1,val2,val3,val4,val5,val6,val7,...val23
null,val1,val2,val3,val4,val5,val6,val7,...val23
null,val1,val2,val3,val4,val5,val6,val7,...val23
이제 다음 코드를 사용하여 n