Apache Spark – Structered Streaming ile zaman gruplarında veri analizi ? (window operations )

spark-window

Bu bölümde Apache Spark ile belirli zaman gruplarında verileri analiz ederek sonuçlar oluşturacağız

Örnek verirsek bir port üzerinden aldıgımız kelimeleri 10’er saniyelik bölümlerde sayarak kaç adet kelime geldiğini hesaplayabiliriz

Okumaya devam et “Apache Spark – Structered Streaming ile zaman gruplarında veri analizi ? (window operations )”

Please follow and like us:

Apache Spark – Structered Streaming Mimarisi

Bu bölümde Apache Spark ile Structered Streaming Mimarisi hakkında bilgiler vereceğiz

Bir önceki bölümde  Structered Streaming ile basit bir örnek yapmıştık. Geliştirdiğimiz uygulamada belirli bir port üzerinden kelimeler gönderip , bu port’u dinleyen Spark uygulamasına word-count analizi yaptırdık

Şimdi ise mimari tarafı inceleyelim

realtime_mimari

Okumaya devam et “Apache Spark – Structered Streaming Mimarisi”

Please follow and like us: