7 using System.Collections.Generic;
96 public const string BINARY =
"binary";
100 public const string JSON =
"json";
275 public const string COLLECTION_NAME =
"collection_name";
279 public const string EXPRESSION =
"expression";
283 public const string HAVING =
"having";
304 public const string SORT_ORDER =
"sort_order";
308 public const string ASCENDING =
"ascending";
312 public const string DESCENDING =
"descending";
338 public const string SORT_BY =
"sort_by";
345 public const string KEY =
"key";
352 public const string VALUE =
"value";
363 public const string RESULT_TABLE =
"result_table";
383 public const string RESULT_TABLE_PERSIST =
"result_table_persist";
384 public const string TRUE =
"true";
385 public const string FALSE =
"false";
390 public const string RESULT_TABLE_FORCE_REPLICATED =
"result_table_force_replicated";
395 public const string RESULT_TABLE_GENERATE_PK =
"result_table_generate_pk";
400 public const string TTL =
"ttl";
405 public const string CHUNK_SIZE =
"chunk_size";
423 public const string MATERIALIZE_ON_GPU =
"materialize_on_gpu";
444 public long limit {
get;
set; } = 1000;
627 public IDictionary<string, string>
options {
get;
set; } =
new Dictionary<string, string>();
814 IDictionary<string, string>
options = null)
816 this.table_name = table_name ??
"";
817 this.column_names = column_names ??
new List<string>();
1025 IDictionary<string, string>
options = null)
1027 this.table_name = table_name ??
"";
1028 this.column_names = column_names ??
new List<string>();
1047 public string response_schema_str {
get;
set; }
1050 public byte[] binary_encoded_response {
get;
set; }
1053 public string json_encoded_response {
get;
set; }
1056 public long total_number_of_records {
get;
set; }
1059 public bool has_more_records {
get;
set; }
1072 public IList<KineticaRecord> data {
get;
set; } =
new List<KineticaRecord>();
1075 public long total_number_of_records {
get;
set; }
1078 public bool has_more_records {
get;
set; }
Specifies the encoding for returned records.
A set of results returned by Kinetica.aggregateGroupBy(string,IList<string>,long,long,IDictionary<string, string>).
AggregateGroupByRequest()
Constructs an AggregateGroupByRequest object with default parameters.
const string BINARY
Indicates that the returned records should be binary encoded.
long offset
A positive integer indicating the number of initial results to skip (this can be useful for paging th...
AggregateGroupByRequest(string table_name, IList< string > column_names, long offset, long limit=1000, IDictionary< string, string > options=null)
Constructs an AggregateGroupByRequest object with the specified parameters.
IDictionary< string, string > options
Optional parameters.
AggregateGroupByRequest(string table_name, IList< string > column_names, long offset, long limit=1000, string encoding=null, IDictionary< string, string > options=null)
Constructs an AggregateGroupByRequest object with the specified parameters.
IList< string > column_names
List of one or more column names, expressions, and aggregate expressions.
A set of results returned by Kinetica.aggregateGroupBy(string,IList<string>,long,long,IDictionary<string, string>).
const string JSON
Indicates that the returned records should be json encoded.
string encoding
Specifies the encoding for returned records.
string table_name
Name of the table on which the operation will be performed.
KineticaData - class to help with Avro Encoding for Kinetica
long limit
A positive integer indicating the maximum number of results to be returned Or END_OF_SET (-9999) to i...
A set of parameters for Kinetica.aggregateGroupBy(string,IList<string>,long,long,IDictionary<string, string>).