Resultados da pesquisa a pedido "scala"

4 a resposta

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 / ...

4 a resposta

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 ...

5 a resposta

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 ...

1 a resposta

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 ...

2 a resposta

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 ...

4 a resposta

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 ...

1 a resposta

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 é ...

2 a resposta

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, ...

4 a resposta

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 ...

1 a resposta

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 ...