Kinetica.LoadGenerator.IngestRecord2 Class Reference

Extended ingest record schema matching the Rust IngestRecord2. More...

Inheritance diagram for Kinetica.LoadGenerator.IngestRecord2:

Collaboration diagram for Kinetica.LoadGenerator.IngestRecord2:

Public Member Functions
override string	ToString ()
ShardKeyValues	GetShardKeyValues ()
	Returns shard key column names and their typed values. More...

Static Public Member Functions
static Dictionary< string, IList< string > >	GetTypeProperties ()
	Gets the column properties for type creation. More...

Properties
long	TimestampMillis [get, set]
	Timestamp in milliseconds since Unix epoch. More...
int	Source [get, set]
	Source identifier (set to message_size for tracking payload size). More...
int	ThreadId [get, set]
	Thread producer ID for multi-threaded load generation analysis. More...
long	LocalCount [get, set]
	Thread-local record counter for ordering analysis. More...
long	Nanosecond [get, set]
	High-precision nanosecond timestamp for latency measurements. More...
string	Payload = string.Empty [get, set]
	Variable-size payload for measuring throughput with different record sizes. More...

Detailed Description

Extended ingest record schema matching the Rust IngestRecord2.

Adds thread tracking and high-precision timing for detailed analysis.

Definition at line 53 of file IngestRecord.cs.

Member Function Documentation

GetShardKeyValues()

ShardKeyValues Kinetica.LoadGenerator.IngestRecord2.GetShardKeyValues ( )

inline

Returns shard key column names and their typed values.

Only columns that are part of the shard key need to be included. The values are used for computing the routing hash to determine which worker node should receive the record.

For best performance, implement this method to avoid allocations when possible (e.g., use ShardKeyValues.Single() for single-column keys).

Returns

A collection of (column name, value) pairs for the shard key.

Implements IShardKeyExtractor.

Definition at line 107 of file IngestRecord.cs.

GetTypeProperties()

static Dictionary<string, IList<string> > Kinetica.LoadGenerator.IngestRecord2.GetTypeProperties ( )

static

Gets the column properties for type creation.

ToString()

override string Kinetica.LoadGenerator.IngestRecord2.ToString

(

)

Property Documentation

LocalCount

long Kinetica.LoadGenerator.IngestRecord2.LocalCount

getset

Thread-local record counter for ordering analysis.

Property: DATA

Definition at line 77 of file IngestRecord.cs.

Nanosecond

long Kinetica.LoadGenerator.IngestRecord2.Nanosecond

getset

High-precision nanosecond timestamp for latency measurements.

Property: DATA

Definition at line 83 of file IngestRecord.cs.

Payload

string Kinetica.LoadGenerator.IngestRecord2.Payload = string.Empty

getset

Variable-size payload for measuring throughput with different record sizes.

Uses string type which is well-supported by Kinetica type system.

Definition at line 89 of file IngestRecord.cs.

Source

int Kinetica.LoadGenerator.IngestRecord2.Source

getset

Source identifier (set to message_size for tracking payload size).

Property: DATA

Definition at line 65 of file IngestRecord.cs.

ThreadId

int Kinetica.LoadGenerator.IngestRecord2.ThreadId

getset

Thread producer ID for multi-threaded load generation analysis.

Property: DATA

Definition at line 71 of file IngestRecord.cs.

TimestampMillis

long Kinetica.LoadGenerator.IngestRecord2.TimestampMillis

getset

Timestamp in milliseconds since Unix epoch.

Property: TIMESTAMP

Definition at line 59 of file IngestRecord.cs.

---

The documentation for this class was generated from the following file:

• Kinetica.LoadGenerator/IngestRecord.cs