7 using System.Collections.Generic;
269 public const string TRUE =
"true";
270 public const string FALSE =
"false";
360 public const string RANGE =
"RANGE";
370 public const string LIST =
"LIST";
375 public const string HASH =
"HASH";
426 public const string TTL =
"ttl";
827 public const string ABORT =
"abort";
870 public const string TRUE =
"true";
874 public const string FALSE =
"false";
908 public const string FULL =
"full";
1075 public IDictionary<string, IDictionary<string, string>>
modify_columns {
get; set; } =
new Dictionary<string, IDictionary<string, string>>();
1597 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
2144 IDictionary<
string, IDictionary<string, string>>
modify_columns = null,
2146 IDictionary<string, string>
options = null)
2148 this.table_name = table_name ??
"";
2149 this.remote_query = remote_query ??
"";
2150 this.modify_columns =
modify_columns ??
new Dictionary<string, IDictionary<string, string>>();
2152 this.options =
options ??
new Dictionary<string, string>();
2184 public IDictionary<string, IList<string>>
type_properties {
get; set; } =
new Dictionary<string, IList<string>>();
2199 public IDictionary<string, string>
info {
get; set; } =
new Dictionary<string, string>();
const string LIST
Use list partitioning.
const string SHARD_KEYS
Optional: comma separated list of column names, to set as primary keys, when not specified in the typ...
const string TRUNCATE_TABLE
If set to true, truncates the table specified by table_name prior to loading the data.
const string PARTITION_DEFINITIONS
Comma-separated list of partition definitions, whose format depends on the choice of partition_type...
const string JDBC_FETCH_SIZE
The JDBC fetch size, which determines how many rows to fetch per round trip.
const string HASH
Use hash partitioning.
const string TTL
Sets the TTL of the table specified in table_name.
const string TRUNCATE_STRINGS
If set to true, truncate string values that are longer than the column's type size.
const string IGNORE_BAD_RECORDS
Malformed records are skipped.
const string NUM_TASKS_PER_RANK
Optional: number of tasks for reading data per rank.
const string CHUNK_SIZE
Indicates the number of records per chunk to be used for this table.
const string DATASOURCE_NAME
Name of an existing external data source from which table will be loaded
InsertRecordsFromQueryRequest()
Constructs an InsertRecordsFromQueryRequest object with default parameters.
IDictionary< string, IDictionary< string, string > > modify_columns
Not implemented yet.
A set of parameters for Kinetica.insertRecordsFromQuery(string,string,IDictionary{string, IDictionary{string, string}},IDictionary{string, string},IDictionary{string, string}).
const string BATCH_SIZE
Number of records per batch when inserting data.
const string REMOTE_QUERY_INCREASING_COLUMN
Column on subscribed remote query result that will increase for new records (e.g., TIMESTAMP).
Options used when creating the target table.
const string SERIES
Use series partitioning.
const string JDBC_SESSION_INIT_STATEMENT
Executes the statement per each jdbc session before doing actual load.
const string PRIMARY_KEYS
Optional: comma separated list of column names, to set as primary keys, when not specified in the typ...
const string NO_ERROR_IF_EXISTS
If true, prevents an error from occurring if the table already exists and is of the given type...
const string ABORT
Stops current insertion and aborts entire operation when an error is encountered. ...
const string REMOTE_QUERY_FILTER_COLUMN
Name of column to be used for splitting the query into multiple sub-queries using the data distributi...
long count_updated
[Not yet implemented] Number of records updated within the target table.
const string PERMISSIVE
Records with missing columns are populated with nulls if possible; otherwise, the malformed records a...
string type_definition
A JSON string describing the columns of the target table
IDictionary< string, string > options
Optional parameters.
const string TYPE_ID
ID of a currently registered type.
const string STRATEGY_DEFINITION
The tier strategy for the table and its columns.
const string REMOTE_QUERY_PARTITION_COLUMN
Alias name for remote_query_filter_column.
const string FULL
Run a type inference on the source data (if needed) and ingest
const string DRY_RUN
Does not load data, but walks through the source data and determines the number of valid records...
const string TYPE_INFERENCE_ONLY
Infer the type of the source data and return, without ingesting any data.
const string UPDATE_ON_EXISTING_PK
Specifies the record collision policy for inserting into a table with a primary key.
const string IS_REPLICATED
Affects the distribution scheme for the table's data.
const string IS_AUTOMATIC_PARTITION
If true, a new partition will be created for values which don't fall into an existing partition...
string table_name
Name of the table into which the data will be inserted, in [schema_name.
InsertRecordsFromQueryRequest(string table_name, string remote_query, IDictionary< string, IDictionary< string, string >> modify_columns=null, IDictionary< string, string > create_table_options=null, IDictionary< string, string > options=null)
Constructs an InsertRecordsFromQueryRequest object with the specified parameters. ...
string type_label
The user-defined description associated with the target table's structure
const string IGNORE_EXISTING_PK
Specifies the record collision error-suppression policy for inserting into a table with a primary key...
string type_id
ID of the currently registered table structure type for the target table
IDictionary< string, string > info
Additional information.
const string FOREIGN_SHARD_KEY
Foreign shard key of the format 'source_column references shard_by_column from target_table(primary_k...
long count_skipped
Number of records skipped, when not running in abort error handling mode.
const string PARTITION_TYPE
Partitioning scheme to use.
const string ERROR_HANDLING
Specifies how errors should be handled upon insertion.
IDictionary< string, string > create_table_options
Options used when creating the target table.
const string TRUE
Upsert new records when primary keys match existing records
const string BAD_RECORD_TABLE_NAME
Optional name of a table to which records that were rejected are written.
IDictionary< string, IList< string > > type_properties
A mapping of each target table column name to an array of column properties associated with that colu...
const string RANGE
Use range partitioning.
const string REMOTE_QUERY_ORDER_BY
Name of column to be used for splitting the query into multiple sub-queries using ordering of given c...
const string IS_RESULT_TABLE
Indicates whether the table is a memory-only table.
const string REMOTE_QUERY
Remote SQL query from which data will be sourced
string table_name
Value of .
const string INTERVAL
Use interval partitioning.
A set of results returned by Kinetica.insertRecordsFromQuery(string,string,IDictionary{string, IDictionary{string, string}},IDictionary{string, string},IDictionary{string, string}).
long count_inserted
Number of records inserted into the target table.
KineticaData - class to help with Avro Encoding for Kinetica
const string PARTITION_KEYS
Comma-separated list of partition keys, which are the columns or column expressions by which records ...
const string NUM_SPLITS_PER_RANK
Optional: number of splits for reading data per rank.
const string FALSE
Reject new records when primary keys match existing records
const string INGESTION_MODE
Whether to do a full load, dry run, or perform a type inference on the source data.
string remote_query
Query for which result data needs to be imported
const string SUBSCRIBE
Continuously poll the data source to check for new data and load it into the table.
const string BAD_RECORD_TABLE_LIMIT
A positive integer indicating the maximum number of records that can be written to the bad-record-tab...
const string FOREIGN_KEYS
Semicolon-separated list of foreign keys, of the format '(source_column_name [, ...]) references target_table_name(primary_key_column_name [, ...]) [as foreign_key_name]'.