logoalt Hacker News

orlptoday at 10:18 AM2 repliesview on HN

Streaming here has a different meaning than perhaps what you're used to. It's not referring to online processing where you maintain aggregates/state while an endless stream of data comes in.

The name was chosen early on to contrast with the old execution model, which was essentially all-data-in-memory, column-at-a-time. That engine still exists, we use it as a fallback mechanism for things that aren't supported yet in the new engine (or if you explicitly ask for `engine="in-memory"`).

The new execution model first constructs a computational graph of nodes which communicate in streams of in-cache batches (morsels) of data, meaning the full dataset will never be held in memory if not necessary. This was called the streaming engine for that reason in an early prototype and the name stuck. In hindsight I do admit the naming choice is somewhat confusing.


Replies

sanderjdtoday at 2:23 PM

When you say "in-cache batches", you mean that this cache is on disk? Is that only the case when data is quite large?

(Or a more general question: What is the best resource for me to read about how the streaming engine and cache work?)

show 1 reply
arn3ntoday at 10:37 AM

Cool, thanks for the explanation!