path # lines of code number of updates days since first update days since last update first updated last updated Sources/CommonAssemblyInfo.cs 10 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Directory.Build.props 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing.Provider/Core/Binary.cs 60 3 939 915 2019-07-07 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Core/Temporal.cs 60 3 939 915 2019-07-07 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Core/Unary.cs 45 2 939 915 2019-07-07 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Extensions/GroupBy.cs 16 2 916 915 2019-07-30 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Extensions/Join.cs 10 2 916 915 2019-07-30 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Extensions/Linq.cs 32 2 939 915 2019-07-07 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Extensions/Windowing.cs 10 2 916 915 2019-07-30 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/IGroupedWindow.cs 9 3 1041 1006 2019-03-27 2019-05-01 Sources/Core/Microsoft.StreamProcessing.Provider/IQStreamable.cs 11 6 1041 915 2019-03-27 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/IQStreamableProvider.cs 10 3 1041 1006 2019-03-27 2019-05-01 Sources/Core/Microsoft.StreamProcessing.Provider/IWindow.cs 8 3 1041 1006 2019-03-27 2019-05-01 Sources/Core/Microsoft.StreamProcessing.Provider/QStreamable.cs 18 6 1041 915 2019-03-27 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/QStreamableProviderBase.cs 12 3 1041 1006 2019-03-27 2019-05-01 Sources/Core/Microsoft.StreamProcessing.Provider/QStreamableVisitor.cs 64 8 1041 914 2019-03-27 2019-08-01 Sources/Core/Microsoft.StreamProcessing.Provider/QueryContext.cs 36 3 950 915 2019-06-26 2019-07-31 Sources/Core/Microsoft.StreamProcessing.Provider/Tests.cs 35 3 950 915 2019-06-26 2019-07-31 Sources/Core/Microsoft.StreamProcessing/Aggregates/AggregateFunctions.cs 242 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/AggregateFunctionsTemplate.cs 3706 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/AggregateTemplates.cs 1 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Aggregates/AverageAggregateTemplate.cs 549 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/AverageSquareAggregateTemplate.cs 540 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/CountAggregate.cs 21 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/DiscriminatedAggregate.cs 40 2 978 972 2019-05-29 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/GeneratedAggregate.cs 57 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/IAggregate.cs 26 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/IBinaryAggregate.cs 15 2 978 972 2019-05-29 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/ListAggregateBase.cs 32 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Aggregates/MinMaxAggregate.cs 55 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/MinMaxState.cs 20 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Aggregates/PercentileContinuous.cs 42 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/PercentileDiscrete.cs 33 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/ProductAggregateTemplate.cs 176 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/SingleOrDefaultAggregate.cs 12 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMaxAggregate.cs 80 3 1004 972 2019-05-03 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/SlidingMinAggregate.cs 80 3 1004 972 2019-05-03 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/SortedMultisetAggregateBase.cs 34 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/StatisticalAggregate.cs 45 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Aggregates/SumAggregateTemplate.cs 176 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/SumSquareAggregateTemplate.cs 176 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/TopKAggregate.cs 70 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Aggregates/TumblingMaxAggregate.cs 50 10 1004 810 2019-05-03 2019-11-13 Sources/Core/Microsoft.StreamProcessing/Aggregates/TumblingMinAggregate.cs 50 8 1004 810 2019-05-03 2019-11-13 Sources/Core/Microsoft.StreamProcessing/CacheUtilities/StreamableIO.cs 212 4 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Collections/CacheKey.cs 140 7 1147 832 2018-12-11 2019-10-22 Sources/Core/Microsoft.StreamProcessing/Collections/CircularBuffer.cs 159 5 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Collections/ColumnBatch.cs 100 4 1147 992 2018-12-11 2019-05-15 Sources/Core/Microsoft.StreamProcessing/Collections/ColumnPool.cs 69 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/DataStructurePool.cs 46 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Collections/DoublingArrayPool.cs 85 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Collections/EndPointHeap.cs 201 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Collections/EndPointQueue.cs 211 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/FastDictionary.cs 139 7 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/FastDictionary2.cs 260 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/FastDictionary3.cs 167 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/FastLinkedList.cs 250 6 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Collections/FastMap.cs 508 7 1147 347 2018-12-11 2021-02-18 Sources/Core/Microsoft.StreamProcessing/Collections/FastStack.cs 66 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Collections/GlobalColumnPoolManager.cs 162 8 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/HashHelpers.cs 95 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/IEndPointOrderer.cs 29 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Collections/MemoryPool.cs 87 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/MultiSet.cs 64 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Collections/PooledCircularBuffer.cs 185 5 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Collections/PrimeFuncs.cs 34 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Collections/PriorityQueue.cs 92 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Collections/RemovableEndPointHeap.cs 314 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Collections/SafeConcurrentDictionary.cs 31 5 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Collections/SortedMultiSet.cs 164 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Collections/StreamMessage.cs 769 11 1147 902 2018-12-11 2019-08-13 Sources/Core/Microsoft.StreamProcessing/Collections/StreamMessagePoolColumnar.cs 53 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/CompoundGroupKeyComparer.cs 77 3 1147 1096 2018-12-11 2019-01-31 Sources/Core/Microsoft.StreamProcessing/CompoundPayloads.cs 68 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgress.cs 30 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressObservable.cs 54 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/Atemporal/AtemporalEgressPipe.cs 104 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalArray/AtemporalArrayEgress.cs 55 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalArray/AtemporalArrayEgressObservable.cs 32 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalArray/AtemporalArrayEgressPipe.cs 114 3 1147 1144 2018-12-11 2018-12-14 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/AtemporalEnumerableEgress.cs 27 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/AtemporalEnumerableEgressPipe.cs 88 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/ChangeListEvent.cs 13 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/ChangeListEventKind.cs 11 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/ChangeListEventStatic.cs 23 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/AtemporalEnumerable/EvolvingStateEnumerable.cs 105 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/Binary/BinaryEgress.cs 70 5 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Egress/Binary/BinaryStreamObserver.cs 36 5 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Egress/EgressBoundary.cs 51 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Egress/EgressPlanNode.cs 30 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Egress/ReshapingPolicy.cs 9 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/StreamMessage/StreamMessageEgress.cs 23 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/StreamMessage/StreamMessageEgressObservable.cs 29 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/StreamMessage/StreamMessageEgressPipe.cs 18 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgress.cs 238 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressObservable.cs 352 4 1147 832 2018-12-11 2019-10-22 Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressPipe.cs 201 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/Temporal/TemporalEgressTransformer.cs 240 10 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgress.cs 357 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressObservable.cs 197 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressPipe.cs 393 3 1147 1144 2018-12-11 2018-12-14 Sources/Core/Microsoft.StreamProcessing/Egress/TemporalArray/TemporalArrayEgressTransformer.cs 306 10 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Events/StreamEvent.cs 170 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Events/StreamEventKind.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Events/StreamEventStatic.cs 101 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Exceptions.cs 25 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Fusible/ExpressionProfile.cs 31 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Fusible/FuseModule.cs 598 8 1147 810 2018-12-11 2019-11-13 Sources/Core/Microsoft.StreamProcessing/Fusible/FusedObservable.cs 79 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Fusible/FusedObservablePipe.cs 45 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Fusible/FusedPlanNode.cs 26 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Fusible/IFusibleStreamable.cs 24 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/IStreamObserver.cs 80 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Atemporal/AtemporalIngress.cs 62 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Atemporal/AtemporalIngressStreamable.cs 68 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Ingress/Atemporal/AtemporalIngressSubscription.cs 145 2 1147 1091 2018-12-11 2019-02-05 Sources/Core/Microsoft.StreamProcessing/Ingress/AtemporalArray/AtemporalArrayIngress.cs 52 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/AtemporalArray/AtemporalArrayIngressStreamable.cs 62 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Ingress/AtemporalArray/AtemporalArrayIngressSubscription.cs 128 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngress.cs 246 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngressReader.cs 77 8 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngressStreamable.cs 74 6 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/BinaryIngressStreamablePassive.cs 77 5 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Ingress/Binary/StreamableSerializer.cs 46 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/DiagnosticObservable.cs 95 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Ingress/IIngressStreamable.cs 21 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/ImpatienceSorter.cs 511 3 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/DisorderPolicy.cs 50 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/FlushPolicy.cs 19 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/OnCompletedPolicy.cs 10 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/PeriodicLowWatermarkPolicy.cs 54 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/PeriodicPunctuationPolicy.cs 45 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Ingress/Policies/TimelinePolicy.cs 34 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Ingress/StreamMessage/StreamMessageIngress.cs 25 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/StreamMessage/StreamMessageIngressStreamable.cs 38 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/StreamMessage/StreamMessageIngressSubscription.cs 37 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/StreamMessageIngressBase.cs 61 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/SubscriptionBase.cs 1167 12 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngress.cs 432 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressStreamable.cs 2548 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressSubscription.cs 6732 9 1147 837 2018-12-11 2019-10-17 Sources/Core/Microsoft.StreamProcessing/Ingress/Temporal/TemporalIngressTransformer.cs 164 6 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngress.cs 242 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngressStreamable.cs 279 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Ingress/TemporalArray/TemporalArrayIngressSubscription.cs 346 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaDescriptor.cs 129 8 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaInterfaces.cs 51 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaMultiEventListTransformer.cs 165 8 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaPlanNode.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaStreamable.cs 266 5 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaTransformer.cs 183 7 1147 816 2018-12-11 2019-11-07 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/AfaTypes.cs 120 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Arc.cs 75 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledAfa.cs 174 10 1147 486 2018-12-11 2020-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledAfaPipeBase.cs 139 8 1147 916 2018-12-11 2019-07-30 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_EventList.cs 361 7 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_MultiEvent.cs 217 4 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_MultiEventList.cs 517 6 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledGroupedAfaPipe_SingleEvent.cs 335 8 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledPartitionedAfaPipe_EventList.cs 387 8 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledPartitionedAfaPipe_MultiEvent.cs 240 6 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledPartitionedAfaPipe_MultiEventList.cs 542 6 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledPartitionedAfaPipe_SingleEvent.cs 432 7 1147 391 2018-12-11 2021-01-05 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledUngroupedAfaPipe_EventList.cs 291 5 1147 816 2018-12-11 2019-11-07 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledUngroupedAfaPipe_MultiEventList.cs 415 5 1147 816 2018-12-11 2019-11-07 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledUngroupedAfaPipe_SingleEvent.cs 290 6 1147 486 2018-12-11 2020-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/CompiledUngroupedDAfaPipe_SingleEvent.cs 261 6 1147 486 2018-12-11 2020-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/GroupedAfaEventListTransformer.cs 96 6 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/GroupedAfaMultiEventTransformer.cs 141 6 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/GroupedAfaTransformer.cs 84 7 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/PatternMatcher.cs 363 12 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/Regex.cs 424 9 1147 458 2018-12-11 2020-10-30 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/UngroupedAfaTransformer.cs 79 7 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Afa/UngroupedDAfaTransformer.cs 79 7 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeConstantDurationPipe.cs 109 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeConstantDurationStatelessPipe.cs 70 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimePlanNode.cs 24 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeStartDependentDurationPipe.cs 106 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeStartDependentDurationStatelessPipe.cs 66 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeStreamable.cs 114 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/AlterLifetimeVariableDurationPipe.cs 114 3 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeConstantDurationPipe.cs 128 3 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeStartDependentDurationPipe.cs 128 3 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeVariableDurationByKeyPipe.cs 135 4 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Operators/AlterLifetime/PartitionedAlterLifetimeVariableDurationPipe.cs 134 3 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatPipe.cs 378 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatPlanNode.cs 17 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatStreamable.cs 57 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Beat/BeatTransformer.cs 41 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/Beat/PartitionedBeatPipe.cs 402 3 1147 529 2018-12-11 2020-08-20 Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinPipe.cs 372 4 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinStreamable.cs 72 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Clip/ClipJoinTransformer.cs 55 6 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Operators/Clip/PartitionedClipJoinPipe.cs 643 7 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantPipe.cs 150 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantPlanNode.cs 15 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantStreamable.cs 50 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/ClipByConstantTransformer.cs 26 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/ClipByConstant/PartitionedClipByConstantPipe.cs 200 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ColumnToRow/ColumnToRowPlanNode.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/ColumnToRow/ColumnToRowStreamable.cs 27 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/ColumnToRow/ColumnToRowTransformer.cs 50 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/DisjointUnion/DisjointUnionPipe.cs 96 4 1147 754 2018-12-11 2020-01-08 Sources/Core/Microsoft.StreamProcessing/Operators/DisjointUnion/DisjointUnionStreamable.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/EndEdgeFreeOutputPipe.cs 220 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/EndEdgeFreeOutputPlanNode.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/EndEdgeFreeOutputStreamable.cs 62 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/EndEdgeFreeOutputTransformer.cs 48 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/EndEdgeFreeOutput/PartitionedEndEdgeFreeOutputPipe.cs 253 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquiJoinPipe.cs 802 7 1147 990 2018-12-11 2019-05-17 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/EquijoinTransformer.cs 264 7 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipe.cs 1074 9 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeCompound.cs 1091 9 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/Basic/PartitionedEquiJoinPipeSimple.cs 977 9 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/EquiJoinStreamable.cs 167 12 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquiJoinPipe.cs 356 11 1091 880 2019-02-05 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/FixedIntervalEquijoinTransformer.cs 236 11 1091 852 2019-02-05 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipe.cs 616 10 1091 880 2019-02-05 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeCompound.cs 621 10 1091 880 2019-02-05 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/FixedInterval/PartitionedFixedIntervalEquiJoinPipeSimple.cs 582 10 1091 880 2019-02-05 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinPipe.cs 534 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/IncreasingOrder/IncreasingOrderEquiJoinTransformer.cs 176 7 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/PartitionedStartEdgeEquiJoinPipe.cs 547 4 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinPipe.cs 354 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/EquiJoin/StartEdge/StartEdgeEquiJoinTransformer.cs 169 5 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimeNegativePipe.cs 192 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimePipe.cs 140 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimePlanNode.cs 16 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimeStreamable.cs 76 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/ExtendLifetimeTransformer.cs 83 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimeNegativePipe.cs 246 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/ExtendLifetime/PartitionedExtendLifetimePipe.cs 190 4 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupPipe.cs 245 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupPlanNode.cs 47 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupStreamable.cs 148 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Group/GroupTransformer.cs 156 7 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/GroupedWindow/GroupedWindowPipe.cs 315 8 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/GroupedWindow/GroupedWindowPlanNode.cs 31 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/GroupedWindow/GroupedWindowStreamable.cs 55 3 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/GroupedWindow/GroupedWindowTransformer.cs 274 8 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinPipe.cs 638 7 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinStreamable.cs 77 7 1147 1004 2018-12-11 2019-05-03 Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/LeftAntiSemiJoinTransformer.cs 51 6 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/LeftAntiSemiJoin/PartitionedLeftAntiSemiJoinPipe.cs 913 10 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/IMapDefinition.cs 13 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/Map2ReduceStreamable.cs 341 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapDefinition.cs 174 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MapReduceStreamable.cs 293 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/MapReduce/MultiUnionStreamable.cs 64 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/BinaryMulticastStreamable.cs 31 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/ConnectableStreamable.cs 18 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/ConnectableStreamableBase.cs 78 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/DependentStreamable.cs 127 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/IConnectableStreamable.cs 9 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/MulticastPlanNode.cs 25 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/Multicast/MulticastStreamable.cs 35 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Partition/PartitionPipe.cs 80 5 1147 1096 2018-12-11 2019-01-31 Sources/Core/Microsoft.StreamProcessing/Operators/Partition/PartitionPlanNode.cs 40 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Partition/PartitionStreamable.cs 35 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PartitionedPointAtEndPipe.cs 168 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndPipe.cs 125 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndPlanNode.cs 15 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndStreamable.cs 57 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/PointAtEndTransformer.cs 26 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/PointAtEnd/StatelessPointAtEndPipe.cs 72 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/PartitionedQuantizeLifetimePipe.cs 199 5 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimePipe.cs 152 5 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimePlanNode.cs 24 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimeStreamable.cs 55 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/QuantizeLifetimeTransformer.cs 26 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/QuantizeLifetime/StatelessQuantizeLifetimePipe.cs 77 5 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/RowToColumn/RowToColumnPlanNode.cs 12 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/RowToColumn/RowToColumnStreamable.cs 31 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/RowToColumn/RowToColumnTransformer.cs 34 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectPipe.cs 223 3 1147 1096 2018-12-11 2019-01-31 Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectPlanNode.cs 24 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectStreamable.cs 64 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/Select/SelectTransformer.cs 123 8 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPipe.cs 438 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyPlanNode.cs 23 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyStreamable.cs 62 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/SelectMany/SelectManyTransformer.cs 150 8 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/PartitionedSessionWindowPipe.cs 260 4 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowPipe.cs 225 6 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowPipeStateless.cs 131 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowPlanNode.cs 20 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowStreamable.cs 56 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/SessionWindow/SessionWindowTransformer.cs 26 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShufflePipe.cs 989 3 1147 1096 2018-12-11 2019-01-31 Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShuffleStreamable.cs 375 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Shuffle/ShuffleTransformer.cs 144 7 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Shufflecast/ShufflecastPipe.cs 183 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Shufflecast/ShufflecastStreamable.cs 62 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/AggregateTempateClasses.cs 300 10 1147 992 2018-12-11 2019-05-15 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipe.cs 398 9 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/PartitionedSnapshotWindowHoppingPipeSimple.cs 325 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipe.cs 317 8 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Hopping/SnapshotWindowHoppingPipeSimple.cs 255 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/PartitionedSnapshotWindowPriorityQueuePipe.cs 368 9 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/PartitionedSnapshotWindowPriorityQueuePipeSimple.cs 321 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/SnapshotWindowPriorityQueuePipe.cs 304 8 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/PriorityQueue/SnapshotWindowPriorityQueuePipeSimple.cs 250 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipe.cs 396 9 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/PartitionedSnapshotWindowSlidingPipeSimple.cs 323 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipe.cs 316 8 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Sliding/SnapshotWindowSlidingPipeSimple.cs 254 7 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/SnapshotWindowPlanNode.cs 26 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/SnapshotWindowStreamable.cs 346 8 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/PartitionedSnapshotWindowStartEdgePipe.cs 242 8 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/PartitionedSnapshotWindowStartEdgePipeSimple.cs 222 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/SnapshotWindowStartEdgePipe.cs 196 8 1147 188 2018-12-11 2021-07-27 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/StartEdge/SnapshotWindowStartEdgePipeSimple.cs 166 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipe.cs 249 9 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/PartitionedSnapshotWindowTumblingPipeSimple.cs 238 6 1147 992 2018-12-11 2019-05-15 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipe.cs 171 8 1147 992 2018-12-11 2019-05-15 Sources/Core/Microsoft.StreamProcessing/Operators/SnapshotWindow/Tumbling/SnapshotWindowTumblingPipeSimple.cs 166 7 1147 782 2018-12-11 2019-12-11 Sources/Core/Microsoft.StreamProcessing/Operators/SprayGroupImport/SparyGroupImportPlanNode.cs 24 3 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/SprayGroupImport/SprayGroupImportPipe.cs 133 4 1147 832 2018-12-11 2019-10-22 Sources/Core/Microsoft.StreamProcessing/Operators/SprayGroupImport/SprayGroupImportStreamable.cs 62 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/PartitionedStitchPipe.cs 373 8 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPipe.cs 322 8 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchPlanNode.cs 18 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchStreamable.cs 55 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Stitch/StitchTransformer.cs 52 3 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupPipe.cs 224 3 1147 1096 2018-12-11 2019-01-31 Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupPlanNode.cs 48 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupStreamable.cs 132 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Ungroup/UngroupTransform.cs 140 7 1147 859 2018-12-11 2019-09-25 Sources/Core/Microsoft.StreamProcessing/Operators/Union/PartitionedUnionPipe.cs 375 4 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionPipe.cs 230 4 1147 789 2018-12-11 2019-12-04 Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionPlanNode.cs 13 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionStreamable.cs 43 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Union/UnionTransformer.cs 36 3 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Operators/Where/MultiStringTransforms.cs 324 7 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Operators/Where/WherePipe.cs 60 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Where/WherePlanNode.cs 18 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Where/WhereStreamable.cs 47 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Operators/Where/WhereTransformer.cs 100 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Pipes/BinaryPipe.cs 408 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Pipes/BinaryPlanNode.cs 76 5 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Pipes/Checkpointable.cs 91 1 1014 1014 2019-04-23 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Pipes/Pipe.cs 95 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Pipes/SchemaSerializationAttribute.cs 7 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Pipes/UnaryPipe.cs 19 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Pipes/UnaryPlanNode.cs 41 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/PlanNode.cs 103 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Properties/AssemblyInfo.cs 9 2 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/QueryContainer.cs 230 8 1147 196 2018-12-11 2021-07-19 Sources/Core/Microsoft.StreamProcessing/Scheduler/IScheduler.cs 36 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Scheduler/NullScheduler.cs 13 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Scheduler/ProgressiveScheduler.cs 271 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Serializer/Encoders/BinaryBase.cs 48 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Serializer/Encoders/BinaryDecoder.cs 278 7 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Serializer/Encoders/BinaryEncoder.cs 237 5 1147 1053 2018-12-11 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Serializer/GeneratedSubtypes/FastDictionaryGenerator.cs 142 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Serializer/GeneratedSubtypes/SortedDictionaryGenerator.cs 60 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Serializer/ISurrogate.cs 10 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Serializer/SerializerSettings.cs 47 3 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/ArraySerializer.cs 73 5 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/ClassSerializer.cs 114 8 1147 880 2018-12-11 2019-09-04 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/EnumSerializer.cs 19 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/EnumerableSerializer.cs 190 9 1147 815 2018-12-11 2019-11-08 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/MultidimensionalArraySerializer.cs 153 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/ObjectSerializerBase.cs 23 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/PrimitiveSerializer.cs 151 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/RecordFieldSerializer.cs 51 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/ReflectionSchemaBuilder.cs 157 8 1147 234 2018-12-11 2021-06-11 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/SurrogateSerializer.cs 31 5 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Serializer/Serializers/UnionSerializer.cs 87 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Serializer/StateSerializer.cs 37 5 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Serializer/StreamSerializer.cs 27 2 499 489 2020-09-19 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Sharding/IShardedStreamable.cs 75 3 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Sharding/ShardedStreamCache.cs 86 5 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Sharding/ShardedStreamSerialization.cs 92 8 1147 489 2018-12-11 2020-09-29 Sources/Core/Microsoft.StreamProcessing/Sharding/ShardedStreamable.cs 123 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Sharding/ShardedStreamableExtensions.cs 23 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/StreamProperties/StreamProperties.cs 831 6 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/StreamProperties/StreamPropertiesExtensions.cs 223 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/AfaExtensions.cs 158 9 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/GroupAggregateTemplate.cs 1639 5 1147 989 2018-12-11 2019-05-18 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/LifetimeExtensions.cs 195 9 1147 915 2018-12-11 2019-07-31 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/PatternExtensions.cs 52 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/PivotExtensions.cs 320 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/SelectExtensions.cs 135 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/StreamableExtensions.cs 667 7 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/StreamableExtensionsTemplate.cs 1653 3 1147 1139 2018-12-11 2018-12-19 Sources/Core/Microsoft.StreamProcessing/StreamableAPI/Templates.cs 1 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Streamables/BinaryStreamable.cs 51 3 1147 1004 2018-12-11 2019-05-03 Sources/Core/Microsoft.StreamProcessing/Streamables/IStreamable.cs 11 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Streamables/SetPropertyStreamable.cs 17 2 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Streamables/Streamable.cs 41 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Streamables/UnaryStreamable.cs 31 4 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/StringHandling/CharArrayPool.cs 92 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/StringHandling/CharArrayWrapper.cs 78 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/StringHandling/MultiString.cs 1578 11 1147 700 2018-12-11 2020-03-02 Sources/Core/Microsoft.StreamProcessing/StringHandling/MyStringBuilder.cs 423 5 1147 1014 2018-12-11 2019-04-23 Sources/Core/Microsoft.StreamProcessing/Transformer/CommonBaseTemplate.cs 105 5 1054 972 2019-03-14 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Transformer/CommonBinaryTemplate.cs 78 5 1054 852 2019-03-14 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Transformer/CommonPipeTemplate.cs 30 2 1054 1053 2019-03-14 2019-03-15 Sources/Core/Microsoft.StreamProcessing/Transformer/CommonUnaryTemplate.cs 102 5 1054 852 2019-03-14 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Transformer/EventBatchManager.cs 35 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Transformer/SelectTransformation.cs 549 12 1147 852 2018-12-11 2019-10-02 Sources/Core/Microsoft.StreamProcessing/Transformer/TemplateClasses.cs 645 18 1147 196 2018-12-11 2021-07-19 Sources/Core/Microsoft.StreamProcessing/Utilities/CallInlinerTemplate.cs 45 3 1147 1057 2018-12-11 2019-03-11 Sources/Core/Microsoft.StreamProcessing/Utilities/ComparerExpression.cs 200 8 1147 726 2018-12-11 2020-02-05 Sources/Core/Microsoft.StreamProcessing/Utilities/ComparerExpressionExtensions.cs 20 3 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Utilities/ComparerExtensions.cs 72 3 1147 1061 2018-12-11 2019-03-07 Sources/Core/Microsoft.StreamProcessing/Utilities/Config.cs 583 7 1147 832 2018-12-11 2019-10-22 Sources/Core/Microsoft.StreamProcessing/Utilities/Empty.cs 20 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Utilities/EqualityComparerExpression.cs 414 10 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Utilities/ExpressionExtensions.cs 1248 17 1147 915 2018-12-11 2019-07-31 Sources/Core/Microsoft.StreamProcessing/Utilities/Native32.cs 90 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Utilities/RxReplacements.cs 59 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Utilities/StructTupleTemplate.cs 794 4 1147 986 2018-12-11 2019-05-21 Sources/Core/Microsoft.StreamProcessing/Utilities/Templates.cs 1 1 1147 1147 2018-12-11 2018-12-11 Sources/Core/Microsoft.StreamProcessing/Utilities/TransformerExtensions.cs 99 9 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Utilities/TypeExtensions.cs 529 11 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Utilities/Utility.cs 168 9 1147 700 2018-12-11 2020-03-02 Sources/Core/Microsoft.StreamProcessing/Windows/FilteredWindowTemplate.cs 170 2 1147 1141 2018-12-11 2018-12-17 Sources/Core/Microsoft.StreamProcessing/Windows/Window.cs 188 6 1147 972 2018-12-11 2019-06-04 Sources/Core/Microsoft.StreamProcessing/Windows/WindowTemplate.cs 791 2 1147 1141 2018-12-11 2018-12-17 Sources/Directory.Build.props 31 4 1147 914 2018-12-11 2019-08-01 azure-pipelines.yml 39 3 1139 426 2018-12-19 2020-12-01