Manages the insertion into GPUdb of large numbers of records in bulk, with automatic batch management and support for multi-head ingest. More…
|
| | InsertException (string msg) |
| | Initializes a new insert exception with the given message.
|
| |
| override string | ToString () |
| |
| | KineticaIngestor (Kinetica kdb, string tableName, int batchSize, KineticaType ktype, Dictionary< string, string >? options=null, Utils.WorkerList? workers=null) |
| | Creates a new ingestor for bulk insertion of records into the specified table.
|
| |
| Int64 | getCountInserted () |
| | Returns the count of records inserted so far.
|
| |
| Int64 | getCountUpdated () |
| | Returns the count of records updated so far.
|
| |
| void | flush () |
| | Ensures that all queued records are inserted into Kinetica.
|
| |
| void | insert (T record) |
| | Queues a record for insertion into Kinetica.
|
| |
| void | insert (IList< T > records) |
| | Queues a list of records for insertion into Kinetica.
|
| |
| | InsertException (string msg) |
| | Initializes a new insert exception with the given message.
|
| |
| override string | ToString () |
| |
| | KineticaIngestor (Kinetica kdb, string tableName, int batchSize, KineticaType ktype, Dictionary< string, string >? options=null, Utils.WorkerList? workers=null) |
| | Creates a new ingestor for bulk insertion of records into the specified table.
|
| |
| Int64 | getCountInserted () |
| | Returns the count of records inserted so far.
|
| |
| Int64 | getCountUpdated () |
| | Returns the count of records updated so far.
|
| |
| void | flush () |
| | Ensures that all queued records are inserted into Kinetica.
|
| |
| void | insert (T record) |
| | Queues a record for insertion into Kinetica.
|
| |
| void | insert (IList< T > records) |
| | Queues a list of records for insertion into Kinetica.
|
| |
Manages the insertion into GPUdb of large numbers of records in bulk, with automatic batch management and support for multi-head ingest.
Use the insert(T) and insert(IList<T>) methods to queue records for insertion, and the flush method to ensure that all queued records have been inserted.
Template Parameters
| T | The type of object being inserted. |
This class is obsolete. Use BulkInserter<T> instead, which provides better performance and async support among other features.
Definition at line 16 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.flush | ( | | ) | |
| inline |
Ensures that all queued records are inserted into Kinetica.
If an error occurs while inserting the records from any queue, the records will no longer be in that queue nor in Kinetica; catch InsertException to get the list of records that were being inserted if needed (for example, to retry). Other queues may also still contain unflushed records if this occurs.
Definition at line 218 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.flush | ( | | ) | |
| inline |
Ensures that all queued records are inserted into Kinetica.
If an error occurs while inserting the records from any queue, the records will no longer be in that queue nor in Kinetica; catch InsertException to get the list of records that were being inserted if needed (for example, to retry). Other queues may also still contain unflushed records if this occurs.
Definition at line 218 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.insert | ( | IList< T > | records | ) | |
| inline |
Queues a list of records for insertion into Kinetica.
If any queue reaches the configured batch size, all records in that queue will be inserted into Kinetica before the method returns. If an error occurs while inserting the queued records, the records will no longer be in that queue nor in Kinetica; catch InsertException to get the list of records that were being inserted (including any from the queue in question and any remaining in the list not yet queued) if needed (for example, to retry). Note that depending on the number of records, multiple calls to Kinetica may occur.
Parameters
| records | The records to insert. |
Definition at line 343 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.insert | ( | IList< T > | records | ) | |
| inline |
Queues a list of records for insertion into Kinetica.
If any queue reaches the configured batch size, all records in that queue will be inserted into Kinetica before the method returns. If an error occurs while inserting the queued records, the records will no longer be in that queue nor in Kinetica; catch InsertException to get the list of records that were being inserted (including any from the queue in question and any remaining in the list not yet queued) if needed (for example, to retry). Note that depending on the number of records, multiple calls to Kinetica may occur.
Parameters
| records | The records to insert. |
Definition at line 343 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.insert | ( | T | record | ) | |
| inline |
Queues a record for insertion into Kinetica.
If the queue reaches the configured batch size, all records in the queue will be inserted into Kinetica before the method returns. If an error occurs while inserting the records, the records will no longer be in the queue nor in Kinetica; catch InsertException to get the list of records that were being inserted if needed (for example, to retry).
Parameters
| record | The record to insert. |
Definition at line 285 of file KineticaIngestor.cs.
| void kinetica.KineticaIngestor< T >.insert | ( | T | record | ) | |
| inline |
Queues a record for insertion into Kinetica.
If the queue reaches the configured batch size, all records in the queue will be inserted into Kinetica before the method returns. If an error occurs while inserting the records, the records will no longer be in the queue nor in Kinetica; catch InsertException to get the list of records that were being inserted if needed (for example, to retry).
Parameters
| record | The record to insert. |
Definition at line 285 of file KineticaIngestor.cs.
