Yazeka
Arama sonuçlarına göre oluşturuldu
Spark Streaming, canlı veri akışlarını işlemek için şu şekilde çalışır:
- Veri Alımı: Veriler, Kafka, Kinesis veya TCP soketleri gibi kaynaklardan gerçek zamanlı olarak okunur 14.
- Mikro Partisyon Oluşturma: Gelen veriler, belirli bir zaman aralığına göre mikro partisyonlara ayrılır (örneğin, her 2 saniyede bir) 4.
- İşleme: Her mikro partisyon, dönüşümler (örneğin, filtreleme, gruplama) ve eylemler (örneğin, bir lavaboya yazma) için işlenir 4.
- Çıktı: Sonuçlar, dosya, veritabanı veya konsol gibi bir lavaboya yazılır 4.
- Hata Toleransı: Checkpointing özelliği ile durum kaydedilir, böylece başarısızlık durumunda veri kaybı önlenir 24.
5 kaynaktan alınan bilgiyle göre: