Usman Masood's guest appearances

Usman Masood

Data Engineering Podcast

Nikita Shamgunov

Christopher Ryan

Emily Miller

Peter Bull

Patrick Hunt

Jonathan Katz

Kevin Moore

Dan Robinson

Matthew Rocklin

Maxime Beauchemin

Jean Georges Perrin

Todd Walter

Mark Marinelli

Andy LoPresto

Joe Crobak

OwlTail

Derek Nelson

Summary Processing high velocity time-series data in real-time is a complex challenge. The team at PipelineDB has built a continuous query engine that simplifies the task of computing aggregates across incoming streams of events. In this episode Derek Nelson and Usman Masood explain how it is architected, strategies for designing your data flows, how to scale it up and out, and edge cases to be aware of. Preamble  Hello and welcome to the Data Engineering Podcast, the show about modern data management 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 Linode. With 200Gbit private networking, scalable shared block storage, and a 40Gbit public network, you’ve got everything you need to run a fast, reliable, and bullet-proof data platform. If you need global distribution, they’ve got that covered too with world-wide datacenters including new ones in Toronto and Mumbai. Go to dataengineeringpodcast.com/linode today to get a $20 credit and launch a new server in under a minute. Go to dataengineeringpodcast.com to subscribe to the show, sign up for the mailing list, read the show notes, and get in touch. Join the community in the new Zulip chat workspace at dataengineeringpodcast.com/chat Your host is Tobias Macey and today I’m interviewing Usman Masood and Derek Nelson about PipelineDB, an open source continuous query engine for PostgreSQL  Interview  Introduction How did you get involved in the area of data management? Can you start by explaining what PipelineDB is and the motivation for creating it?  What are the major use cases that it enables? What are some example applications that are uniquely well suited to the capabilities of PipelineDB?   What are the major concepts and components that users of PipelineDB should be familiar with? Given the fact that it is a plugin for PostgreSQL, what level of compatibility exists between PipelineDB and other plugins such as Timescale and Citus? What are some of the common patterns for populating data streams? What are the options for scaling PipelineDB systems, both vertically and horizontally?  How much elasticity does the system support in terms of changing volumes of inbound data? What are some of the limitations or edge cases that users should be aware of?   Given that inbound data is not persisted to disk, how do you guard against data loss?  Is it possible to archive the data in a stream, unaltered, to a separate destination table or other storage location? Can a separate table be used as an input stream?   Since the data being processed by the continuous queries is potentially unbounded, how do you approach checkpointing or windowing the data in the continuous views? What are some of the features that you have found to be the most useful which users might initially overlook? What would be involved in generating an alert or notification on an aggregate output that was in some way anomalous? What are some of the most challenging aspects of building continuous aggregates on unbounded data? What have you found to be some of the most interesting, complex, or challenging aspects of building and maintaining PipelineDB? What are some of the most interesting or unexpected ways that you have seen PipelineDB used? When is PipelineDB the wrong choice? What do you have planned for the future of PipelineDB now that you have hit the 1.0 milestone?  Contact Info  Derek  derekjn on GitHub LinkedIn   Usman  @usmanm on Twitter Website    Parting Question  From your perspective, what is the biggest gap in the tooling or technology for data management today?  Links  PipelineDB Stride PostgreSQL  Podcast Episode   AdRoll Probabilistic Data Structures TimescaleDB  [Podcast Episode](   Hive Redshift Kafka Kinesis ZeroMQ Nanomsg HyperLogLog Bloom Filter  The intro and outro music is from The Hug by The Freak Fandango Orchestra  / CC BY-SASupport Data Engineering Podcast

<h2>Summary</h2> <p>Processing high velocity time-series data in real-time is a complex challenge. The team at PipelineDB has built a continuous query engine that simplifies the task of computing aggregates across incoming streams of events. In this episode Derek Nelson and Usman Masood explain how it is architected, strategies for designing your data flows, how to scale it up and out, and edge cases to be aware of.</p> <h2>Preamble</h2> <ul> <li>Hello and welcome to the Data Engineering Podcast, the show about modern data management</li> <li>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 Linode. With 200Gbit private networking, scalable shared block storage, and a 40Gbit public network, you’ve got everything you need to run a fast, reliable, and bullet-proof data platform. If you need global distribution, they’ve got that covered too with world-wide datacenters including new ones in Toronto and Mumbai. Go to <a href="https://www.dataengineeringpodcast.com/linode?utm_source=rss&amp;utm_medium=rss" rel="nofollow" target="_blank">dataengineeringpodcast.com/linode</a> today to get a $20 credit and launch a new server in under a minute.</li> <li>Go to <a href="https://www.dataengineeringpodcast.com?utm_source=rss&amp;utm_medium=rss" rel="nofollow" target="_blank">dataengineeringpodcast.com</a> to subscribe to the show, sign up for the mailing list, read the show notes, and get in touch.</li> <li>Join the community in the new Zulip chat workspace at <a href="https://www.dataengineeringpodcast.com/chat?utm_source=rss&amp;utm_medium=rss" rel="nofollow" target="_blank">dataengineeringpodcast.com/chat</a></li> <li>Your host is Tobias Macey and today I’m interviewing Usman Masood and Derek Nelson about PipelineDB, an open source continuous query engine for PostgreSQL</li> </ul> <h2>Interview</h2> <ul> <li>Introduction</li> <li>How did you get involved in the area of data management?</li> <li>Can you start by explaining what PipelineDB is and the motivation for creating it? <ul> <li>What are the major use cases that it enables?</li> <li>What are some example applications that are uniquely well suited to the capabilities of PipelineDB?</li> </ul> <p></p></li> <li>What are the major concepts and components that users of PipelineDB should be familiar with?</li> <li>Given the fact that it is a plugin for PostgreSQL, what level of compatibility exists between PipelineDB and other plugins such as Timescale and Citus?</li> <li>What are some of the common patterns for populating data streams?</li> <li>What are the options for scaling PipelineDB systems, both vertically and horizontally?<p></p> <ul> <li>How much elasticity does the system support in terms of changing volumes of inbound data?</li> <li>What are some of the limitations or edge cases that users should be aware of?</li> </ul> <p></p></li> <li>Given that inbound data is not persisted to disk, how do you guard against data loss?<p></p> <ul> <li>Is it possible to archive the data in a stream, unaltered, to a separate destination table or other storage location?</li> <li>Can a separate table be used as an input stream?</li> </ul> <p></p></li> <li>Since the data being processed by the continuous queries is potentially unbounded, how do you approach checkpointing or windowing the data in the continuous views?</li> <li>What are some of the features that you have found to be the most useful which users might initially overlook?</li> <li>What would be involved in generating an alert or notification on an aggregate output that was in some way anomalous?</li> <li>What are some of the most challenging aspects of building continuous aggregates on unbounded data?</li> <li>What have you found to be some of the most interesting, complex, or challenging aspects of building and maintaining PipelineDB?</li> <li>What are some of the most interesting or unexpected ways that you have seen PipelineDB used?</li> <li>When is PipelineDB the wrong choice?</li> <li>What do you have planned for the future of PipelineDB now that you have hit the 1.0 milestone?</li> </ul><p></p> <h2>Contact Info</h2> <ul> <li>Derek <ul> <li><a href="https://github.com/derekjn?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">derekjn</a> on GitHub</li> <li><a href="https://www.linkedin.com/in/derekjn/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">LinkedIn</a></li> </ul> <p></p></li> <li>Usman<p></p> <ul> <li><a href="https://twitter.com/usmanm?lang=en&amp;utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">@usmanm</a> on Twitter</li> <li><a href="http://www.usmanm.com/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Website</a></li> </ul> <p></p></li> </ul><p></p> <h2>Parting Question</h2> <ul> <li>From your perspective, what is the biggest gap in the tooling or technology for data management today?</li> </ul> <h2>Links</h2> <ul> <li><a href="https://www.pipelinedb.com/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">PipelineDB</a></li> <li><a href="https://www.stride.io/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Stride</a></li> <li><a href="https://www.postgresql.org/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">PostgreSQL</a> <ul> <li><a href="" rel="nofollow" target="_blank">Podcast Episode</a></li> </ul> <p></p></li> <li><a href="https://www.adroll.com/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">AdRoll</a></li> <li><a href="https://en.wikipedia.org/wiki/Category:Probabilistic_data_structures?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Probabilistic Data Structures</a></li> <li><a href="https://www.timescale.com/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">TimescaleDB</a><p></p> <ul> <li>[Podcast Episode](</li> </ul> <p></p></li> <li><a href="https://hive.apache.org/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Hive</a></li> <li><a href="https://aws.amazon.com/redshift/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Redshift</a></li> <li><a href="https://kafka.apache.org/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Kafka</a></li> <li><a href="https://aws.amazon.com/kinesis/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Kinesis</a></li> <li><a href="http://zeromq.org/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">ZeroMQ</a></li> <li><a href="https://nanomsg.org/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Nanomsg</a></li> <li><a href="https://en.wikipedia.org/wiki/HyperLogLog?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">HyperLogLog</a></li> <li><a href="https://en.wikipedia.org/wiki/Bloom_filter?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">Bloom Filter</a></li> </ul><p></p> <p>The intro and outro music is from <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/Love_death_and_a_drunken_monkey/04_-_The_Hug?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">The Hug</a> by <a href="http://freemusicarchive.org/music/The_Freak_Fandango_Orchestra/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">The Freak Fandango Orchestra</a>  / <a href="http://creativecommons.org/licenses/by-sa/3.0/?utm_source=rss&amp;utm_medium=rss" rel="noopener nofollow" target="_blank">CC BY-SA</a></p><p><a href="https://dataengineering.supercast.com/" rel="payment nofollow" target="_blank">Support Data Engineering Podcast</a></p>

Continuously Query Your Time-Series Data Using PipelineDB with Derek Nelson and Usman Masood - Episode 62