7 using System.Collections.Generic;
129 public IDictionary<string, string>
_params {
get; set; } =
new Dictionary<string, string>();
134 public IDictionary<string, byte[]>
bin_params {
get; set; } =
new Dictionary<string, byte[]>();
150 public IDictionary<string, IList<string>>
input_column_names {
get; set; } =
new Dictionary<string, IList<string>>();
211 public IDictionary<string, string>
options {
get; set; } =
new Dictionary<string, string>();
303 IDictionary<string, string>
_params = null,
304 IDictionary<
string, byte[]>
bin_params = null,
308 IDictionary<string, string>
options = null)
310 this.proc_name = proc_name ??
"";
311 this._params =
_params ??
new Dictionary<string, string>();
312 this.bin_params =
bin_params ??
new Dictionary<string, byte[]>();
314 this.input_column_names =
input_column_names ??
new Dictionary<string, IList<string>>();
316 this.options =
options ??
new Dictionary<string, string>();
335 public IDictionary<string, string>
info {
get; set; } =
new Dictionary<string, string>();
const string RUN_TAG
A string that, if not empty, can be used in subsequent calls to Kinetica.showProcStatus(string,IDictionary{string, string}) or Kinetica.killProc(string,IDictionary{string, string}) to identify the proc instance.
string run_id
The run ID of the running proc instance.
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 > info
Additional information.
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}).