Resultados da pesquisa a pedido "scala"
Método de fábrica Scala com genéricos
Eu tenho alguns objetos para os quais estou tentando escrever um método de fábrica. Simplificado, são eles: case class a[a1,a2](j:a1, k:a2) {} case class b[b1,b2](j:b1, k:b2) {}Gostaria de criar um método que me permitisse passar o tipo e obter ...
Caminho canônico para Array vazio em Scala?
Qual é a maneira canônica de obter uma matriz vazia no Scala?new Array[String](0) é muito detalhado.
Como o @Inject in Scala funciona
Gostaria de saber como funciona a anotação @Inject no Play-Scala. Obviamente, ele injeta uma dependência, mas estou curioso para saber como está funcionando. Quando eu estava usando ele no controlador de extensão de classe e defini o gerador de ...
Como fazer a inicialização do banco de dados ao usar o DI no Play 2.4?
O Play 2.4 desencoraja o usoGlobalSettings.onStart e inteiroGlobal objeto [https://www.playframework.com/documentation/2.4.x/GlobalSettings]. Eu estou usando play-slick e temexcelente amostra de DI no ...
Do DataFrame para o RDD [LabeledPoint]
Estou tentando implementar um classificador de documentos usando o Apache Spark MLlib e estou tendo alguns problemas para representar os dados. Meu código é o seguinte: import org.apache.spark.sql.{Row, SQLContext} ...
Qual é o conceito de "fraca conformidade" no Scala?
Eu encontrei recentemente o termo "Conformidade fraca" (no usuário Stack Overflowretrônimo [https://stackoverflow.com/users/160378/retronym]resposta de Como configurar a conversão implícita para permitir aritmética entre ...
Qual é a maneira mais rápida de somar uma coleção no Scala
Eu tentei coleções diferentes no Scala para somar seus elementos e eles são muito mais lentos do que Java soma suas matrizes (comfor ciclo). Existe uma maneira de o Scala ser tão rápido quanto as matrizes Java? Ouvi dizer que no scala 2.8 os ...
Spark Streaming em um diretório S3
Portanto, tenho milhares de eventos sendo transmitidos pelo Amazon Kinesis para o SQS e depois despejados em um diretório S3. A cada 10 minutos, um novo arquivo de texto é criado para despejar os dados do Kinesis no S3. Gostaria de configurar o ...
palavra-chave de bloqueio no Scala
Qual é a diferença entreFuture(blocking(blockingCall())) eblocking(Future(blockingCall()))? Ambos são definidos emscala.concurrent._ Eu olheino scala docs [http://docs.scala-lang.org/overviews/core/futures.html#blocking]e alguma outra respostas ...
mesclar vários arquivos pequenos em poucos arquivos maiores no Spark
Eu estou usando a colméia através do Spark. Eu tenho uma inserção na consulta de tabela particionada no meu código spark. Os dados de entrada estão em 200 + gb. Quando o Spark está gravando em uma tabela particionada, está cuspindo arquivos muito ...