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