Coral8 provides a custom language dedicated to event stream processing/complex event processing class/continuous intelligence. As clichéd as it may be, Coral8's strength is also its weakness, in that once you start working in ccl, you give up all the tools ( compilers, code generators, static analysis...

Over the winter break I wanted to learn more about a few technologies:   T4 - the built into Visual Studio code generation tool The Kdb+ columnar database Expression trees   The result ended up in a Linq to Kdb+ query provider. The following snippet translates to using (IConnection connection...

In the first post on integrating PowerShell and Coral8 I showed how to create a message sink. In C#ish pseudocode we did the following: OutputStream<T> => Action<T> where the Action<T> was a PowerShell block to send a message via GMail. Today the goal is to do a transform, something...

Via Jafar Husain - it appears that there’s a early release of the Live Labs Reactive Framework (& with Brian Beckman and Erik Meijer ) in the latest Silverlight Toolkit   In addition to some of the standard LINQ operators ( Select, Where, Aggregate ), some new operators look quite promising ...

Talk around the water cooler is that it might be possible to use the Reactive Framework for some lightweight CEP. I’ll correct some of the (big) mistakes from my last post and build up a “jumping” window extension method for IObservable s.   In my last post I build a simple grouping method, but...

One compelling feature of StreamInsight is it’s in-process hosting model. In addition to reducing the complexity of server side installs, it’s now possible to have a  CEP engine in the client UI. The simplest way of getting CEP streams onto the UI would be the Reactive Framework methods. Something...

In my last post I showed how to send StreamInsight output streams to a UI via the ReactiveFramework . Here’s we’ll do the reverse, by sending an RX stream into a CEP stream. Instead of a partial example, I’ll use an end to end example showing simulated stock ticks, computing the 5 min rolling VWAP ,...

The bug I mentioned in my first attempt at a sliding window was the minor issue that the aggegates never went down to 0, even if the window had emptied out. The problem line of code was cur.GroupBy(tsst => tsst.Value.Symbol) – if the window is empty, there is nothing to group – and as a result the...

Streaming OLAP is something that comes up over and over again in the “CEP space” – using the Reactive Extensions for .Net this demo shows the basics; filtering, grouping, aggregates, and concurrent queries. To set the context, the idea here is focus on the “query” side, so the UI is aggressively simple...

Recently my building has been having issues with its boilers, and the heat has been going out for longer than is comfortable. The superintendent that makes a habit of periodically checking on the status of each of the boilers. A workable approach certainly, but figured this would be ideal for a technology...