This is the final part of the deep dive series on understanding internals of Apache Spark Window Functions. In earlier sections, we...

In part 3 , we explored the internal workings of AggregateProcessor and how it evaluates expressions using our rank() window function...

In the previous post, we briefly alluded about AggregateProcessor without going into the depth. In this part, we will focus on its...

This is part 2 of deep dive series on understanding internals of Apache Spark Window Functions. Following our discussion of Spark's rank()...

This is part 1 of deep dive series on understanding internals of Apache Spark Window Functions. Introduction A window function in query...

Today's distributed systems are undoubtedly complex and varied, requiring different data consistency guarantees. Amongst all,...

Data is exploding exponentially and so is the requirement for massively scalable distributed storage systems. A distributed storage...

Background BSON stands for Binary JSON which is a serialization format for binary-encoding JSON-like documents. BSON was developed at...

The change streams by default emits only the delta fields for any update operation, ie. the event with operationType update does not...

Today we are going to explore a very powerful tool in the change streams called the resume token. For motivation purposes, consider, your...

In Part 1 of the series, we saw how to keep a watch on a collection and receive events. This means, that the subscriber receives all the...

MongoDB 3.6 introduced a new feature called change streams. The change streams is a very powerful feature which allows applications to...