IngestRecord.cs

Go to the documentation of this file.

using System;
using kinetica.Records;

namespace Kinetica.LoadGenerator
{
    public class IngestRecord : IShardKeyExtractor
    {
        public long TimestampMillis { get; set; }

        public int Source { get; set; }

        public string Payload { get; set; } = string.Empty;

        public static Dictionary<string, IList<string>> GetTypeProperties() => new()
        {
            { "TimestampMillis", new List<string> { kinetica.ColumnProperty.TIMESTAMP } },
            { "Source", new List<string> { kinetica.ColumnProperty.DATA } },
            { "Payload", new List<string> { kinetica.ColumnProperty.DATA } }
        };

        public override string ToString() =>
            $"IngestRecord {{ TimestampMillis={TimestampMillis}, Source={Source}, PayloadSize={Payload.Length} }}";

        public ShardKeyValues GetShardKeyValues()
        {
            return new ShardKeyValues();
        }
    }

    public class IngestRecord2 : IShardKeyExtractor
    {
        public long TimestampMillis { get; set; }

        public int Source { get; set; }

        public int ThreadId { get; set; }

        public long LocalCount { get; set; }

        public long Nanosecond { get; set; }

        public string Payload { get; set; } = string.Empty;

        public static Dictionary<string, IList<string>> GetTypeProperties() => new()
        {
            { "TimestampMillis", new List<string> { kinetica.ColumnProperty.TIMESTAMP } },
            { "Source", new List<string> { kinetica.ColumnProperty.DATA } },
            { "ThreadId", new List<string> { kinetica.ColumnProperty.DATA } },
            { "LocalCount", new List<string> { kinetica.ColumnProperty.DATA } },
            { "Nanosecond", new List<string> { kinetica.ColumnProperty.DATA } },
            { "Payload", new List<string> { kinetica.ColumnProperty.DATA } }
        };

        public override string ToString() =>
            $"IngestRecord2 {{ TimestampMillis={TimestampMillis}, Source={Source}, ThreadId={ThreadId}, LocalCount={LocalCount}, Nanosecond={Nanosecond}, PayloadSize={Payload.Length} }}";

        public ShardKeyValues GetShardKeyValues()
        {
            return new ShardKeyValues();
        }
    }
}