Resultados da pesquisa a pedido "scala"
Como adicionar o número da linha em cada linha?
suponha que estes são meus dados: ‘Maps‘ and ‘Reduces‘ are two phases of solving a query in HDFS. ‘Map’ is responsible to read data from input location. it will generate a key value pair. that is, an intermediate output in local machine. ...
Quando é necessário um tipo de retorno para métodos no Scala?
O compilador Scala geralmente pode inferir tipos de retorno para métodos, mas há algumas circunstâncias em que é necessário especificar o tipo de retorno. Métodos recursivos, por exemplo, exigem que um tipo de retorno seja especificado. Percebo ...
Qual é a diferença entre ArrayBuffer e Array in scala
Eu sou novo no scala / java e tenho problemas em obter a diferença entre os dois. Ao ler o documento scala, entendi que o ArrayBuffer é feito para ser interativo (acrescentar, inserir, acrescentar, etc.). 1) Quais são as diferenças fundamentais ...
Diferença entre Spark Vetores e Scala imutável Vector?
Estou escrevendo um projeto para o Spark 1.4 no Scala e atualmente estou entre converter meus dados de entrada iniciais emspark.mllib.linalg.Vectors escala.immutable.Vector com quem mais tarde quero trabalhar no meu algoritmo. Alguém poderia ...
Stream vs Views vs Iterators
Quais são as diferenças entre fluxos, visualizações (SeqView) e iteradores no scala? Este é o meu entendimento: São todas listas preguiçosas.Os fluxos armazenam em cache os valores.Iteradores podem ser usados apenas uma vez? Você não pode voltar ...
Como simplificar chamadas de mapa aninhadas?
Suponha que eu tenha alguns functores aninhados, por exemploList[Option[Int]] e precisa ligar para omap do mais interior. Agora estou usando aninhadomaps: scala> val opts: List[Option[Int]] = List(Some(0), Some(1)) opts: List[Option[Int]] = ...
Como registrar uma função no sqlContext UDF no scala?
Eu tenho um método chamado getAge (timestamp: Long) e quero registrar isso como uma função sql. eu tenho sqlContext.udf.register("getAge",getAge)Mas está me dizendo que eu preciso de argumentos ou uso _ depois, tentei usar _ mas me dá erro. ...
Por que a transmissão por faísca não funciona bem quando uso o App extends?
O primeiro código lança uma exceção de ponteiro nulo. object TryBroadcast extends App{ val conf = new SparkConf().setAppName("o_o") val sc = new SparkContext(conf) val sample = sc.parallelize(1 to 1024) val bro = sc.broadcast(6666) val broSample ...
Levante o filtro para forçar o ssl
em um aplicativo struts, tenho um filtro que força determinadas páginas a serem acessadas apenas por https via redirecionamento. Estou pensando em portá-lo para levantar, então minha pergunta é: Nesse ambiente, existe uma maneira de "levantar" ...
Directiva `` destacar '' da Spray
Dado o seguinte código de pulverização: object Main extends App with SimpleRoutingApp { implicit val system = ActorSystem("my-system") val pipeline: HttpRequest => Future[String] = sendReceive ~> unmarshal[String] startServer(interface = ...