Domande con tag 'stream-processing'

domande con tag
3
risposte

Perché dovrei usare "operazioni funzionali" invece di un ciclo for?

for (Canvas canvas : list) { } NetBeans mi suggerisce di utilizzare "operazioni funzionali": list.stream().forEach((canvas) -> { }); Ma perché questo preferito ? Se mai, è più difficile da leggere e capire. Stai chiamando stream()...
posta 13.09.2015 - 21:12
3
risposte

E 'un antipattern usare peek () per modificare un elemento stream?

Supponiamo di avere un flusso di cose e voglio "arricchirle" a metà stream, posso usare peek() per fare ciò, ad esempio: streamOfThings.peek(this::thingMutator).forEach(this::someConsumer); Supponiamo che la mutazione delle cose a ques...
posta 01.02.2016 - 18:39
4
risposte

Cos'è in realtà un flusso di byte?

Qualcuno può spiegarmi cosa contiene effettivamente il flusso di byte? Contiene solo byte (dati esadecimali) o dati binari o solo lettere inglesi? Sono anche confuso riguardo al termine "dati grezzi". Se qualcuno mi chiedesse di "invertire i dat...
posta 05.11.2013 - 17:45
3
risposte

È una cosa sensata restituire gli stream ovunque verrebbero normalmente restituite le raccolte?

Durante lo sviluppo della mia API che non è legata a nessun codice legacy, mi trovo spesso a scrivere metodi che sono stati interrotti esclusivamente dalla pipeline di Streams raccogliendo i risultati. Come questo: ImmutableSet<T> derive...
posta 12.03.2015 - 19:46
1
risposta

Come funziona lo smistamento con lo stream di java 8 sotto il cofano?

Quando chiamo Stream.sort(..) c'è una nuova serie di elementi creati e il flusso itera sopra l'array ordinato appena creato? In altre parole, come Java 8 Stream fa sort sotto il cofano?     
posta 30.09.2016 - 21:51
1
risposta

Quale tipo di buffer devo implementare per un dispositivo audio streaming unidirezionale?

Sto lavorando a un progetto in cui i dati audio vengono trasmessi in streaming su un dispositivo. I dati audio sono codificati tramite opus e trasmessi in streaming a 20 ms di carico utile alla volta. Lo streaming viene effettuato tramite TCP pe...
posta 14.05.2015 - 00:56
2
risposte

Broker di messaggi tradizionali e dati di streaming

Secondo il sito di Kafka : "Kakfa is used for building real-time data pipelines and streaming apps." Cercando in Internet in lungo e in largo, ho trovato la seguente definizione generalmente accettata di ciò che " stream data " è: I...
posta 07.06.2017 - 05:31
2
risposte

Esistono tecniche per rilevare le ridondanze in un flusso di modifiche a un filesystem?

Sto lavorando su un client di sincronizzazione file che attualmente produce un flusso di modifiche al filesystem sottostante. Questo è un flusso di eventi create / update / move / delete per ogni "target" di sincronizzazione. Ogni evento incl...
posta 23.01.2018 - 13:04
1
risposta

Perché esiste la funzione Cddio 'ungetc'?

Nel linguaggio di programmazione C (e in molte lingue successive che sono direttamente interfacciate con o costruito un fac-simile delle funzioni IO standard di C), esiste una funzione chiamata ungetc : int ungetc(int char, FILE *stream); ....
posta 04.09.2016 - 23:34
1
risposta

Come si dovrebbe gestire il buffer intermedio della classe DataReader?

Riepilogo Sto sviluppando un lettore di file in formato WAV con WinRT, e per questo ho bisogno di leggere quantità casuali di strutture costituite da tipi fondamentali come int , uint , float e così via. Indietro nello svilu...
posta 20.09.2015 - 23:23