scala

5calore

4risposta

Come aggiungere un osservatore basato sul tempo ad un futuro di Scala?

Voglio aggiungere un after(d: FiniteDuration)(callback: => Unit) util a Scala Future s che permetta che io faccia questo: val f = Future(someTask) f.after(30.seconds) { println("f has not compl

8calore

3risposta

Aggregazione di più colonne con funzione personalizzata nella scintilla

Mi chiedevo se esiste un modo per specificare una funzione di aggregazione personalizzata per i frame di dati spark su più colonne. Ho una tabella come questa del tipo (nome, articolo, prezzo): john |

6calore

2risposta

recupera più di 20 righe e visualizza il valore completo della colonna in spark-shell

Sto utilizzando cassandraSQL da spark-shell per interrogare i dati da cassandra. Quindi, voglio sapere due cose su come recuperare più di 20 righe usando cassnadraSQL e in secondo luogo come faccio a

7calore

1risposta

implementazione libera in scalaz

L'implementazione libera in Haskell è: data Free f a = Pure a | Free (f (Free f a)) , mentre, l'implementazione in Scalaz è: sealed abstract class Free[S[_], A] private case class Return[S[_], A

7calore

1risposta

Come evitare la doppia registrazione con il logback?

Nella mia applicazione, vorrei registrare alcuni messaggi provenienti dal mio codice in un modo specifico rispetto a tutti gli altri messaggi registrati. Tuttavia non sono sicuro di come posso evitare

10calore

1risposta

Scope pacchetto-privato in Scala visibile da Java

Ho appena scoperto un comportamento piuttosto strano dell'oscilloscopio Scala quando il codice bytecode generato dal codice Scala viene utilizzato dal codice Java. Si consideri il seguente frammento d

5calore

1risposta

scala - modo idiomatico per cambiare lo stato della classe

Ho diverse classi tutte estendono lo stesso tratto e condividono tutte le funzionalità reciproche che dovrebbero cambiare il loro stato. Tuttavia mi chiedevo se c'è un modo migliore per implementare l

8calore

1risposta

Come appiattire una sequenza di ValidatedNel gatti valori

ho bisogno di appiattire una sequenza di cats.data.ValidatedNel[E, T] valori per un singolo ValidatedNel valore: val results: Seq[cats.data.ValidatedNel[E, T]] = ??? val flattenedResult: cats.data.V

5calore

3risposta

Stream di Akka: lettura di più file

Ho una lista di file. Voglio: Per leggere da tutti come un'unica fonte. I file devono essere letti in sequenza, in ordine. (no round-robin) Non è necessario che nessun file sia interamente memorizzato

6calore

2risposta

idea sbt java.lang.NoClassDefFoundError: org/apache/spark/SparkConf

Sono un principiante della scintilla. Costruisco un ambiente uso "linux + idea + sbt", quando provo l'avvio rapido di Spark, ottengo il problema: Exception in thread "main" java.lang.NoClassDefFoundEr