Resultados da pesquisa a pedido "scala"
Como usar um SourceQueue do Akka Streams com o PlayFramework
Eu gostaria de usar um SourceQueue para enviar elementos dinamicamente para uma fonte do Akka Stream. O controlador Play precisa de uma fonte para transmitir um resultado usando ochuncked método. Como o Play usa seu próprio Akka Stream Sink sob o ...
Como subtrair um dia / hora / minuto do joda-time DateTime no Scala?
Estou tentando usar o joda-time comseu invólucro Scala [http://github.com/jorgeortiz85/scala-time]. Dizendoval dt é umDateTime e contém umdate (zero time), como obtenho a data do dia antes?dt - 1.days não funciona e dá "type mismatch" ("found: ...
Inferindo o tipo de parâmetro implícito genérico do tipo de retorno
Digamos que eu tenha uma classe simples como esta abstract class Foo { implicit val impInt: Int = 42 def f[A]()(implicit a: A): A val f2: Int = f() }Ao declarar valf2, o compilador pode inferir que o tipo de parâmetro implícito da funçãof éInt ...
Como usar switch / case (correspondência simples de padrões) no Scala?
Eu me vi preso a uma coisa muito trivial: -] Eu tenho um enum: object Eny extends Enumeration { type Eny = Value val FOO, BAR, WOOZLE, DOOZLE = Value }Em um código, tenho que convertê-lo condicionalmente em um número (a correspondência ...
Um flatMap com faísca causa uma reprodução aleatória?
O flatMap no spark se comporta como a função de mapa e, portanto, não causa embaralhamento ou desencadeia um embaralhamento. Eu suspeito que isso causa embaralhamento. Alguém pode confirmar?
scala retorna primeiro Primeiro na lista
Eu tenho uma listal:List[T1] e atualmente estou fazendo o seguinte: myfun : T1 -> Option[T2] val x: Option[T2] = l.map{ myfun(l) }.flatten.find(_=>true)omyfun A função retorna None ou Some, flatten joga fora todos os Nones e find retorna o ...
Quais são as suas experiências em desenvolvimento no Scala / Lift?
Eu ouvi muitas coisas boas sobreScala [http://www.scala-lang.org/]e aLift [http://liftweb.net/]Estrutura da Web recentemente, especialmente deCaras ...
Como selecionar um subconjunto de campos de uma coluna da matriz no Spark?
Digamos que eu tenha um DataFrame da seguinte maneira: case class SubClass(id:String, size:Int,useless:String) case class MotherClass(subClasss: Array[SubClass]) val df = sqlContext.createDataFrame(List( ...
Registre UDF no SqlContext do Scala para usar no PySpark
É possível registrar um UDF (ou função) escrito em Scala para usar no PySpark? Por exemplo.: val mytable = sc.parallelize(1 to 2).toDF("spam") mytable.registerTempTable("mytable") def addOne(m: Integer): Integer = m + 1 // Spam: 1, 2No Scala, ...
Como usar as funções fornecidas pela classe DataFrameNaFunctions no Spark, em um Dataframe?
Eu tenho um quadro de dados e quero usar um dossubstituir()função de org.apache.spark.sql.DataFrameNaFunctionsnesse quadro de dados. Problema:Eu não recebo esses métodos em inteligência (sugestões) com a instância do dataframe. Eu importei essa ...