StreamInsight 2.1 Released

The wait is over—we are pleased to announce the release of StreamInsight 2.1. Since the release of version 1.2, we have heard your feedbacks and suggestions and based on that we have come up with a whole new set of features. Here are some of the highlights:

  • A New Programming Model – A more clear and consistent object model, eliminating the need for complex input and output adapters (though they are still completely supported). This new model allows you to provision, name, and manage data sources and sinks in the StreamInsight server.
  • Tight integration with Reactive Framework (Rx) – You can write reactive queries hosted inside StreamInsight as well as compose temporal queries on reactive objects.
  • High Availability – Check-pointing over temporal streams and multiple processes with shared computation.

Here is how simple coding can be with the 2.1 Programming Model:

class Program
    static void Main(string[] args)
        using (Server server = Server.Create("Default"))
            // Create an app
            Application app = server.CreateApplication("app");

            // Define a simple observable which generates an integer every second
            var source = app.DefineObservable(() =>

            // Define a sink.
            var sink = app.DefineObserver(() =>
                Observer.Create<long>(x => Console.WriteLine(x)));

            // Define a query to filter the events
            var query = from e in source
                        where e % 2 == 0
                        select e;

            // Bind the query to the sink and create a runnable process
            using (IDisposable proc = query.Bind(sink).Run("MyProcess"))
                Console.WriteLine("Press a key to dispose the process...");


That’s how easily you can define a source, sink and compose a query and run it. Note that we did not replace the existing APIs, they co-exist with the new surface.

Stay tuned, you will see a series of articles coming out over the next few weeks about the new features and how to use them.

Come and grab it from our download center page and let us know what you think! You can find the updated MSDN documentation here, and we would appreciate if you could provide feedback to the docs as well—best via email to

Moreover, we updated our samples to demonstrate the new programming surface.

The StreamInsight Team

Comments (2)
  1. Rick says:


    Does this version have better support for Windows Azure?


  2. Rick, what kind of improved support are you looking for? How do you want to use StreamInsight in Azure?

Comments are closed.

Skip to main content