7 using System.Collections.Generic;
83 public const string BINARY =
"binary";
84 public const string JSON =
"json";
332 public const string TRUE =
"true";
333 public const string FALSE =
"false";
510 public IList<string>
expressions {
get; set; } =
new List<string>();
519 public IList<IDictionary<string, string>>
new_values_maps {
get; set; } =
new List<IDictionary<string, string>>();
766 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
1009 IDictionary<string, string>
options = null)
1011 this.table_name = table_name ??
"";
1012 this.expressions = expressions ??
new List<string>();
1013 this.new_values_maps =
new_values_maps ??
new List<IDictionary<string, string>>();
1015 this.records_to_insert_str =
new List<string>();
1017 this.options =
options ??
new Dictionary<string, string>();
1281 IDictionary<string, string>
options = null)
1283 this.table_name = table_name ??
"";
1284 this.expressions = expressions ??
new List<string>();
1285 this.new_values_maps =
new_values_maps ??
new List<IDictionary<string, string>>();
1289 this.options =
options ??
new Dictionary<string, string>();
1560 public struct Options
1566 public const string GLOBAL_EXPRESSION =
"global_expression";
1590 public const string BYPASS_SAFETY_CHECKS =
"bypass_safety_checks";
1591 public const string TRUE =
"true";
1592 public const string FALSE =
"false";
1655 public const string UPDATE_ON_EXISTING_PK =
"update_on_existing_pk";
1691 public const string IGNORE_EXISTING_PK =
"ignore_existing_pk";
1708 public const string UPDATE_PARTITION =
"update_partition";
1725 public const string TRUNCATE_STRINGS =
"truncate_strings";
1748 public const string USE_EXPRESSIONS_IN_NEW_VALUES_MAPS =
"use_expressions_in_new_values_maps";
1756 public const string RECORD_ID =
"record_id";
1765 public string table_name {
get; set; }
1769 public IList<string> expressions {
get; set; } =
new List<string>();
1778 public IList<IDictionary<string, string>> new_values_maps {
get; set; } =
new List<IDictionary<string, string>>();
1787 public IList<T> data {
get; set; } =
new List<T>();
2000 public IDictionary<string, string> options {
get; set; } =
new Dictionary<string, string>();
2240 IList<string> expressions,
2241 IList<IDictionary<string, string>> new_values_maps,
2242 IList<T> data = null,
2243 IDictionary<string, string> options = null)
2245 this.table_name = table_name ??
"";
2246 this.expressions = expressions ??
new List<string>();
2247 this.new_values_maps = new_values_maps ??
new List<IDictionary<string, string>>();
2248 this.data = data ??
new List<T>();
2249 this.options = options ??
new Dictionary<string, string>();
2279 public IDictionary<string, string>
info {
get; set; } =
new Dictionary<string, string>();
IList< string > expressions
A list of the actual predicates, one for each update; format should follow the guidelines /filter...
IDictionary< string, string > info
Additional information.
const string GLOBAL_EXPRESSION
An optional global expression to reduce the search space of the predicates listed in expressions...
string record_encoding
Identifies which of and should be used.
const string TRUNCATE_STRINGS
If set to true, any strings which are too long for their charN string fields will be truncated to fit...
const string RECORD_ID
ID of a single record to be updated (returned in the call to Kinetica.insertRecords{T}(string,IList{T},IDictionary{string, string}) or Kinetica.getRecordsFromCollection{T}(string,long,long,IDictionary{string, string})).
A set of parameters for Kinetica.updateRecords{T}(string,IList{string},IList{IDictionary{string, string}},IList{T},IDictionary{string, string}).
A set of results returned by Kinetica.updateRecords{T}(string,IList{string},IList{IDictionary{string...
UpdateRecordsRequest()
Constructs an UpdateRecordsRequest object with default parameters.
RawUpdateRecordsRequest(string table_name, IList< string > expressions, IList< IDictionary< string, string >> new_values_maps, IList< byte[]> records_to_insert=null, IDictionary< string, string > options=null)
Constructs a RawUpdateRecordsRequest object with the specified parameters.
IList< byte[]> records_to_insert
An optional list of new binary-avro encoded records to insert, one for each update.
const string UPDATE_ON_EXISTING_PK
Specifies the record collision policy for updating a table with a primary key.
long count_updated
Total number of records updated.
const string USE_EXPRESSIONS_IN_NEW_VALUES_MAPS
When set to true, all new values in new_values_maps are considered as expression values.
UpdateRecordsRequest(string table_name, IList< string > expressions, IList< IDictionary< string, string >> new_values_maps, IList< T > data=null, IDictionary< string, string > options=null)
Constructs an UpdateRecordsRequest object with the specified parameters.
IList< IDictionary< string, string > > new_values_maps
List of new values for the matching records.
Identifies which of and should be used.
IList< long > counts_inserted
Total number of records inserted per predicate in (will be either 0 or 1 for each expression)...
IList< long > counts_updated
Total number of records updated per predicate in .
const string IGNORE_EXISTING_PK
Specifies the record collision error-suppression policy for updating a table with a primary key...
string table_name
Name of table to be updated, in [schema_name.
IDictionary< string, string > options
Optional parameters.
RawUpdateRecordsRequest(string table_name, IList< string > expressions, IList< IDictionary< string, string >> new_values_maps, IList< byte[]> records_to_insert=null, IList< string > records_to_insert_str=null, string record_encoding=null, IDictionary< string, string > options=null)
Constructs a RawUpdateRecordsRequest object with the specified parameters.
const string UPDATE_PARTITION
Force qualifying records to be deleted and reinserted so their partition membership will be reevaluat...
long count_inserted
Total number of records inserted (due to expressions not matching any existing records).
KineticaData - class to help with Avro Encoding for Kinetica
IList< string > records_to_insert_str
An optional list of JSON encoded objects to insert, one for each update, to be added if the particula...
const string BYPASS_SAFETY_CHECKS
When set to true, all predicates are available for primary key updates.
RawUpdateRecordsRequest()
Constructs a RawUpdateRecordsRequest object with default parameters.