Saya memiliki aliran di mana saya mengkonsumsi jalan ke file dalam batch kecil dari topik Kafka pah, baca file itu sendiri (array json besar) dan tulis kembali ke topik data Kafka. Sepertinya ini: val fileFlow = Flow[Path].flatMapConcat(HdfsSource.data(fs, _)) .via(JsonFraming.objectSc....
29 Mei 2021, 22:52
Di bawah ini adalah kode yang saya gunakan untuk menghitung rata-rata aliran data dalam daftar objek: import akka.NotUsed; import akka.actor.ActorSystem; import akka.stream.javadsl.Sink; import akka.stream.javadsl.Source; import java.util.ArrayList; import java.util.Arrays; import java.util.List; i....
29 Mei 2021, 14:07
Kawan-kawan! Saya memiliki layanan kecil dari contoh AKKA-HTTP. import ch.megard.akka.http.cors.scaladsl.CorsDirectives._ object Server extends App{ val route = cors() { path("hello") { get { complete(HttpEntity(ContentTypes.`text/html(UTF-8)`, "<h1>Привет ёпта</h1>....
23 Mei 2021, 02:00
Saya memiliki masalah di mana saya diminta untuk menggunakan AKKA stream untuk merancang API pencarian untuk mencari data ke dalam beberapa file .tsv terkait. > Untuk mantan Anda memiliki 2 file: film.tsv (id, judul) aktor.tsv (nama, movieid) Katakanlah Anda ingin membuat titik akhir yang m....
4 April 2021, 15:38
Saya berjuang dengan hubungan dalam model aktor. Biarkan saya menggunakan contoh sederhana. Ada dua jenis aktor dalam sistem: gudang dan item. Barang selalu ditugaskan ke gudang tertentu. Perintah AddStock memungkinkan untuk meningkatkan jumlah stok yang ditugaskan ke lokasi gudang yang diberikan. H....
11 September 2020, 11:30