Streaming Queries in Spark Declarative Pipelines (Apache Spark 4.1.0) revisited

W zasadzie zapowiedź jak poprzednio. Teoretycznie powinno być dokładniej i praktyczniej.

Niebawem nowe wydanie Apache Spark 4.1.0, więc kontynuujemy rozpoznanie Spark Declarative Pipelines od strony streaming queries (opartymi na good ol' Spark Structured Streaming).

Czego się nauczysz (dowiesz podczas kodowania na żywo):

1. Stworzysz projekt SDP (z pomocą starego dobrego uv już w wersji 0.9.11!)
2. Poznasz dekorator dp.append_flow oraz CREATE FLOW AS INSERT INTO BY NAME do definiowania przepływów (flows)
3. Poznasz dwa nie-dekoratory dp.create_sink i dp.create_streaming_table oraz CREATE STREAMING TABLE
4. Podsumujemy spotkanie omówieniem (nie)możliwych integracji z Delta Lake, Unity Catalog oraz Databricks Asset Bundles.

W razie pytań, sugestii lub chcesz pomóc, skontaktuj się ze mną na [email protected]. Każda pomoc mile widziana!

Proszę o nagłośnienie meetupu wśród Twoich znajomych. Dziękuję i zapraszam!