BulkInserterOptions.cs

Go to the documentation of this file.

using System;
using System.Collections.Generic;

namespace kinetica;

    public sealed class BulkInserterOptions
    {
        public int BatchSize { get; set; } = 10_000;

        public int MaxInFlightBatches { get; set; } = 100;

        public int NumStripes { get; set; } = Environment.ProcessorCount;

        public int MaxFlushWorkers { get; set; } = Math.Max(4, Environment.ProcessorCount * 2);

        public int MaxRetries { get; set; } = 3;

        public int FlushIntervalSeconds { get; set; } = 0;

        public Dictionary<string, string> InsertOptions { get; set; } = new();

        public IBatchInsertionListener? BatchListener { get; set; }

        public Utils.WorkerList? WorkerList { get; set; }

        public int MaxErrorQueueSize { get; set; } = 10_000;

        public int CloseTimeoutMs { get; set; } = 60_000;

        public BulkInserterOptions() { }

        public BulkInserterOptions(int batchSize)
        {
            BatchSize = batchSize;
        }

        public BulkInserterOptions Clone()
        {
            return new BulkInserterOptions
            {
                BatchSize = BatchSize,
                MaxInFlightBatches = MaxInFlightBatches,
                NumStripes = NumStripes,
                MaxFlushWorkers = MaxFlushWorkers,
                MaxRetries = MaxRetries,
                FlushIntervalSeconds = FlushIntervalSeconds,
                InsertOptions = new Dictionary<string, string>(InsertOptions),
                BatchListener = BatchListener,
                WorkerList = WorkerList,
                MaxErrorQueueSize = MaxErrorQueueSize,
                CloseTimeoutMs = CloseTimeoutMs
            };
        }
    }