StreamInsight 2.1 Released

  • Article

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(() =>

                 Observable.Interval(TimeSpan.FromSeconds(1)));

 

             // 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...");

                 Console.ReadKey();

             }

         }

     }

 }

 

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 garye@microsoft.com.

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

Regards,
The StreamInsight Team