19 instantiations of FixedSizeQueue
Microsoft.ML.Core (1)
Utilities\FixedSizeQueue.cs (1)
143var q = new FixedSizeQueue<T>(Capacity);
Microsoft.ML.TimeSeries (17)
AdaptiveSingularSpectrumSequenceModeler.cs (4)
268_buffer = new FixedSizeQueue<Single>(seriesLength); 677FixedSizeQueue<Single> window = new FixedSizeQueue<float>(tMat.WindowSize - 1); 768FixedSizeQueue<Single> window = new FixedSizeQueue<float>(tMat.WindowSize - 1); 1452var lastCol = new FixedSizeQueue<Single>(_windowSize - 1);
SequentialAnomalyDetectionTransformBase.cs (3)
663LogMartingaleUpdateBuffer = new FixedSizeQueue<Double>(WindowSize == 0 ? 1 : WindowSize); 665LogMartingaleUpdateBuffer = new FixedSizeQueue<Double>(1); 667RawScoreBuffer = new FixedSizeQueue<float>(WindowSize == 0 ? 1 : WindowSize);
SequentialTransformBase.cs (4)
126WindowedBuffer = (WindowSize > 0) ? new FixedSizeQueue<TInput>(WindowSize) : new FixedSizeQueue<TInput>(1); 127InitialWindowedBuffer = (InitialWindowSize > 0) ? new FixedSizeQueue<TInput>(InitialWindowSize) : new FixedSizeQueue<TInput>(1);
SequentialTransformerBase.cs (4)
108WindowedBuffer = (WindowSize > 0) ? new FixedSizeQueue<TInput>(WindowSize) : new FixedSizeQueue<TInput>(1); 109InitialWindowedBuffer = (InitialWindowSize > 0) ? new FixedSizeQueue<TInput>(InitialWindowSize) : new FixedSizeQueue<TInput>(1);
TimeSeriesUtils.cs (2)
32var q = new FixedSizeQueue<Single>(capacity); 61var q = new FixedSizeQueue<double>(capacity);
Microsoft.ML.Transforms (1)
Text\NgramUtils.cs (1)
59_queue = new FixedSizeQueue<uint>(_ngramLength + _skipLength);
55 references to FixedSizeQueue
Microsoft.ML.Core (2)
Utilities\FixedSizeQueue.cs (2)
141public FixedSizeQueue<T> Clone() 143var q = new FixedSizeQueue<T>(Capacity);
Microsoft.ML.TimeSeries (52)
AdaptiveSingularSpectrumSequenceModeler.cs (5)
149private readonly FixedSizeQueue<Single> _buffer; 677FixedSizeQueue<Single> window = new FixedSizeQueue<float>(tMat.WindowSize - 1); 768FixedSizeQueue<Single> window = new FixedSizeQueue<float>(tMat.WindowSize - 1); 1166internal override void Train(FixedSizeQueue<Single> data) 1452var lastCol = new FixedSizeQueue<Single>(_windowSize - 1);
ExponentialAverageTransform.cs (2)
117private protected override void TransformCore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration, ref Single output) 136private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data)
IidAnomalyDetectionBase.cs (2)
178private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data) 188private protected override double ComputeRawAnomalyScore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration)
MovingAverageTransform.cs (5)
115private static Single ComputeMovingAverageUniformInitialisation(FixedSizeQueue<Single> others, Single input, int lag, 145internal static Single ComputeMovingAverageNonUniform(FixedSizeQueue<Single> others, Single input, Single[] weights, int lag) 180internal static Single ComputeMovingAverageUniform(FixedSizeQueue<Single> others, Single input, int lag, 276private protected override void TransformCore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration, ref Single output) 292private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data)
PercentileThresholdTransform.cs (3)
103internal static void CountGreaterOrEqualValues(FixedSizeQueue<Single> others, Single theValue, out int greaterVals, out int equalVals, out int totalVals) 137private protected override void TransformCore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration, ref bool dst) 152private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data)
PValueTransform.cs (2)
120private protected override void TransformCore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration, ref Single dst) 139private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data)
SequenceModelerBase.cs (1)
46internal abstract void Train(FixedSizeQueue<TInput> data);
SequentialAnomalyDetectionTransformBase.cs (4)
429private FixedSizeQueue<Double> LogMartingaleUpdateBuffer { get; set; } 432private FixedSizeQueue<Single> RawScoreBuffer { get; set; } 522public sealed override void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, ref VBuffer<Double> dst) 688private protected abstract Double ComputeRawAnomalyScore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration);
SequentialTransformBase.cs (4)
82private protected FixedSizeQueue<TInput> WindowedBuffer; 87private protected FixedSizeQueue<TInput> InitialWindowedBuffer; 204private protected abstract void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, ref TOutput dst); 215private protected abstract void LearnStateFromDataCore(FixedSizeQueue<TInput> data);
SequentialTransformerBase.cs (5)
48private protected FixedSizeQueue<TInput> WindowedBuffer { get; set; } 53private protected FixedSizeQueue<TInput> InitialWindowedBuffer { get; set; } 254public virtual void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, ref TOutput dst) 283private protected virtual void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, 301private protected virtual void LearnStateFromDataCore(FixedSizeQueue<TInput> data)
SlidingWindowTransformBase.cs (2)
154private protected override void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, ref VBuffer<TInput> output) 178private protected override void LearnStateFromDataCore(FixedSizeQueue<TInput> data)
SrCnnAnomalyDetectionBase.cs (3)
168private protected override void LearnStateFromDataCore(FixedSizeQueue<float> data) 172private protected sealed override void SpectralResidual(Single input, FixedSizeQueue<Single> data, ref VBufferEditor<double> result) 242private List<Single> BackAdd(FixedSizeQueue<Single> data)
SrCnnTransformBase.cs (3)
295public sealed override void TransformCore(ref TInput input, FixedSizeQueue<TInput> windowedBuffer, long iteration, ref VBuffer<double> dst) 312private protected override void LearnStateFromDataCore(FixedSizeQueue<TInput> data) 316private protected virtual void SpectralResidual(TInput input, FixedSizeQueue<TInput> data, ref VBufferEditor<double> result)
SsaAnomalyDetectionBase.cs (2)
330private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data) 341private protected override double ComputeRawAnomalyScore(ref Single input, FixedSizeQueue<Single> windowedBuffer, long iteration)
SsaForecastingBase.cs (3)
248private protected override void LearnStateFromDataCore(FixedSizeQueue<Single> data) 259public override void TransformCore(ref float input, FixedSizeQueue<float> windowedBuffer, long iteration, ref VBuffer<float> dst) 270private protected override void TransformCore(ref float input, FixedSizeQueue<float> windowedBuffer, long iteration,
TimeSeriesUtils.cs (6)
14internal static void SerializeFixedSizeQueue(FixedSizeQueue<Single> queue, BinaryWriter writer) 26internal static FixedSizeQueue<Single> DeserializeFixedSizeQueueSingle(BinaryReader reader, IHost host) 32var q = new FixedSizeQueue<Single>(capacity); 43internal static void SerializeFixedSizeQueue(FixedSizeQueue<double> queue, BinaryWriter writer) 55internal static FixedSizeQueue<double> DeserializeFixedSizeQueueDouble(BinaryReader reader, IHost host) 61var q = new FixedSizeQueue<double>(capacity);
Microsoft.ML.Transforms (1)
Text\NgramUtils.cs (1)
32private readonly FixedSizeQueue<uint> _queue;