Publicații conexe 'stream'
Instalare rapidă și primul pas în Apache Kafka
Puțin Ce este Apache Kafka
Apache Kafka este o platformă de streaming de evenimente și ar putea fi aplicată în multe locuri, iată câteva exemple .
Sarcină de procesare în timp real - de exemplu, bursa de valori, UPI sau alte utilizări bancare Pentru a urmări și monitoriza logistica și industria auto, uber îl folosește. "Aici" Pentru a servi drept fundație pentru platforme de date, arhitecturi bazate pe evenimente și microservicii. Netflix îl folosește pentru a procesa cereri..
Fluxuri Java pentru începători
Stream API a fost introdus în Java 8. Este folosit pentru a procesa colecțiile de obiecte. Cu ajutorul funcțiilor Streams și Lambda, putem scrie cod curat, concis și ușor de înțeles.
Streams este o conductă de operațiuni, pe care o putem folosi pentru a evalua datele.
„Streamurile” au operațiuni intermediare și terminale pe care le putem folosi conform cerințelor noastre. Iată o listă de operațiuni:
Intermediar Operațiuni : peek, flatMap, limit, sort, distinct, map, filter..
Întrebări înrudite 'stream'
Abordare de programare funcțională pentru fluxurile de intrare/ieșire ale Java
Folosesc DataInputStream Java cu scala pentru a analiza un fișier binar simplu (ceea ce este o experiență foarte proastă din cauza lipsei de tipuri nesemnate, chiar și în scala, dar asta este o altă poveste).
Cu toate acestea, mă simt nevoit să...
1568 vederi
schedule
29.07.2022
Citirea din NetworkStream. Care este mai bun ReadLine() vs. Read into ByteArray?
Folosesc TcpClient pentru a comunica cu un server care trimite informații sub formă de șiruri delimitate „\n”. Fluxul de date este destul de mare și odată ce canalul este setat, fluxul va avea întotdeauna informații din care să citească. Mesajele...
10392 vederi
schedule
03.09.2022
DirectShow: IMediaSeeking::SetRate nu funcționează cu fluxurile H.264
Cum pot seta rata de redare video când lucrez cu fluxuri video H.264 cu DirectShow?
Se pare că IMediaSeeking::SetRate nu funcționează cu decodorul video H.264. Am încercat până acum următoarele decodore: Microsoft DTV-DVD Decoder (livrat cu...
1202 vederi
schedule
20.09.2022
Capturarea ieșirii HTML cu un filtru de acțiune a controlerului
Am implementat următorul filtru pentru o acțiune pentru a capta ieșirea HTML, a o converti într-un șir, a face unele operațiuni pentru a modifica șirul și a returna un ContentResult cu noul șir. Din păcate, continui să ajung cu un șir gol....
10338 vederi
schedule
02.09.2022
Citirea dintr-un flux în Windows Phone7
Lucrez cu Windows Phone SDK 7 și încerc să implementez descărcarea unui fișier imagine. Nu pot folosi obiectul standard BitmapImage deoarece serverul meu folosește module cookie de autentificare și, din câte îmi dau seama, nu există nicio modalitate...
407 vederi
schedule
03.07.2022
Redare Kinect Point Cloud cu Vertex Buffer Object (VBO)
Încerc să fac un vizualizator dinamic de nor de puncte. Punctele sunt actualizate la fiecare cadru cu senzorul Kinect. Pentru a prelua cadrele, folosesc OpenCV și GLUT pentru a le afișa. API-ul OpenCV returnează un 640 x 480 (float *), pentru...
2975 vederi
schedule
17.09.2022
Adăugarea unui nume și a unui scor nou la o matrice 2D existentă + fluxuri I/O?
Așa că am un joc Sudoku și încerc să implementez un sistem de scor mare (Înregistrează primii 5 jucători) pe baza timpilor jucătorilor. Cu cât timpul este mai mic, cu atât rangul în Scorul Mare este mai mare. M-am gândit cum să trec prin fluxuri....
862 vederi
schedule
03.09.2022
Video cu cameră IP de la distanță pe mai multe dispozitive Android
Unul dintre clienții mei a instalat o cameră IP (D-Link S930L) într-o biserică și dorește să partajeze videoclipuri cu alții folosind o aplicație Android.
Problema este că mai mulți (câteva sute) de utilizatori se vor conecta la serviciu în același...
1736 vederi
schedule
31.07.2022
Flux de imagini trimis prin Socket - Problemă de blocare a serverului
Am implementat o aplicație pentru Android care face o poză cu camera SP și o trimite printr-o priză către server.
Folosesc următorul cod (JAVA) pentru a citi fișierul imagine stocat local și a-l trimite în bucăți succesive peste socket:...
820 vederi
schedule
22.08.2022
streaming c++ în matrice de caractere?
În prezent lucrez la o aplicație c++ care folosește o bibliotecă c care are nevoie de un callback implementat din partea mea, de exemplu, callback-ul este definit astfel:
int onWrite(char *what, char *buffer, size_t size, off_t offset);
am...
12360 vederi
schedule
14.08.2022
Copiați datele din MemoryStream direct în BinaryWriter.BaseStream?
Am o grămadă de date într-un MemoryStream și vreau să le scriu pe toate într-un BinaryWriter .
Din fericire pentru mine, toate fluxurile au acum o Stream.CopyTo(Stream) metoda și pot obține fluxul țintă din BinaryWriter.BaseStream...
2857 vederi
schedule
04.09.2022
Funcția Node lazy și asincronă în forEach
Încerc să citesc fișierul cu (aproximativ 50 000 de linii) și să salvez fiecare linie după analizarea în mongodb. Funcția de salvare Mongodb este asincronă. Pentru iterarea unui fișier, folosesc modulul node-lazy.
Ceea ce primesc este că doar o...
1271 vederi
schedule
31.08.2022
Cum se interoghează „meta date” fluxului NodeJS?
Am un program cu mai multe conducte lungi cu mai multe transformări.
e.g.
socket.pipe(ta).pipe(tb).pipe(tc);
...
tc.pipe(other_socket);
Care este cel mai bun mod de a adăuga/citi metadate la/din conductă?
De exemplu: ta acumulează și...
488 vederi
schedule
31.07.2022
cum să redeschid și să întrerup fluxul de la tastatură?
Am o întrebare foarte simplă. Bazat pe schema Java I/O, ori de câte ori un fir așteaptă niște date, deci va fi blocat? este adevarat? ceva de genul.
byte[] _buff=new byte[1024];
int _r=_in.read(_buff);//it blocks until some data is available...
183 vederi
schedule
31.07.2022
Cum să obțineți adresa URL de streaming de la stația de radio de streaming online
Mi s-a cerut să fac o aplicație Android neoficială de streaming online pentru un anumit post de radio. Am experiență cu transmiterea în streaming în Android pentru anumite mp3 sau orice flux. Dar nu cunosc stream url să furnizați în...
123321 vederi
schedule
15.07.2022
Cum să retransmiteți de la Red5 la Wowza
Am încercat să re-stream de la Red5 la Wowza folosind Wowza Streamanager. Acest lucru funcționează excelent dacă folosesc FMS care trag fluxul în Wowza și pe playere Flash și dispozitive IOS (dacă folosesc h.264/AAC pe encoderul FMLE - care...
756 vederi
schedule
01.07.2022
Trimiteți jurnalele către pagina web cu node.js
Am o problemă în timp ce încerc să trimit câteva jurnale ale aplicației mele în față.
Vreau să trimit toate jurnalele unui anumit container docker către o pagină web. Îl pot atașa în consolă, funcționează perfect, dar nu reușesc să trimit acest...
241 vederi
schedule
05.07.2022
programul de blocări ofstream close
Am urmatorul cod
void _log_message(const char* fmt, ...)
{
va_list arg;
ofstream logfile;
cout << "Open Log File" << endl;
logfile.open(LOG_FILE, ios::out | ios::app);
if(!logfile.is_open()) return;
time_t t =...
1167 vederi
schedule
16.09.2022
Nodejs salvează fișierul binar folosind stream
Salutare tuturor,
Încerc să folosesc fluxul pentru a salva obiectul de date într-un fișier Excel. Cu toate acestea, fișierul nu a putut fi deschis după salvare.
În același timp, folosesc fs.writeFile pentru a salva același obiect de date, iar...
4091 vederi
schedule
28.07.2022
Buffered Reader pentru Android Streaming prin Bluetooth
Bună, băieți, așa că încerc să citesc un flux de pe un dispozitiv bluetooth care transmite continuu numere întregi ca acesta:
-11
121
123
1234
-11
Funcționează totul cu un cod pe care l-am găsit online, dar pentru a face o parte din...
776 vederi
schedule
28.06.2022
