kinetica.Utils.WorkerQueue< T > Class Template Reference

Public Member Functions
	WorkerQueue (System.Uri url)
	Creates an insertion queue for a given worker. More...
	WorkerQueue (System.Uri url, int capacity, bool has_primary_key, bool update_on_existing_pk)
	Creates an insertion queue for a given worker. More...
IList< T >	flush ()
	Returns the current queue and creates a new empty one. More...
IList< T >?	insert (T record, RecordKey key)
	Inserts a record into the queue (if all conditions are favourable). More...

Properties
System.Uri	url [get]

Detailed Description

Definition at line 7 of file WorkerQueue.cs.

Constructor & Destructor Documentation

WorkerQueue() [1/2]

kinetica.Utils.WorkerQueue< T >.WorkerQueue ( System.Uri  url )

inline

Creates an insertion queue for a given worker.

Parameters

url

Definition at line 21 of file WorkerQueue.cs.

WorkerQueue() [2/2]

kinetica.Utils.WorkerQueue< T >.WorkerQueue ( System.Uri  url, int  capacity, bool  has_primary_key, bool  update_on_existing_pk  )

inline

Creates an insertion queue for a given worker.

Parameters

url
capacity
has_primary_key
update_on_existing_pk

Definition at line 38 of file WorkerQueue.cs.

Member Function Documentation

flush()

IList<T> kinetica.Utils.WorkerQueue< T >.flush ( )

inline

Returns the current queue and creates a new empty one.

Returns

A list of records to be inserted.

Definition at line 53 of file WorkerQueue.cs.

insert()

IList<T>? kinetica.Utils.WorkerQueue< T >.insert ( T  record, RecordKey  key  )

inline

Inserts a record into the queue (if all conditions are favourable).

Returns the queue if it becomes full upon insertion.

Parameters

record	The record to insert into the queue.
key	A primary key, if any.

Returns

The list of records (if the queue is full), or null.

Definition at line 70 of file WorkerQueue.cs.

Property Documentation

url

System.Uri kinetica.Utils.WorkerQueue< T >.url

get

Definition at line 9 of file WorkerQueue.cs.

---

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

• _build/public-os_ubuntu24.04-arch_amd64-cc_gcc_13.3.0/install/Kinetica/Utils/WorkerQueue.cs