Resultados da pesquisa a pedido "scala"
Quais são as diferenças entre um futuro Scala e um futuro Java
Existem diferenças conceituais, funcionais ou mecânicas entre um futuro Scala e um futuro Java? Conceitualmente, não vejo diferenças, pois ambos pretendem fornecer um mecanismo para computação assíncrona.
Interpolação de cadeia, aspas de escape
Estou um pouco confuso com o quão difícil isso acaba sendo. Eu já olhei em torno do stackoverflow, mas nenhuma solução parece funcionar bem para mim. O que eu quero fazer: val file = checkcache(fileName) file match { case Some(_) => ...
Como usar o KafkaSource do Flink no Scala?
Estou tentando executar um programa de teste simples com o KafkaSource da Flink. Estou usando o seguinte: Flink 0.9Scala 2.10.4Kafka 0.8.2.1Segui os documentos para testar o KafkaSource (dependência adicionada, agrupe o conector Kafka ...
Como filtrar linhas com base no fato de um valor da coluna estar em um Conjunto de seqüências de caracteres em um Spark DataFrame
Existe uma maneira mais elegante de filtrar com base nos valores em um conjunto de cadeias? def myFilter(actions: Set[String], myDF: DataFrame): DataFrame = { val containsAction = udf((action: String) => { actions.contains(action) ...
Scala - Obtenha elementos de interface do usuário do FXML
Estou trabalhando em um projeto Scala / JavaFX com IntelliJ e um plugin para scala. A maneira típica em Java de acessar elementos do seu arquivo fxml é definir um ID para cada elemento que você deseja acessar e, em seguida, em sua ...
Como forçar o Spark a executar código?
Como forçar o Spark a executar uma chamada para mapear, mesmo que ele ache que não precisa ser executado devido à sua avaliação lenta? Eu tentei colocarcache() com a chamada do mapa, mas isso ainda não funciona. Meu método de mapa, na verdade, ...
Como configurar o diretório de cache do Ivy por usuário ou em todo o sistema?
estou usandoSBT [http://www.scala-sbt.org/]como minha ferramenta de construção para criar um projeto Scala. Meu problema é que não consigo configurar o SBT para baixar dependências para o diretório inicial do usuário. Portanto, estou procurando ...
SparkContext não serializável dentro de um objeto complementar
Atualmente, estou tentando estender um aplicativo Machine Learning que usa Scala e Spark. Estou usando a estrutura de um projeto anterior de Dieterich Lawson que encontrei no ...
Como converter DataFrame para Json?
Eu tenho um arquivo Json enorme, uma pequena parte dele da seguinte maneira: { "socialNews": [{ "adminTagIds": "", "fileIds": "", "departmentTagIds": "", ........ ........ "comments": [{ "commentId": "", "newsId": "", "entityId": "", .... .... ...
Explicação do método de dobra do spark RDD
Estou executando o Spark-1.4.0 pré-criado para o Hadoop-2.4 (no modo local) para calcular a soma dos quadrados de um DoubleRDD. Meu código Scala parece sc.parallelize(Array(2., 3.)).fold(0.0)((p, v) => p+v*v)E deu um ...