Real-Time Data Pipelines Made Easy with Structured Streaming in Apache Spark | Databricks episode artwork

EPISODE · Feb 18, 2024 · 4 MIN

Real-Time Data Pipelines Made Easy with Structured Streaming in Apache Spark | Databricks

from Higher Signal: Get Smarter. Faster. · host Higher Signal

Get the slides: https://www.datacouncil.ai/talks/building-real-time-data-pipelines-made-easy-with-structured-streaming-in-apache-spark?utm_source=youtube&utm_medium=social&utm_campaign=%20-%20DEC-SF-18%20Slides%20DownloadABOUT THE TALK:Structured Streaming is the next generation of distributed, streaming processing in Apache Spark. Developers can write a query written in their language of choice (Scala/Java/Python/R) using powerful high-level APIs (DataFrames / Datasets / SQL) and apply that same query to both static datasets and streaming data. In case of streaming, Spark will automatically create an incremental execution plan that automatically handles late, out-of-order data and ensures end-to-end exactly-once fault-tolerance guarantees. In this practical session, I will walk through a concrete streaming ETL example where – in less than 10 lines – you can read raw, unstructured data from Kafka data, transform it and write it out as a structured table ready for batch and ad-hoc queries on up-to-the-last-minute data. I will give a quick glimpse of advanced features like event-time based aggregations, stream-stream joins and arbitrary stateful operations.ABOUT THE SPEAKER:Tathagata is a committer and PMC to the Apache Spark project and a Software Engineer at Databricks. He is the lead developer of Spark Streaming, and now focuses primarily on Structured Streaming. Previously, he was a member of the AMPLab, UC Berkeley as a graduate student researcher where he conducted research on data-center frameworks and networks with Scott Shenker and Ion Stoica.ABOUT DATA COUNCIL: Data Council (https://www.datacouncil.ai/) is a community and conference series that provides data professionals with the learning and networking opportunities they need to grow their careers. Make sure to subscribe to our channel for more videos, including DC_THURS, our series of live online interviews with leading data professionals from top open source projects and startups. FOLLOW DATA COUNCIL:Twitter: https://twitter.com/DataCouncilAI LinkedIn: https://www.linkedin.com/company/datacouncil-ai

Episode metadata supplied by the publisher feed · Published Feb 18, 2024

Get the slides: https://www.datacouncil.ai/talks/building-real-time-data-pipelines-made-easy-with-structured-streaming-in-apache-spark?utm_source=youtube&utm_medium=social&utm_campaign=%20-%20DEC-SF-18%20Slides%20DownloadABOUT THE TALK:Structured Streaming is the next generation of distributed, streaming processing in Apache Spark. Developers can write a query written in their language of choice (Scala/Java/Python/R) using powerful high-level APIs (DataFrames / Datasets / SQL) and apply that same query to both static datasets and streaming data. In case of streaming, Spark will automatically create an incremental execution plan that automatically handles late, out-of-order data and ensures end-to-end exactly-once fault-tolerance guarantees. In this practical session, I will walk through a concrete streaming ETL example where – in less than 10 lines – you can read raw, unstructured data from Kafka data, transform it and write it out as a structured table ready for batch and ad-hoc queries on up-to-the-last-minute data. I will give a quick glimpse of advanced features like event-time based aggregations, stream-stream joins and arbitrary stateful operations.ABOUT THE SPEAKER:Tathagata is a committer and PMC to the Apache Spark project and a Software Engineer at Databricks. He is the lead developer of Spark Streaming, and now focuses primarily on Structured Streaming. Previously, he was a member of the AMPLab, UC Berkeley as a graduate student researcher where he conducted research on data-center frameworks and networks with Scott Shenker and Ion Stoica.ABOUT DATA COUNCIL: Data Council (https://www.datacouncil.ai/) is a community and conference series that provides data professionals with the learning and networking opportunities they need to grow their careers. Make sure to subscribe to our channel for more videos, including DC_THURS, our series of live online interviews with leading data professionals from top open source projects and startups. FOLLOW DATA COUNCIL:Twitter: https://twitter.com/DataCouncilAI LinkedIn: https://www.linkedin.com/company/datacouncil-ai

PodParley-generated summary based on available episode metadata and transcript content.

NOW PLAYING

Real-Time Data Pipelines Made Easy with Structured Streaming in Apache Spark | Databricks

0:00 4:29

No transcript for this episode yet

We transcribe on demand. Request one and we'll notify you when it's ready — usually under 10 minutes.

French Your Way Jessica: Native French teacher founder of French Your Way Boost your French listening skills and test your comprehension with this one of a kind series of podcasts. Get the chance to listen to a real conversation between native speakers talking at normal speed AND customise your learning experience through carefully designed sets of questions (2 levels of difficulty) available for download at www.frenchvoicespodcast.com. All interviews also come with the transcript. French teacher Jessica interviews native speakers of French from around the world who share a bit of their life and passion. Where else would you meet in one same place a French yoga teacher based in Melbourne, a soap manufacturer from Provence, or a couple cycling around the world? PodSights Health & Wellness podsights.ai Transform your wellbeing journey. Get trusted, evidence-based answers to your health, fitness, and mental wellness questions. Make informed decisions about your health. Visit podsights.ai to create your own wellness podcast. Wounded Warriors of the Cross Gary Pastoral and clergy mental health is a mostly ignored area, especially by those who live their lives as pastors in the clergy. The stigma of mental health within those who serve in the shadow of the cross is something that invokes the stigma of fear. Many of those in the clergy will choose to suffer in their despair rather than reaching out for help. Sometimes those suffering choose to wait until it's too late to get the real help that they need. At Wounded Warriors of the Cross our mission is to lift the stigma and the veil of silence that encompasses clergy mental health and assist those who suffer in silence. Wounded Warriors of the Cross is here to shed the light of Christ's love into those dark places. FEAR NOTHING and Have Lots of Fun with Carlie Lara Wallace carlielara Welcome to The Fear Nothing and Have Lots of Fun Podcast!! We get vulnerable, we have fun, and there’s always a bit of the gospel! These episodes detail all that God is doing in my life right now, and what I’m learning through these experiences. NEW EPISODES come out every Wednesday at 6:05am for those hump day early risers!

Frequently Asked Questions

How long is this episode of Higher Signal: Get Smarter. Faster.?

This episode is 4 minutes long.

When was this Higher Signal: Get Smarter. Faster. episode published?

This episode was published on February 18, 2024.

What is this episode about?

Get the slides: https://www.datacouncil.ai/talks/building-real-time-data-pipelines-made-easy-with-structured-streaming-in-apache-spark?utm_source=youtube&utm_medium=social&utm_campaign=%20-%20DEC-SF-18%20Slides%20DownloadABOUT THE TALK:Structured...

Can I download this Higher Signal: Get Smarter. Faster. episode?

Yes, you can download this episode by clicking the download button on the episode player, or subscribe to the podcast in your preferred podcast app for automatic downloads.
URL copied to clipboard!