Domande con tag 'stream-processing'

domande con tag
1
risposta

Spostamento dall'architettura Batch a Streaming mediante una struttura dati Graph

Il caso d'uso che sto cercando di risolvere è quello di assegnare milioni di utenti ai loro gruppi / segmenti. Ho migliaia di criteri diversi da cui vengono creati i bucket degli utenti. Per esempio. criteri del bucket: All married males in...
posta 21.05.2017 - 02:29
0
risposte

Architettura di streaming (nota anche come Kappa) e diversi tipi di dati

Sto cercando di verificare la mia comprensione della architettura kappa . Il punto principale che sto tentando di risolvere è come, se del caso, si unisca l'elaborazione dei dati in analisi e altre parti di dati, come un utente che modifica un'...
posta 13.02.2017 - 14:25
0
risposte

Arricchimento del flusso asincrono con una coda di messaggi (ad esempio Kafka)

Vorrei arricchire alcuni dati di streaming, con un servizio per arricchimento, possibilmente ciascun servizio scritto in una lingua diversa e gestito / distribuito separatamente. Ogni servizio consumerebbe qualche argomento di Kafka, arricchi...
posta 15.11.2016 - 17:52
2
risposte

Come gestisci un buffer mutabile in uno spazio funzionale?

Ho un metodo di analisi dello stream in C # che legge porzioni di un frame del protocollo dal protocollo STOMP; la specifica non è la parte importante per la domanda però. Ciò che è importante è che ho scritto il codice in uno stile imperativo...
posta 28.06.2016 - 19:25
1
risposta

Devo produrre output con yield o stream.write in Python 3?

Sto lavorando su un programma Python 3 che, tra le altre cose, scriverà i dati in file di testo in numerosi formati. Ho una funzione per formato, che genera i dati da scrivere. Vedo due possibili modi di scrivere queste funzioni: una utilizza...
posta 05.01.2018 - 11:21
2
risposte

Ideal Interprocess Communication

Quindi, c'è un flusso di lavoro che ritengo debba esistere. Potrebbe già esistere, e io non ne so nulla. Considera il flusso di lavoro della riga di comando di Linux, il "motto" di Linux, più o meno. Hai un sacco di piccoli programmi, accetta...
posta 18.04.2018 - 23:57
1
risposta

Che cosa sono i flussi reattivi e cosa c'è di così speciale in loro?

Ho sfogliato Wikipedia e ho riscontrato una nuova funzionalità di Java 1.9: Stream reattivi . Sfortunatamente, la pagina di Wikipedia collegata non aiuta molto a capire quali sono quei flussi reattivi e cosa li rende così speciali. Si è d...
posta 16.07.2017 - 11:42
1
risposta

Utilizzo di For-each loop vs operation funzionale vs Java8 stream

Quali sono i vantaggi in termini di velocità di elaborazione effettiva (la verosimiglianza del codice viene messa da parte) e per quale caso ciascuno sarebbe consigliato, come un buon modello di progettazione? Mi piacerebbe sapere quanto sopra i...
posta 15.06.2017 - 14:35
2
risposte

Streaming video tramite chiamate Ajax

In questi giorni ho visto un paio di siti (incluso Youtube) che trasmettono video tramite chiamate Ajax (XHR) in pochi MB o anche meno di MB. Per un esempio di ciò che ho detto, vedi le linee evidenziate nell'immagine qui sotto. Voglio...
posta 27.10.2016 - 02:46
2
risposte

MJRTY - Un algoritmo di voto a maggioranza rapida non funziona [chiuso]

L'algoritmo MJRTY si propone di risolvere il problema di trovare l'elemento di maggioranza in un flusso (un elemento che comprende più del 50% del flusso). Moore ha proposto di risolvere questo problema utilizzando solo 2 informazioni e una sing...
posta 23.02.2015 - 16:14