Continuous LINQ

Source code checked in, #14267

DotNetAddict — Tue, 08 Jul 2008 16:55:42 GMT

Created property changed event manager for all property changes... first step in huge refactor.

Source code checked in, #14237

dochsu — Mon, 07 Jul 2008 23:16:21 GMT

- Add support for Except.

Source code checked in, #14234

dochsu — Mon, 07 Jul 2008 21:30:06 GMT

- Initial Except checkin

Source code checked in, #14230

dochsu — Mon, 07 Jul 2008 18:55:43 GMT

- Add unit tests for ContinuousSum and ContinuousCount.

Source code checked in, #14229

dochsu — Mon, 07 Jul 2008 18:33:06 GMT

- Add unit tests.

Source code checked in, #14226

dochsu — Mon, 07 Jul 2008 18:24:25 GMT

- Remove Trace statements. - Add bindings...

Source code checked in, #13970

DotNetAddict — Mon, 30 Jun 2008 19:29:36 GMT

First attempt at continuous distinct

UPDATED RELEASE: CLINQ v1.1.0.0 (May 02, 2008)

Fri, 02 May 2008 16:58:08 GMT

This release of CLINQ contains both new features and incremental upgrades to existing functionality. The code has been cleaned up significantly as we've been trimming some of the needless fat from some of the library methods and classes.

New features include the ability to perform [Continuous Aggregation], which allows you to define a continuous query that, instead of returning a set of results, returns a continuously updating continuous value such as a sum, min, max, average, or even standard deviation.

We have also created a new demo application for this version of CLINQ called "Stock Monitor", which simulates looking at ticker data for a particular stock. It shows not only how to do multiple continuous queries based on a single source set, but also shows off the power of continuous aggregates, and even how to create a live, continuous line graph using WPF data binding and CLINQ aggregates!

UPDATED RELEASE: CLINQ v1.1.0.0

Fri, 02 May 2008 16:57:40 GMT

UPDATED RELEASE: CLINQ v1.1.0.0

Fri, 02 May 2008 16:55:04 GMT

UPDATED WIKI: Create Your Own Continuous Aggregate

DotNetAddict — Fri, 02 May 2008 15:13:01 GMT

Creating Your Own Continuous Aggregate

UPDATED WIKI: Continuous Aggregation

DotNetAddict — Fri, 02 May 2008 15:12:43 GMT

Continuous Aggregation

Continuous Aggregation is the act of taking a continuous collection, or any other ObservableCollection, for that matter, and continuously updating a scalar value that is some kind of aggregation of that collection. For example, let's say you have a collection of Customers and you want to have a value on your WPF GUI that is a constantly updating number showing the sum of the customer ages. It could also be more complicated and show the sum total of all orders purchased by a subset of customers. The possibilities are endless.

The first thing you would do is create your continuous collection, potentially by using a CLINQ query over an observable collection, as shown below:

customersOverThirty = from cust in AllCustomers
                        where cust.Age > 30
                        select cust;

Then you create your continuous value object and invoke one of the aggregation extensions, such as ContinuousSum:

ContinuousValue<int> totalAge = customersOverThirty.ContinuousSum<Customer>(c => c.Age);

If you want to get really fancy, you can even nest/chain continuous aggregations together, as shown here:

ContinuousValue<double> totalPrice = customersOverThirty.ContinuousSum<Customer>(
    c => c.Orders.ContinuousSum<Order>( o => o.Price ));

Now you can safely place this continuous value in your model object, a model singleton, or the datacontext of a WPF window and the WPF GUI will automatically be made aware of the changes to that scalar value!

Click here to see how you can Create Your Own Continuous Aggregate.

Continuous Aggregation should be available in the 1.1.0.0 release - CLINQ v1.1.0.0

Source code checked in

DotNetAddict — Fri, 02 May 2008 14:47:46 GMT

UI Tweaks to Stock monitor Demo

Source code checked in

javaerb — Tue, 29 Apr 2008 15:19:13 GMT

AggregateViewAdapter refactored

Source code checked in

javaerb — Tue, 29 Apr 2008 15:18:41 GMT

dispatcher unused; Equals and GetHashCode do not make a lot of sense for this class

Source code checked in

DotNetAddict — Tue, 29 Apr 2008 12:56:54 GMT

Initial attempt at the stock monitor demo... not ready for "play" yet, but its working. Includes sample user-defined aggregate (Continuous VWAP) as well as binding a polyline to a continuous collection :)

Source code checked in

javaerb — Mon, 28 Apr 2008 19:47:37 GMT

add some nice object methods

Source code checked in

javaerb — Mon, 28 Apr 2008 19:15:45 GMT

when collection is empty, use default value for aggregate

Source code checked in

javaerb — Mon, 28 Apr 2008 18:54:51 GMT

roll back apparently-unnecessary changes

CLOSED ISSUE: Continuous Aggregation Ceases to work after some number of collection changes

DotNetAddict — Fri, 25 Apr 2008 15:28:34 GMT

This issue is currently showing up in the stock monitor demo and I have had little luck troubleshooting it. After about 9 or so (varies) changes to the source collection, continuous aggregates on that source stop firing notifications. The Weak Collection Changed Event Handler (WCCH) works fine and continues firing over and over without fail... however, that doesn't seem to propogate to the continuous aggregation method, because after X changes, it stops firing.