【原创】StreamInsight查询系列（十）——基本查询操作之联接
上篇博文介绍了StreamInsight基础查询操作中的决胜排序部分。这篇文章将主要介绍如何StreamInsight基本查询的最后一篇——联接。 测试数据准备 为了方便测试查询，我们首先准备一些静态的测试数据源。如下input1和input2是一个包含时间戳和[1,5]区间数字的复杂事件流：/
http://cyqdata.cn/cnblogs/article-detail-52655
【原创】StreamInsight查询系列（九）——基本查询操作之决胜排序
上篇博文介绍了StreamInsight基础查询操作中的分组排序部分。这篇文章将主要介绍如何StreamInsight查询中的决胜排序（Ranking and Tiebreaking）。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var sourceData = new[]
{
new
http://cyqdata.cn/cnblogs/article-detail-52602
【原创】StreamInsight查询系列（八）——基本查询操作之分组排序
上篇博文介绍了StreamInsight基础查询操作中的基础排序部分。这篇文章将主要介绍如何StreamInsight查询中的分组排序（TopK）。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var weatherData = new[]
{
new { Timestamp = new
http://cyqdata.cn/cnblogs/article-detail-52551
【原创】StreamInsight查询系列（六）——基本查询操作之分组聚合
上篇博文介绍了StreamInsight基础查询操作中的用户自定义聚合部分。这篇文章将主要介绍如何在StreamInsight查询中使用分组聚合。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var weatherData = new[]
{
new { Timestamp = new D
http://cyqdata.cn/cnblogs/article-detail-52505
【原创】StreamInsight查询系列（五）——基本查询操作之用户自定义聚合
上篇博文介绍了StreamInsight基础查询操作中的聚合部分。这篇文章将主要介绍如何在StreamInsight查询中使用用户自定义聚合。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var weatherData = new[]
{
new { Timestamp = new Dat
http://cyqdata.cn/cnblogs/article-detail-52485
【原创】StreamInsight查询系列（四）——基本查询操作之聚合
上篇博文介绍了StreamInsight基础查询操作中的过滤部分。这篇文章将主要介绍StreamInsight基础查询操作中的聚合部分。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var weatherData = new[]
{
new { Timestamp = new DateTi
http://cyqdata.cn/cnblogs/article-detail-52465
【原创】StreamInsight查询系列（三）——基本查询操作之过滤
上篇博文介绍了如何在LINQPad中输出StreamInsight查询结果。这篇文章将主要介绍StreamInsight基础查询操作中的过滤部分。 测试数据准备 为了方便测试查询，我们首先准备一个静态的测试数据源：var weatherData = new[]
{
new { Timestamp = new
http://cyqdata.cn/cnblogs/article-detail-52444
基本查询操作 (LINQ)
本主题简要介绍 LINQ 查询表达式，以及您在查询中执行的一些典型类型的操作。下面各主题中提供了更详细的信息：
获取数据源
在 LINQ 查询中，第一步是指定数据源。像在大多数编程语言中一样，在 C# 中，必须先声明变量，才能使用它。在 LINQ 查询中，最先使用 from 子句的目的是引入数据源 (customers) 和范围变量 (cust)。
//queryAllCustomers is
http://cyqdata.cn/cnblogs/article-detail-40186