scala

0열

1답변

ScalaCheck forAll을 사용하여 케이스 클래스의 매개 변수 하나를 설정하고 나머지를 임의로 생성하도록하려면 어떻게해야합니까?

그래서 로컬 캐시 구현을 위해 ScalaTest/ScalaCheck를 사용하여 Scala UnitTest를 만들고 있는데, 이미 본 ID로 이벤트가 들어 오면 완전히 새로운 값을 생성하는 대신 해당 값을 업데이트하는 기능을 테스트해야합니다. 캐시의 항목. 이제 루프의 반복마다 동일한 ID가 생성되도록하는 방법을 확실히 알았습니다. 아래 코드를 참조하십시오.

0열

1답변

Spark 2에서 CastClassException을 얻는 중 : java.lang.ClassCastException : java.util.ArrayList를 org.apache.hadoop.io.Text로 캐스팅 할 수 없습니다.

Array 및 Array와 같은 복잡한 데이터 유형 열이있는 테이블을 처리 할 때 Spark 2에서 CastClassException을 가져 오는 중입니다. 내가 시도 작업은 간단 하나입니다 계산 df=spark.sql("select * from <tablename>") df.count 하지만 스파크 응용 프로그램 Exception in thread

1열

1답변

스칼라 및 코 틀린에 대한 수동 JAR 컴파일

스콧 코드를 호출하는 Kotlin 개념 증명을 만들려고합니다. 두 언어를 컴파일하려면 다음 kotlin-src/ hello.kt scala-src/ Hello.scala : 여기 프로젝트는 순간의 모습이다 META-INF/ main.kotlin_module HelloKt.class HelloScala.class : 루

0열

1답변

어떻게 완전히

이었다 0.00 % (Akka-HTTP microservices) 내 보고서는 내가 내 코드 커버리지 보고서를 100 % 실행할 수있는 [info] Statement coverage.: 0.00% [info] Branch coverage....: 0.00% [info] Coverage reports completed [info] All done. Co

1열

1답변

Json은 scala/play로 구문 분석 : 특성을 얻는 방법?

play2를 사용하여 스칼라에서 Json을 읽으려고 할 때 정보가 객체를 만드는 데 사용되면 막혔습니다. 이 내 코드는 바로 지금입니다 : trait MyTrait { } object object1 extends MyTrait { override def toString: String = "object1" }

2열

1답변

스파크를 끔찍하게 수정하여 CSV를 잘못 해석하는 방법은 무엇입니까?

두 개의 csv 파일이 있습니다. 하나는 영화 용 키워드이고 다른 하나는 캐스트와 크롤을 포함합니다. keywords.csv 파일은 다음과 같습니다 : $ head -n 3 keywords.csv id,keywords 862,"[{'id': 931, 'name': 'jealousy'}, {'id': 4290, 'name': 'toy'}, {'id': 5

0열

2답변

문자열에서 클래스 형식을 스칼라로 매핑하기

json4s (scala)를 통해 다른 내부 사례 클래스를 구문 분석하려는 많은 외부 JSON 엔터티가 있습니다. json4s의 추출 함수를 통해 모든 것이 잘 작동합니다. 나는 타입과 json 문자열을 취하고 타입/케이스 클래스에 문자열을 파싱하는 parse 함수를 구현했다. 내가 여기에 반복을 좋아하지 않아이 entityName match { case

1열

1답변

컨테이너 대수 데이터 유형 스칼라

스칼라 유형 시스템에는 익숙하지 않지만 여기에 내가하려고하는 것이있다. 나는 사람을 이름으로 필터링하려고하는 함수가 있는데, 이름이 필터 인 경우에만 실패합니다. case class Person(id: Int, first: String, last:String) def(people: Set[Person], firstName: String, lastName:

2열

1답변

카레는 특성 동반자 개체에

두 질문에 적용 1) 왜 나는 apply 기능은 카레 때 BaseTrait 동반자 개체에서이 두 apply 방법이없는 (주, 그것은 그들이 않은 카레 때 작동입니다 , 두 가지 주장이있다)? 2)이 기능을 구현하려면 어떻게해야합니까? 여러 가지 적용되는 방법이 있습니다. trait BaseTrait[T, U] { def name: String

1열

2답변

멀티 스레드 드라이버에서 Apache Spark SQL 작업 시작하기

Spark로 약 1500 개의 원격 Oracle 테이블에서 데이터를 가져오고 싶었습니다. 스레드 당 테이블을 선택할 수있는 멀티 스레드 응용 프로그램을 원합니다. 쓰레드를 시작하고 각각의 테이블에서 읽을 스파크 작업을 시작합니다. 그 불꽃이 실행 공식 스파크 사이트 https://spark.apache.org/docs/latest/job-scheduling