Taming Hopping Windows

At first glance, hopping windows seem fairly innocuous and obvious. They organize events into windows with a simple periodic definition: the windows have some duration d (e.g. a window covers 5 second time intervals), an interval or period p (e.g. a new window starts every 2 seconds) and an alignment a (e.g. one of those…


Time in StreamInsight (III)

Part 3: Synchronizing Streams in Time This post deals with the problem of timeliness of results for a query with multiple input steams. So far we have seen what considerations need to be made to advance time for a single input stream. The semantics of the binary operators Join and Union are such that they release events when both…


Time in StreamInsight (II)

Part 2: Advancing Time in a Stream The purpose of this post is to highlight some common cases where declaratively specifying settings for advancing time makes sense. You can also take a look at the product documentation: http://msdn.microsoft.com/en-us/library/ff518502.aspx. It provides some useful background for this discussion. As you probably know by now, every StreamInsight computation…

2

Time in StreamInsight (I)

Part 1: Assigning Timestamps to Events After having used the blog mainly for announcements, we’d like to get down to the real business and start posting more technical articles that will explore many different aspects of the framework. Let’s start with time, since this is a central concept in any event processing system. StreamInsight reasons…