StreamInsight では、多くのサンプルがストリームのカウント、合計、フィルターの linq の使用法に対応しています。
var cepStream = enumerable.ToPointStream(application, e => PointEvent<Car>.CreateInsert(new DateTimeOffset(e.TimeStamp, TimeSpan.Zero), e), AdvanceTimeSettings.IncreasingStartTime);
var step1 = from e in cepStream
where e.Color == "RedCar"
select e;
特定の時間内に発生したレコードを抽出するクエリを定義するのにいくつかの困難があります。例えば、step1は「レッドカー」というポイントイベントを格納していますが、10分以内に2回連続で発生した「レッドカー」のイベントを抽出するにはどうすればよいでしょうか??
本当にここで立ち往生しており、どんな助けも大歓迎です!!