7 using System.Collections.Generic;
113 public IDictionary<string, string>
_params {
get;
set; } =
new Dictionary<string, string>();
118 public IDictionary<string, byte[]>
bin_params {
get;
set; } =
new Dictionary<string, byte[]>();
134 public IDictionary<string, IList<string>>
input_column_names {
get;
set; } =
new Dictionary<string, IList<string>>();
188 public IDictionary<string, string>
options {
get;
set; } =
new Dictionary<string, string>();
273 IDictionary<string, string>
_params = null,
274 IDictionary<
string, byte[]>
bin_params = null,
278 IDictionary<string, string>
options = null)
280 this.proc_name = proc_name ??
"";
282 this.
bin_params = bin_params ??
new Dictionary<string, byte[]>();
284 this.
input_column_names = input_column_names ??
new Dictionary<string, IList<string>>();
286 this.
options = options ??
new Dictionary<string, string>();
302 public string run_id {
get;
set; }
IList< string > input_table_names
Names of the tables containing data to be passed to the proc.
string proc_name
Name of the proc to execute.
const string USE_CACHED_INPUT
A comma-delimited list of run IDs (as returned from prior calls to Kinetica.executeProc(string,IDictionary<string, string>,IDictionary<string, byte[]>,IList<string>,IDictionary<string, IList<string>>,IList<string>,IDictionary<string, string>)) of running or completed proc instances from which input data cached using the cache_input option will be used.
ExecuteProcRequest(string proc_name, IDictionary< string, string > _params=null, IDictionary< string, byte[]> bin_params=null, IList< string > input_table_names=null, IDictionary< string, IList< string >> input_column_names=null, IList< string > output_table_names=null, IDictionary< string, string > options=null)
Constructs an ExecuteProcRequest object with the specified parameters.
const string CACHE_INPUT
A comma-delimited list of table names from input_table_names from which input data will be cached for...
IDictionary< string, byte[]> bin_params
A map containing named binary parameters to pass to the proc.
IDictionary< string, string > options
Optional parameters.
A set of results returned by Kinetica.executeProc(string,IDictionary<string, string>,IDictionary<string, byte[]>,IList<string>,IDictionary<string, IList<string>>,IList<string>,IDictionary<string, string>).
const string KIFS_INPUT_DIRS
A comma-delimited list of KiFS directories whose local files will be made directly accessible to the ...
IList< string > output_table_names
Names of the tables to which output data from the proc will be written.
ExecuteProcRequest()
Constructs an ExecuteProcRequest object with default parameters.
IDictionary< string, IList< string > > input_column_names
Map of table names from to lists of names of columns from those tables that will be passed to the pr...
IDictionary< string, string > _params
A map containing named parameters to pass to the proc.
KineticaData - class to help with Avro Encoding for Kinetica
A set of parameters for Kinetica.executeProc(string,IDictionary<string, string>,IDictionary<string, byte[]>,IList<string>,IDictionary<string, IList<string>>,IList<string>,IDictionary<string, string>).