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
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