modules/platforms/dotnet/Apache.Ignite.BenchmarkDotNet/DataStreamer/DataStreamerBenchmark.cs

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

namespace Apache.Ignite.BenchmarkDotNet.DataStreamer
{
    using System;
    using Apache.Ignite.Core;
    using Apache.Ignite.Core.Cache;
    using global::BenchmarkDotNet.Attributes;

    /// <summary>
    /// Data streamer benchmark.
    /// <para />
    /// Results on Core i7-9700K, Ubuntu 20.04, .NET Core 5.0.5:
    /// |                 Method |     Mean |   Error |  StdDev | Ratio | RatioSD |
    /// |----------------------- |---------:|--------:|--------:|------:|--------:|
    /// |               Streamer | 182.6 ms | 3.60 ms | 5.05 ms |  1.00 |    0.00 |
    /// | StreamerAllowOverwrite | 192.1 ms | 3.82 ms | 4.54 ms |  1.05 |    0.04 |
    /// </summary>
    public class DataStreamerBenchmark
    {
        /** */
        private const int EntryCount = 90000;

        /** */
        private IIgnite Client { get; set; }

        /** */
        private ICache<int, Guid> Cache { get; set; }

        /// <summary>
        /// Sets up the benchmark.
        /// </summary>
        [GlobalSetup]
        public void GlobalSetup()
        {
            var cfg = new IgniteConfiguration(Utils.GetIgniteConfiguration())
            {
                AutoGenerateIgniteInstanceName = true
            };

            Ignition.Start(cfg);
            Ignition.Start(cfg);
            Client = Ignition.Start(new IgniteConfiguration(cfg) {ClientMode = true});

            Cache = Client.CreateCache<int, Guid>("c");
        }

        /// <summary>
        /// Cleans up the benchmark.
        /// </summary>
        [GlobalCleanup]
        public void GlobalCleanup()
        {
            Ignition.StopAll(true);
        }

        /// <summary>
        /// Streamer benchmark.
        /// </summary>
        [Benchmark(Baseline = true)]
        public void Streamer()
        {
            StreamData(false);
        }

        /// <summary>
        /// Streamer benchmark.
        /// </summary>
        [Benchmark]
        public void StreamerAllowOverwrite()
        {
            StreamData(true);
        }

        /** */
        private void StreamData(bool allowOverwrite)
        {
            Cache.Clear();

            using (var streamer = Client.GetDataStreamer<int, Guid>(Cache.Name))
            {
                streamer.AllowOverwrite = allowOverwrite;

                for (var i = 0; i < EntryCount; i++)
                {
                    streamer.Add(i, Guid.NewGuid());
                }
            }
        }
    }
}