Charting A Path For Streaming Data To Fill Your Data Lake With Hudi

Summary

Data lake architectures have largely been biased toward batch processing workflows due to the volume of data that they are designed for. With more real-time requirements and the increasing use of streaming data there has been a struggle to merge fast, incremental updates with large, historical analysis. Vinoth Chandar helped to create the Hudi project while at Uber to address this challenge. By adding support for small, incremental inserts into large table structures, and building support for arbitrary update and delete operations the Hudi project brings the best of both worlds together. In this episode Vinoth shares the history of the project, how its architecture allows for building more frequently updated analytical queries, and the work being done to add a more polished experience to the data lake paradigm.

Announcements

• Hello and welcome to the Data Engineering Podcast, the show about modern data management
• You listen to this show to learn about all of the latest tools, patterns, and practices that power data engineering projects across every domain. Now there’s a book that captures the foundational lessons and principles that underly everything that you hear about here. I’m happy to announce I collected wisdom from the community to help you in your journey as a data engineer and worked with O’Reilly to publish it as 97 Things Every Data Engineer Should Know. Go to dataengineeringpodcast.com/97things today to get your copy!
• When you’re ready to build your next pipeline, or want to test out the projects you hear about on the show, you’ll need somewhere to deploy it, so check out our friends at Linode. With their managed Kubernetes platform it’s now even easier to deploy and scale your workflows, or try out the latest Helm charts from tools like Pulsar and Pachyderm. With simple pricing, fast networking, object storage, and worldwide data centers, you’ve got everything you need to run a bulletproof data platform. Go to dataengineeringpodcast.com/linode today and get a $100 credit to try out a Kubernetes cluster of your own. And don’t forget to thank them for their continued support of this show!
• RudderStack’s smart customer data pipeline is warehouse-first. It builds your customer data warehouse and your identity graph on your data warehouse, with support for Snowflake, Google BigQuery, Amazon Redshift, and more. Their SDKs and plugins make event streaming easy, and their integrations with cloud applications like Salesforce and ZenDesk help you go beyond event streaming. With RudderStack you can use all of your customer data to answer more difficult questions and then send those insights to your whole customer data stack. Sign up free at dataengineeringpodcast.com/rudder today.
• We’ve all been asked to help with an ad-hoc request for data by the sales and marketing team. Then it becomes a critical report that they need updated every week or every day. Then what do you do? Send a CSV via email? Write some Python scripts to automate it? But what about incremental sync, API quotas, error handling, and all of the other details that eat up your time? Today, there is a better way. With Census, just write SQL or plug in your dbt models and start syncing your cloud warehouse to SaaS applications like Salesforce, Marketo, Hubspot, and many more. Go to dataengineeringpodcast.com/census today to get a free 14-day trial.
• Your host is Tobias Macey and today I’m interviewing Vinoth Chandar about Apache Hudi, a data lake management layer for supporting fast and incremental updates to your tables.

Interview

• Introduction
• How did you get involved in the area of data management?
• Can you describe what Hudi is and the story behind it?
• What are the use cases that it is focused on supporting?
• There have been a number of alternative table formats introduced for data lakes recently. How does Hudi compare to projects like Iceberg, Delta Lake, Hive, etc.?
• Can you describe how Hudi is architected?
  • How have the goals and design of Hudi changed or evolved since you first began working on it?
  • If you were to start the whole project over today, what would you do differently?
• Can you talk through the lifecycle of a data record as it is ingested, compacted, and queried in a Hudi deployment?
• One of the capabilities that is interesting to explore is support for arbitrary record deletion. Can you talk through why this is a challenging operation in data lake architectures?
  • How does Hudi make that a tractable problem?
• What are the data platform components that are needed to support an installation of Hudi?
• What is involved in migrating an existing data lake to use Hudi?
  • How would someone approach supporting heterogeneous table formats in their lake?
• As someone who has invested a lot of time in technologies for supporting data lakes, what are your thoughts on the tradeoffs of data lake vs data warehouse and the current trajectory of the ecosystem?
• What are the most interesting, innovative, or unexpected ways that you have seen Hudi used?
• What are the most interesting, unexpected, or challenging lessons that you have learned while working on Hudi?
• When is Hudi the wrong choice?
• What do you have planned for the future of Hudi?

Contact Info

• Linkedin
• Twitter

Parting Question

• From your perspective, what is the biggest gap in the tooling or technology for data management today?

Closing Announcements

• Thank you for listening! Don’t forget to check out our other show, Podcast.__init__ to learn about the Python language, its community, and the innovative ways it is being used.
• Visit the site to subscribe to the show, sign up for the mailing list, and read the show notes.
• If you’ve learned something or tried out a project from the show then tell us about it! Email [email protected]) with your story.
• To help other people find the show please leave a review on iTunes and tell your friends and co-workers
• Join the community in the new Zulip chat workspace at dataengineeringpodcast.com/chat

Links

• Hudi Docs
• Hudi Design & Architecture
• Incremental Processing
• CDC == Change Data Capture
  • Podcast Episodes
• Oracle GoldenGate
• Voldemort
• Kafka
• Hadoop
• Spark
• HBase
• Parquet
• Iceberg Table Format
  • Data Engineering Episode
• Hive ACID
• Apache Kudu
  • Podcast Episode
• Vertica
• Delta Lake
  • Podcast Episode
• Optimistic Concurrency Control
• MVCC == Multi-Version Concurrency Control
• Presto
• Flink
  • Podcast Episode
• Trino
  • Podcast Episode
• Gobblin
• LakeFS
  • Podcast Episode
• Nessie

The intro and outro music is from The Hug by The Freak Fandango Orchestra / CC BY-SA