Serivisi

Uburyo bwo guhanagura amakuru
(I) DStream na RDD
Nkuko tubizi, Ibarura rya Spark Streaming rishingiye kuri Spark Core, kandi intandaro ya Spark Core ni RDD, bityo Spark Streaming igomba kuba ifitanye isano na RDD.Nyamara, Spark Streaming ntabwo yemerera abakoresha gukoresha RDD muburyo butaziguye, ariko ikuramo urutonde rwibitekerezo bya DStream, DStream na RDD nubusabane burimo, urashobora kubyumva nkuburyo bwo gushushanya muri Java, ni ukuvuga, DStream niyongera rya RDD, ariko imyitwarire isa na RDD.
DStream na RDD byombi bifite imiterere myinshi.
.
(2) bose bafite ibikorwa byibikorwa, nka foreachRDD, kubara, nibindi.
Uburyo bwo gutangiza gahunda burahoraho.
(B) Intangiriro ya DStream muri Spark Streaming
DStream ikubiyemo ibyiciro byinshi.
(1) Ibyiciro byamasoko yamakuru, nka InputDStream, yihariye nka DirectKafkaInputStream, nibindi.
(2) Amasomo yo guhindura, mubisanzwe MappedDStream, ShuffledDStream
(3) ibisohoka ibyiciro, mubisanzwe nka ForEachDStream
Kuva hejuru, amakuru kuva muntangiriro (kwinjiza) kugeza kumpera (ibisohoka) bikorwa na sisitemu ya DStream, bivuze ko uyikoresha mubisanzwe adashobora kubyara no gukoresha RDDs, bivuze ko DStream ifite amahirwe ninshingano zo kuba ashinzwe ubuzima bwinzira ya RDDs.
Muyandi magambo, Spark Streaming ifite angusukura mu buryo bwikoraimikorere.
(iii) Inzira y'ibisekuru bya RDD muri Spark Streaming
Ubuzima bwa RDDs muri Spark Streaming irakomeye kuburyo bukurikira.
(1) Muri InputDStream, amakuru yakiriwe ahindurwa muri RDD, nka DirectKafkaInputStream, itanga KafkaRDD.
.
.