Kinetica C# API  Version 7.1.10.0
 All Classes Namespaces Files Functions Variables Enumerations Enumerator Properties Pages
ExportRecordsToTable.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 
10 
11 namespace kinetica
12 {
13 
21  {
22 
101  public struct Options
102  {
103 
106  public const string BATCH_SIZE = "batch_size";
107 
111  public const string DATASINK_NAME = "datasink_name";
112 
115  public const string JDBC_SESSION_INIT_STATEMENT = "jdbc_session_init_statement";
116 
119  public const string JDBC_CONNECTION_INIT_STATEMENT = "jdbc_connection_init_statement";
120 
124  public const string REMOTE_TABLE = "remote_table";
125 
141  public const string USE_ST_GEOMFROM_CASTS = "use_st_geomfrom_casts";
142  public const string TRUE = "true";
143  public const string FALSE = "false";
144 
160  public const string USE_INDEXED_PARAMETERS = "use_indexed_parameters";
161  } // end struct Options
162 
163 
169  public string table_name { get; set; }
170 
173  public string remote_query { get; set; } = "";
174 
251  public IDictionary<string, string> options { get; set; } = new Dictionary<string, string>();
252 
253 
257 
347  string remote_query = null,
348  IDictionary<string, string> options = null)
349  {
350  this.table_name = table_name ?? "";
351  this.remote_query = remote_query ?? "";
352  this.options = options ?? new Dictionary<string, string>();
353  } // end constructor
354 
355  } // end class ExportRecordsToTableRequest
356 
357 
358 
363  {
364 
367  public string table_name { get; set; }
368 
371  public long count_inserted { get; set; }
372 
374  public long count_skipped { get; set; }
375 
378  public long count_updated { get; set; }
379 
381  public IDictionary<string, string> info { get; set; } = new Dictionary<string, string>();
382 
383  } // end class ExportRecordsToTableResponse
384 
385 
386 
387 
388 } // end namespace kinetica
ExportRecordsToTableRequest(string table_name, string remote_query=null, IDictionary< string, string > options=null)
Constructs an ExportRecordsToTableRequest object with the specified parameters.
IDictionary< string, string > options
Optional parameters.
A set of results returned by Kinetica.exportRecordsToTable(string,string,IDictionary{string, string}).
string table_name
Name of the table from which the data will be exported to remote database, in [schema_name.
const string USE_INDEXED_PARAMETERS
Uses $n style syntax when generating insert query for remote_table option Supported values: TRUE FAL...
A set of parameters for Kinetica.exportRecordsToTable(string,string,IDictionary{string, string}).
const string JDBC_SESSION_INIT_STATEMENT
Executes the statement per each jdbc session before doing actual load.
const string DATASINK_NAME
Name of an existing external data sink to which table name specified in table_name will be exported...
const string JDBC_CONNECTION_INIT_STATEMENT
Executes the statement once before doing actual load.
IDictionary< string, string > info
Additional information.
string remote_query
Parameterized insert query to export gpudb table data into remote database.
const string BATCH_SIZE
Batch size, which determines how many rows to export per round trip.
const string USE_ST_GEOMFROM_CASTS
Wraps parametrized variables with st_geomfromtext or st_geomfromwkb based on source column type Suppo...
long count_inserted
Number of records inserted into the target table.
long count_updated
[Not yet implemented] Number of records updated within the target table.
long count_skipped
Number of records skipped.
KineticaData - class to help with Avro Encoding for Kinetica
Definition: KineticaData.cs:14
ExportRecordsToTableRequest()
Constructs an ExportRecordsToTableRequest object with default parameters.
const string REMOTE_TABLE
Name of the target table to which source table is exported.