7 using System.Collections.Generic;
41 public const string BINARY =
"binary";
42 public const string JSON =
"json";
366 public const string TRUE =
"true";
367 public const string FALSE =
"false";
525 public const string TTL =
"ttl";
632 public long limit {
get; set; } = -9999;
658 public IList<byte[]>
data {
get; set; } =
new List<byte[]>();
959 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
1296 IList<byte[]>
data = null,
1297 IDictionary<string, string>
options = null)
1299 this.statement = statement ??
"";
1300 this.offset =
offset ?? 0;
1301 this.limit =
limit ?? -9999;
1304 this.data =
data ??
new List<byte[]>();
1305 this.options =
options ??
new Dictionary<string, string>();
1655 IList<byte[]>
data = null,
1656 IDictionary<string, string>
options = null)
1658 this.statement = statement ??
"";
1659 this.offset =
offset ?? 0;
1660 this.limit =
limit ?? -9999;
1663 this.data =
data ??
new List<byte[]>();
1664 this.options =
options ??
new Dictionary<string, string>();
1763 public IDictionary<string, string>
info {
get; set; } =
new Dictionary<string, string>();
1820 public IList<KineticaRecord>
data {
get; set; } =
new List<KineticaRecord>();
1854 public IDictionary<string, string>
info {
get; set; } =
new Dictionary<string, string>();
const string COST_BASED_OPTIMIZATION
If false, disables the cost-based optimization of the given query.
ExecuteSqlRequest()
Constructs an ExecuteSqlRequest object with default parameters.
string json_encoded_response
Avro JSON encoded response.
string statement
SQL statement (query, DML, or DDL) to be executed
string encoding
Specifies the encoding for returned records; either 'binary' or 'json'.
long offset
A positive integer indicating the number of initial results to skip (this can be useful for paging th...
Specifies the encoding for returned records; either 'binary' or 'json'.
const string SSQ_OPTIMIZATION
If false, scalar subqueries will be translated into joins Supported values: TRUE FALSE The default ...
const string RULE_BASED_OPTIMIZATION
If false, disables rule-based rewrite optimizations for the given query Supported values: TRUE FALSE...
const string VALIDATE_CHANGE_COLUMN
When changing a column using alter table, validate the change before applying it. ...
long count_affected
The number of objects/records affected.
string paging_table
Name of the table that has the result records of the query.
long total_number_of_records
Total/Filtered number of records.
string paging_table
Name of the table that has the result records of the query.
ExecuteSqlRequest(string statement, long?offset=null, long?limit=null, string request_schema_str=null, IList< byte[]> data=null, IDictionary< string, string > options=null)
Constructs an ExecuteSqlRequest object with the specified parameters.
const string PARALLEL_EXECUTION
If false, disables the parallel step execution of the given query.
long count_affected
The number of objects/records affected.
const string PREPARE_MODE
If true, compiles a query into an execution plan and saves it in query cache.
const string PRESERVE_DICT_ENCODING
If true, then columns that were dict encoded in the source table will be dict encoded in the projecti...
byte[] binary_encoded_response
Avro binary encoded response.
IList< KineticaRecord > data
Avro binary encoded response.
const string LATE_MATERIALIZATION
If true, Joins/Filters results will always be materialized ( saved to result tables format) Supported...
IDictionary< string, string > info
Additional information.
A set of results returned by Kinetica.executeSql(string,long,long,string,IList{byte[]},IDictionary{string, string}).
const string DISTRIBUTED_OPERATIONS
If true, enables the use of distributed operations in servicing the given query.
A set of parameters for Kinetica.executeSql(string,long,long,string,IList{byte[]},IDictionary{string, string}).
const string PAGING_TABLE
When empty or the specified paging table not exists, the system will create a paging table and return...
const string PAGING_TABLE_TTL
Sets the TTL of the paging table.
string request_schema_str
Avro schema of .
long limit
A positive integer indicating the maximum number of results to be returned, or END_OF_SET (-9999) to ...
IList< byte[]> data
An array of binary-encoded data for the records to be binded to the SQL query.
IDictionary< string, string > options
Optional parameters.
const string TTL
Sets the TTL of the intermediate result tables used in query execution.
IDictionary< string, string > info
Additional information.
const string NO_COUNT
<DEVELOPER> The default value is 'false'.
const string COUNT
Number of records in the final table
const string VIEW_ID
<DEVELOPER> The default value is ''.
bool has_more_records
Too many records.
ExecuteSqlRequest(string statement, long?offset=null, long?limit=null, string encoding=null, string request_schema_str=null, IList< byte[]> data=null, IDictionary< string, string > options=null)
Constructs an ExecuteSqlRequest object with the specified parameters.
const string COUNT
Number of records in the final table
const string DISTRIBUTED_JOINS
If true, enables the use of distributed joins in servicing the given query.
bool has_more_records
Too many records.
KineticaData - class to help with Avro Encoding for Kinetica
string response_schema_str
Avro schema of <member name="binary_encoded_response"> or <member name="json_encoded_response">.
const string UPDATE_ON_EXISTING_PK
Can be used to customize behavior when the updated primary key value already exists as described in K...
const string RESULTS_CACHING
If false, disables caching of the results of the given query Supported values: TRUE FALSE The defau...
const string PLAN_CACHE
If false, disables plan caching for the given query.
A set of results returned by Kinetica.executeSql(string,long,long,string,IList{byte[]},IDictionary{string, string}).
long total_number_of_records
Total/Filtered number of records.