scala

0열

1답변

scala에서 비어 있지 않은 Iterator를 반환 한 getLines를 사용하여 파일을 읽었습니다. 그런 다음 for 루프를 사용하여 줄을 인쇄했습니다. 그 후 다시 인쇄를 시도하면 빈 Iterator가 표시됩니다. 누군가 설명 할 수 있습니까? 당신이 Iterator 상태 변화를 가로 지르는 유지로하기 때문에 매우 Iterator의 예상되는 동작 sc

0열

1답변

은 새로운 열의 가치를 추가

I는 방송 변수로 배열을하고 정수 포함 broadcast_array.value Array(72159153, 72159163, 72159202, 72159203, 72159238, 72159398, 72159447, 72159448, 72159455, 72159492... I 데이터 집합의 열을을 (호출은 broadcast_array에있을 수 있습니다

2열

1답변

더 높은 종류의 Scalacheck 문제 : 유형에 대해 암시 적 확장이 다양 함

모나드 유형 클래스를 정의했으며 scalacheck로 법칙을 검증하려고합니다. 나는 다음과 같은 오류가 있습니다 class OptionMonadSpec extends MonadSpec[String, String, String, Option](Monad.optionMonad) abstract class MonadSpec[A, B, C, Box[_] : C

0열

1답변

Maxmind Geo 데이터가 포함 된 Spark UDF

Maxmind snowplow library을 사용하여 데이터 프레임에있는 각 IP의 지오 데이터를 추출하려고합니다. 우리는 스파크 SQL (스파크 버전 2.1.0)를 사용하고 난 다음 클래스에서 UDF를 생성 :이 class UdfDefinitions @Inject() extends Serializable with StrictLogging { spar

0열

1답변

스프레이 JSON은 어떻게 여기 <pre><code>case class Vegetable(name: String, color: String, seller:ISeller) </code></pre> <p>ISeller 자바 인터페이스 클래스</p> 다음 직렬화 할 수 스프레이 JSON을 사용하여

인터페이스의 형태를 직렬화. 나는 스프레이 - JSON을 처음 접했을 때 이것이 어떻게 직렬화되고 비 직렬화 될 수 있는지 모르겠습니다. 나는이 시도하지만 런타임 오류 implicit val VegetableFormat = jsonFormat3(Vegetable) 여기에 어떤 포인터가 잘됩니다 제공합니다.

0열

2답변

redis가 지원되는 스칼라 캐시

redis를 scalacache에 통합하려고합니다. 키는 일반적으로 문자열이지만 값은 객체 세트 [문자열] 등 캐시이 val cache: RedisCache = RedisCache(config.host, config.port) private implicit val scalaCache: ScalaCache[Array[Byte]] = ScalaCache(ca

0열

1답변

Spark RDD의 네이티브 스칼라 메서드를 사용하면 Spark 매직이 손실됩니까?

저는 Spark에 대한 연구를 위해 뛰어 들고 있습니다. Spark이 어떤 일을 처리하는 방법에 대한 질문이 있습니다. 키 -> 값 쌍 (CustomerID, TotalSpend)의 RDD가 있습니다. RDD에서 .sortBy를 사용하면 .sortBy가 Spark 메서드가 아닌 Scala 메서드이므로 Spark 마법을 놓치고 있습니까? 즉, Spark에서

1열

2답변

akka의 TestKit에서 스칼라를 사용하여 태그를 지정하는 방법은 무엇입니까?

특정 시나리오에서 특정 테스트를 실행하기 위해 태그를 지정하고 싶습니다. (예를 들어, slow 만 빌드하는 동안 실행, 아직 반면 개발해야한다고.) 스칼라에서 을 ScalaTest의 FlatSpec를 사용하여 나는 taggedAs 및 scalatest의 Tag을 사용할 수 있습니다 알고 있습니다. 그러나 액터 테스트에서 같은 것을 달성하는 방법을 모르겠습

2열

1답변

스파크 데이터 처리

분석 프로세스의 일부로 스파크와 스칼라를 사용하여 빅 데이터 세트를 처리하려고합니다. 샘플 입력 id, related_ids a, "b,e,f,i,j" b, "e,i,j,k,l" c, "f,i,j,m,n" d, "c,i,g,m,s" 예제 출력 A, "C, D" B "A, C ' C,"A, B " D" NULL " 데이터 프레임을 생성하는 것을 생

0열

1답변

SBT가 Avro 클래스를 생성하지 않음

새 프로젝트를 sbt로 만들고 있는데 avro 파일을 생성하는 데 어려움을 겪고 있습니다. $ cat ~/.sbt/0.13/plugins/plugins.sbt addSbtPlugin("org.ensime" % "sbt-ensime" % "2.0.1") addSbtPlugin("com.typesafe.sbteclipse" % "sbteclipse-plug