Resultados da pesquisa a pedido "scala"
Precedência do operador no Scala
Eu gosto da proposta de Scala de precedência de operador, mas em alguns casos raros, regras não modificadas podem ser inconvenientes, porque você tem restrições ao nomear seus métodos. Existem maneiras de definir outras regras para uma classe / ...
Por que o exemplo não é compilado, também conhecido como (co-, contra- e in) variação?
Seguindo emessa questão [https://stackoverflow.com/questions/663032/generic-wildcards-in-variable-declarations-in-scala] , alguém pode explicar o seguinte em Scala: class Slot[+T] (var some: T) { // DOES NOT COMPILE // "COVARIANT parameter ...
Apache-Spark: Para que serve o mapa (_._ 2)?
Eu li o código fonte de um projeto, encontrei: val sampleMBR = inputMBR.map(_._2).sampleinputMBR é uma tupla. a funçãomapA definição de é: map[U classTag](f:T=>U):RDD[U]parece quemap(_._2) é a abreviação demap(x => (x._2)). Alguém pode me ...
Como testo um ator da Akka que envia uma mensagem para outro ator?
Estou usando o ScalaTest com o Akka TestKit para escrever testes de unidade e integração para um ator que eu codifiquei para simplesmente enviar uma mensagem para outro ator sem alterar nenhum estado interno. Veja isso por exemplo: class MyActor ...
Como pré-preencher um menu suspenso usando o modelo scala e a estrutura de reprodução
Estou usando o modelo scala e a estrutura do Play 2.0 para o meu projeto. Digamos que eu tenha um formulário de usuário com campos como nome (campo de texto), idade (lista suspensa). Ao criar o usuário, preenchi o nome como dave e selecionei a ...
Anexar uma coluna ao Data Frame no Apache Spark 1.3
É possível e qual seria o método mais eficiente para adicionar uma coluna ao Data Frame? Mais especificamente, a coluna pode servir como IDs de linha para o quadro de dados existente. Em um caso simplificado, lendo um arquivo e não ...
Como lidar com o tempo limite de resposta?
No roteamento akka-http, posso retornarFuture como uma resposta que converte implicitamente emToResponseMarshaller. Existe alguma maneira de lidar com o tempo limite deste futuro? Ou tempo limite da conexão no nível da rota? Ou uma maneira é ...
org.apache.spark.SparkException: tarefa não serializável
Este é um exemplo de código funcional: JavaPairDStream<String, String> messages = KafkaUtils.createStream(javaStreamingContext, zkQuorum, group, topicMap); messages.print(); JavaDStream<String> lines = messages.map(new Function<Tuple2<String, ...
Por que Scala aplica thunks automaticamente, às vezes?
Logo após 2:40 emShadowofCatron [http://www.youtube.com/user/ShadowofCatron]é Vídeo Scala Tutorial 3 [http://www.youtube.com/watch?v=R3gh9jIIbME], apontou que oparênteses após o nome de ...
Tipo de tempo de execução de característica do parâmetro type por TypeTag quando usado com o tipo Existential no Scala
eu tenhotrait com o parâmetro type Para obter o tipo de tempo de execução, eu usoTypeTag. No entanto, quando estetrait (e suas classes) são usadas comexistential type em uma coleção, por exemploList ouMap, TypeTag está perdido". Aqui está um ...