Kinetica   C#   API  Version 7.2.3.0
AppendRecords.cs
Go to the documentation of this file.
1 /*
2  * This file was autogenerated by the Kinetica schema processor.
3  *
4  * DO NOT EDIT DIRECTLY.
5  */
6 
7 using System.Collections.Generic;
8 
9 namespace kinetica
10 {
21  {
25  public struct Options
26  {
33  public const string OFFSET = "offset";
34 
41  public const string LIMIT = "limit";
42 
46  public const string EXPRESSION = "expression";
47 
54  public const string ORDER_BY = "order_by";
55 
77  public const string UPDATE_ON_EXISTING_PK = "update_on_existing_pk";
78 
79  public const string TRUE = "true";
80  public const string FALSE = "false";
81 
108  public const string IGNORE_EXISTING_PK = "ignore_existing_pk";
109 
113  public const string PK_CONFLICT_PREDICATE_HIGHER = "pk_conflict_predicate_higher";
114 
118  public const string PK_CONFLICT_PREDICATE_LOWER = "pk_conflict_predicate_lower";
119 
134  public const string TRUNCATE_STRINGS = "truncate_strings";
135  } // end struct Options
136 
142  public string table_name { get; set; }
143 
149  public string source_table_name { get; set; }
150 
160  public IDictionary<string, string> field_map { get; set; } = new Dictionary<string, string>();
161 
314  public IDictionary<string, string> options { get; set; } = new Dictionary<string, string>();
315 
318  public AppendRecordsRequest() { }
319 
495  string source_table_name,
496  IDictionary<string, string> field_map,
497  IDictionary<string, string> options = null)
498  {
499  this.table_name = table_name ?? "";
500  this.source_table_name = source_table_name ?? "";
501  this.field_map = field_map ?? new Dictionary<string, string>();
502  this.options = options ?? new Dictionary<string, string>();
503  } // end constructor
504  } // end class AppendRecordsRequest
505 
510  {
511  public string table_name { get; set; }
512 
516  public IDictionary<string, string> info { get; set; } = new Dictionary<string, string>();
517  } // end class AppendRecordsResponse
518 } // end namespace kinetica
string source_table_name
The source table name to get records from, in [schema_name.
const string IGNORE_EXISTING_PK
Specifies the record collision error-suppression policy for inserting source table records (specified...
const string UPDATE_ON_EXISTING_PK
Specifies the record collision policy for inserting source table records (specified by source_table_n...
A set of string constants for the parameter options.
A set of parameters for Kinetica.appendRecords.
const string ORDER_BY
Comma-separated list of the columns to be sorted by from source table (specified by source_table_name...
AppendRecordsRequest()
Constructs an AppendRecordsRequest object with default parameters.
const string PK_CONFLICT_PREDICATE_HIGHER
The record with higher value for the column resolves the primary-key insert conflict.
const string TRUNCATE_STRINGS
If set to TRUE, it allows inserting longer strings into smaller charN string columns by truncating th...
IDictionary< string, string > field_map
Contains the mapping of column names from the target table (specified by table_name) as the keys,...
string table_name
The table name for the records to be appended, in [schema_name.
A set of results returned by Kinetica.appendRecords.
IDictionary< string, string > options
Optional parameters.
IDictionary< string, string > info
Additional information.
const string PK_CONFLICT_PREDICATE_LOWER
The record with lower value for the column resolves the primary-key insert conflict.
const string OFFSET
A positive integer indicating the number of initial results to skip from source_table_name.
KineticaData - class to help with Avro Encoding for Kinetica
Definition: KineticaData.cs:14
const string LIMIT
A positive integer indicating the maximum number of results to be returned from source_table_name.
const string EXPRESSION
Optional filter expression to apply to the source_table_name.
AppendRecordsRequest(string table_name, string source_table_name, IDictionary< string, string > field_map, IDictionary< string, string > options=null)
Constructs an AppendRecordsRequest object with the specified parameters.