akka-stream

5calore

3risposta

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

12calore

1risposta

Akka Streams. Stato di stato in un flusso

Voglio leggere più file di grandi dimensioni utilizzando gli stream di akka per elaborare ogni riga. Immagina che ogni chiave sia costituita da un ("identificatore" -> "valore"). Se viene trovato un n

10calore

1risposta

Via/ViaMat/to/toMat in Akka Stream

Qualcuno può spiegare chiaramente quali sono le differenze tra questi 4 metodi? Quando è più appropriato usare ciascuno di essi? Inoltre, in generale, qual è il nome di questo gruppo di metodi? Ci son

8calore

1risposta

Come assemblare un sink di Akka Streams da più scritture di file?

Sto provando ad integrare un flusso basato su stream akka nella mia app Play 2.5. L'idea è che puoi eseguire lo streaming in una foto, quindi scrivere su disco come file raw, una versione con miniatur

5calore

1risposta

Akka flusso vs Spark flusso

Quali sono vantaggio/svantaggio di utilizzare Akka flusso vs flusso scintilla per l'elaborazione flusso? come, costruito in contropressione, prestazioni, tolleranza ai guasti, trasformazioni incorpora

5calore

1risposta

Creazione di un'origine da un EventStream

Sto utilizzando PlayFramework 2.5.3 e vorrei creare un akka.stream.scaladsl.Source da un akka.event.EventStream (il flusso di eventi fa parte di un sistema di attori). Lo stream di eventi produrrebbe

10calore

1risposta

Un modo corretto per arrestare i flussi di Akka a condizione

Ho utilizzato con successo FileIO per trasmettere il contenuto di un file, calcolare alcune trasformazioni per ogni riga e aggregare/ridurre i risultati. Ora ho un caso d'uso piuttosto specifico, in c

13calore

1risposta

Caricamento file tramite Akka HTTP

Sto cercando di implementare la funzionalità di caricamento dei file nella mia applicazione usando Akka HTTP. Sto usando la versione akka-stream2.4.4. Ecco il codice (modificato da akka-doc) path("fil

6calore

3risposta

Divisione sorgente streaming Akka in due

Ho un flusso Akka Source che voglio suddividere in due fonti in base a un predicato. E.g. avendo una sorgente (tipi sono semplificate intenzionalmente): val source: Source[Either[Throwable, String], N

5calore

1risposta

Stream di Akka - immissione di un flusso legato all'IO su un dispatcher diverso

Il mio stream ha un mix uniforme di CPU bound e livelli di IO bound (ogni fase IO è seguita da uno stage CPU). Quello che voglio fare è mettere le operazioni IO su un dispatcher diverso rispetto al re