Kinetica C# API  Version 6.2.0.1
kinetica.Kinetica Class Reference

API to talk to Kinetica Database More...

Classes

class  Options
 Connection Options More...
 

Public Member Functions

 Kinetica (string url_str, Options options=null)
 API Constructor More...
 
void AddTableType (string table_name, Type obj_type)
 Given a table name, add its record type to enable proper encoding of records for insertion or updates. More...
 
void SetKineticaSourceClassToTypeMapping (Type objectType, KineticaType kineticaType)
 Saves an object class type to a KineticaType association. More...
 
void DecodeRawBinaryDataUsingRecordType< T > (KineticaType record_type, IList< byte[]> records_binary, IList< T > records)
 Given a KineticaType object for a certain record type, decode binary data into distinct records (objects). More...
 
void DecodeRawBinaryDataUsingSchemaString< T > (string schema_string, IList< byte[]> records_binary, IList< T > records)
 Given a schema string for a certain record type, decode binary data into distinct records (objects). More...
 
void DecodeRawBinaryDataUsingSchemaString< T > (IList< string > schema_strings, IList< IList< byte[]>> lists_records_binary, IList< IList< T >> record_lists)
 Given a list of schema strings, decode binary data into distinct records (objects). More...
 
void DecodeRawBinaryDataUsingTypeIDs< T > (IList< string > type_ids, IList< byte[]> records_binary, IList< T > records)
 Given IDs of records types registered with Kinetica, decode binary data into distinct records (objects). More...
 
void DecodeRawBinaryDataUsingTypeIDs< T > (IList< string > type_ids, IList< IList< byte[]>> lists_records_binary, IList< IList< T >> record_lists)
 Given IDs of records types registered with Kinetica, decode binary data into distinct records (objects). More...
 
AdminAlterJobsResponse adminAlterJobs (AdminAlterJobsRequest request_)
 Perform the requested action on a list of one or more job(s). More...
 
AdminAlterJobsResponse adminAlterJobs (IList< int > job_ids, string action, IDictionary< string, string > options=null)
 Perform the requested action on a list of one or more job(s). More...
 
AdminOfflineResponse adminOffline (AdminOfflineRequest request_)
 Take the system offline. More...
 
AdminOfflineResponse adminOffline (bool offline, IDictionary< string, string > options=null)
 Take the system offline. More...
 
AdminShowAlertsResponse adminShowAlerts (AdminShowAlertsRequest request_)
 Retrieves a list of the most recent alerts generated. More...
 
AdminShowAlertsResponse adminShowAlerts (int num_alerts, IDictionary< string, string > options=null)
 Retrieves a list of the most recent alerts generated. More...
 
AdminShowJobsResponse adminShowJobs (AdminShowJobsRequest request_)
 Get a list of the current jobs in GPUdb. More...
 
AdminShowJobsResponse adminShowJobs (IDictionary< string, string > options=null)
 Get a list of the current jobs in GPUdb. More...
 
AdminShowShardsResponse adminShowShards (AdminShowShardsRequest request_)
 Show the mapping of shards to the corresponding rank and tom. More...
 
AdminShowShardsResponse adminShowShards (IDictionary< string, string > options=null)
 Show the mapping of shards to the corresponding rank and tom. More...
 
AdminShutdownResponse adminShutdown (AdminShutdownRequest request_)
 Exits the database server application. More...
 
AdminShutdownResponse adminShutdown (string exit_type, string authorization, IDictionary< string, string > options=null)
 Exits the database server application. More...
 
AdminVerifyDbResponse adminVerifyDb (AdminVerifyDbRequest request_)
 Verify database is in a consistent state. More...
 
AdminVerifyDbResponse adminVerifyDb (IDictionary< string, string > options=null)
 Verify database is in a consistent state. More...
 
AggregateConvexHullResponse aggregateConvexHull (AggregateConvexHullRequest request_)
 Calculates and returns the convex hull for the values in a table specified by . More...
 
AggregateConvexHullResponse aggregateConvexHull (string table_name, string x_column_name, string y_column_name, IDictionary< string, string > options=null)
 Calculates and returns the convex hull for the values in a table specified by table_name . More...
 
AggregateGroupByResponse aggregateGroupBy (AggregateGroupByRequest request_)
 Calculates unique combinations (groups) of values for the given columns in a given table/view/collection and computes aggregates on each unique combination. More...
 
AggregateGroupByResponse aggregateGroupBy (string table_name, IList< string > column_names, long offset, long limit=1000, IDictionary< string, string > options=null)
 Calculates unique combinations (groups) of values for the given columns in a given table/view/collection and computes aggregates on each unique combination. More...
 
AggregateHistogramResponse aggregateHistogram (AggregateHistogramRequest request_)
 Performs a histogram calculation given a table, a column, and an interval function. More...
 
AggregateHistogramResponse aggregateHistogram (string table_name, string column_name, double start, double end, double interval, IDictionary< string, string > options=null)
 Performs a histogram calculation given a table, a column, and an interval function. More...
 
AggregateKMeansResponse aggregateKMeans (AggregateKMeansRequest request_)
 This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering. More...
 
AggregateKMeansResponse aggregateKMeans (string table_name, IList< string > column_names, int k, double tolerance, IDictionary< string, string > options=null)
 This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering. More...
 
AggregateMinMaxResponse aggregateMinMax (AggregateMinMaxRequest request_)
 Calculates and returns the minimum and maximum values of a particular column in a table. More...
 
AggregateMinMaxResponse aggregateMinMax (string table_name, string column_name, IDictionary< string, string > options=null)
 Calculates and returns the minimum and maximum values of a particular column in a table. More...
 
AggregateMinMaxGeometryResponse aggregateMinMaxGeometry (AggregateMinMaxGeometryRequest request_)
 Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table. More...
 
AggregateMinMaxGeometryResponse aggregateMinMaxGeometry (string table_name, string column_name, IDictionary< string, string > options=null)
 Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table. More...
 
AggregateStatisticsResponse aggregateStatistics (AggregateStatisticsRequest request_)
 Calculates the requested statistics of the given column(s) in a given table. More...
 
AggregateStatisticsResponse aggregateStatistics (string table_name, string column_name, string stats, IDictionary< string, string > options=null)
 Calculates the requested statistics of the given column(s) in a given table. More...
 
AggregateStatisticsByRangeResponse aggregateStatisticsByRange (AggregateStatisticsByRangeRequest request_)
 Divides the given set into bins and calculates statistics of the values of a value-column in each bin. More...
 
AggregateStatisticsByRangeResponse aggregateStatisticsByRange (string table_name, string select_expression, string column_name, string value_column_name, string stats, double start, double end, double interval, IDictionary< string, string > options=null)
 Divides the given set into bins and calculates statistics of the values of a value-column in each bin. More...
 
AggregateUniqueResponse aggregateUnique (AggregateUniqueRequest request_)
 Returns all the unique values from a particular column (specified by ) of a particular table or collection (specified by ). More...
 
AggregateUniqueResponse aggregateUnique (string table_name, string column_name, long offset, long limit=10000, IDictionary< string, string > options=null)
 Returns all the unique values from a particular column (specified by column_name ) of a particular table or collection (specified by table_name ). More...
 
AggregateUnpivotResponse aggregateUnpivot (AggregateUnpivotRequest request_)
 Rotate the column values into rows values. More...
 
AggregateUnpivotResponse aggregateUnpivot (string table_name, IList< string > column_names, string variable_column_name, string value_column_name, IList< string > pivoted_columns, IDictionary< string, string > options=null)
 Rotate the column values into rows values. More...
 
AlterSystemPropertiesResponse alterSystemProperties (AlterSystemPropertiesRequest request_)
 The Kinetica.alterSystemProperties(IDictionary<string, string>,IDictionary<string, string>) endpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution. More...
 
AlterSystemPropertiesResponse alterSystemProperties (IDictionary< string, string > property_updates_map, IDictionary< string, string > options=null)
 The Kinetica.alterSystemProperties(IDictionary<string, string>,IDictionary<string, string>) endpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution. More...
 
AlterTableResponse alterTable (AlterTableRequest request_)
 Apply various modifications to a table, view, or collection. More...
 
AlterTableResponse alterTable (string table_name, string action, string _value, IDictionary< string, string > options=null)
 Apply various modifications to a table, view, or collection. More...
 
AlterTableMetadataResponse alterTableMetadata (AlterTableMetadataRequest request_)
 Updates (adds or changes) metadata for tables. More...
 
AlterTableMetadataResponse alterTableMetadata (IList< string > table_names, IDictionary< string, string > metadata_map, IDictionary< string, string > options=null)
 Updates (adds or changes) metadata for tables. More...
 
AlterUserResponse alterUser (AlterUserRequest request_)
 Alters a user. More...
 
AlterUserResponse alterUser (string name, string action, string _value, IDictionary< string, string > options=null)
 Alters a user. More...
 
AppendRecordsResponse appendRecords (AppendRecordsRequest request_)
 Append (or insert) all records from a source table (specified by ) to a particular target table (specified by ). More...
 
AppendRecordsResponse appendRecords (string table_name, string source_table_name, IDictionary< string, string > field_map, IDictionary< string, string > options=null)
 Append (or insert) all records from a source table (specified by source_table_name ) to a particular target table (specified by table_name ). More...
 
ClearTableResponse clearTable (ClearTableRequest request_)
 Clears (drops) one or all tables in the database cluster. More...
 
ClearTableResponse clearTable (string table_name="", string authorization="", IDictionary< string, string > options=null)
 Clears (drops) one or all tables in the database cluster. More...
 
ClearTableMonitorResponse clearTableMonitor (ClearTableMonitorRequest request_)
 Deactivates a table monitor previously created with Kinetica.createTableMonitor(string,IDictionary<string, string>). More...
 
ClearTableMonitorResponse clearTableMonitor (string topic_id, IDictionary< string, string > options=null)
 Deactivates a table monitor previously created with Kinetica.createTableMonitor(string,IDictionary<string, string>). More...
 
ClearTriggerResponse clearTrigger (ClearTriggerRequest request_)
 Clears or cancels the trigger identified by the specified handle. More...
 
ClearTriggerResponse clearTrigger (string trigger_id, IDictionary< string, string > options=null)
 Clears or cancels the trigger identified by the specified handle. More...
 
CreateJobResponse createJob (CreateJobRequest request_)
 Create a job which will run asynchronously. More...
 
CreateJobResponse createJob (string endpoint, string request_encoding, byte[] data, string data_str, IDictionary< string, string > options=null)
 Create a job which will run asynchronously. More...
 
CreateJoinTableResponse createJoinTable (CreateJoinTableRequest request_)
 Creates a table that is the result of a SQL JOIN. More...
 
CreateJoinTableResponse createJoinTable (string join_table_name, IList< string > table_names, IList< string > column_names, IList< string > expressions=null, IDictionary< string, string > options=null)
 Creates a table that is the result of a SQL JOIN. More...
 
CreateMaterializedViewResponse createMaterializedView (CreateMaterializedViewRequest request_)
 Initiates the process of creating a materialized view, reserving the view's name to prevent other views or tables from being created with that name. More...
 
CreateMaterializedViewResponse createMaterializedView (string table_name, IDictionary< string, string > options=null)
 Initiates the process of creating a materialized view, reserving the view's name to prevent other views or tables from being created with that name. More...
 
CreateProcResponse createProc (CreateProcRequest request_)
 Creates an instance (proc) of the user-defined function (UDF) specified by the given command, options, and files, and makes it available for execution. More...
 
CreateProcResponse createProc (string proc_name, string execution_mode=CreateProcRequest.ExecutionMode.DISTRIBUTED, IDictionary< string, byte[]> files=null, string command="", IList< string > args=null, IDictionary< string, string > options=null)
 Creates an instance (proc) of the user-defined function (UDF) specified by the given command, options, and files, and makes it available for execution. More...
 
CreateProjectionResponse createProjection (CreateProjectionRequest request_)
 Creates a new projection of an existing table. More...
 
CreateProjectionResponse createProjection (string table_name, string projection_name, IList< string > column_names, IDictionary< string, string > options=null)
 Creates a new projection of an existing table. More...
 
CreateRoleResponse createRole (CreateRoleRequest request_)
 Creates a new role. More...
 
CreateRoleResponse createRole (string name, IDictionary< string, string > options=null)
 Creates a new role. More...
 
CreateTableResponse createTable (CreateTableRequest request_)
 Creates a new table or collection. More...
 
CreateTableResponse createTable (string table_name, string type_id, IDictionary< string, string > options=null)
 Creates a new table or collection. More...
 
CreateTableMonitorResponse createTableMonitor (CreateTableMonitorRequest request_)
 Creates a monitor that watches for new records inserted into a particular table (identified by ) and forwards copies to subscribers via ZMQ. More...
 
CreateTableMonitorResponse createTableMonitor (string table_name, IDictionary< string, string > options=null)
 Creates a monitor that watches for new records inserted into a particular table (identified by table_name ) and forwards copies to subscribers via ZMQ. More...
 
CreateTriggerByAreaResponse createTriggerByArea (CreateTriggerByAreaRequest request_)
 Sets up an area trigger mechanism for two column_names for one or more tables. More...
 
CreateTriggerByAreaResponse createTriggerByArea (string request_id, IList< string > table_names, string x_column_name, IList< double > x_vector, string y_column_name, IList< double > y_vector, IDictionary< string, string > options=null)
 Sets up an area trigger mechanism for two column_names for one or more tables. More...
 
CreateTriggerByRangeResponse createTriggerByRange (CreateTriggerByRangeRequest request_)
 Sets up a simple range trigger for a column_name for one or more tables. More...
 
CreateTriggerByRangeResponse createTriggerByRange (string request_id, IList< string > table_names, string column_name, double min, double max, IDictionary< string, string > options=null)
 Sets up a simple range trigger for a column_name for one or more tables. More...
 
CreateTypeResponse createType (CreateTypeRequest request_)
 Creates a new type describing the layout or schema of a table. More...
 
CreateTypeResponse createType (string type_definition, string label, IDictionary< string, IList< string >> properties=null, IDictionary< string, string > options=null)
 Creates a new type describing the layout or schema of a table. More...
 
CreateUnionResponse createUnion (CreateUnionRequest request_)
 Merges data from one or more tables with comparable data types into a new table. More...
 
CreateUnionResponse createUnion (string table_name, IList< string > table_names, IList< IList< string >> input_column_names, IList< string > output_column_names, IDictionary< string, string > options=null)
 Merges data from one or more tables with comparable data types into a new table. More...
 
CreateUserExternalResponse createUserExternal (CreateUserExternalRequest request_)
 Creates a new external user (a user whose credentials are managed by an external LDAP). More...
 
CreateUserExternalResponse createUserExternal (string name, IDictionary< string, string > options=null)
 Creates a new external user (a user whose credentials are managed by an external LDAP). More...
 
CreateUserInternalResponse createUserInternal (CreateUserInternalRequest request_)
 Creates a new internal user (a user whose credentials are managed by the database system). More...
 
CreateUserInternalResponse createUserInternal (string name, string password, IDictionary< string, string > options=null)
 Creates a new internal user (a user whose credentials are managed by the database system). More...
 
DeleteProcResponse deleteProc (DeleteProcRequest request_)
 Deletes a proc. More...
 
DeleteProcResponse deleteProc (string proc_name, IDictionary< string, string > options=null)
 Deletes a proc. More...
 
DeleteRecordsResponse deleteRecords (DeleteRecordsRequest request_)
 Deletes record(s) matching the provided criteria from the given table. More...
 
DeleteRecordsResponse deleteRecords (string table_name, IList< string > expressions, IDictionary< string, string > options=null)
 Deletes record(s) matching the provided criteria from the given table. More...
 
DeleteRoleResponse deleteRole (DeleteRoleRequest request_)
 Deletes an existing role. More...
 
DeleteRoleResponse deleteRole (string name, IDictionary< string, string > options=null)
 Deletes an existing role. More...
 
DeleteUserResponse deleteUser (DeleteUserRequest request_)
 Deletes an existing user. More...
 
DeleteUserResponse deleteUser (string name, IDictionary< string, string > options=null)
 Deletes an existing user. More...
 
ExecuteProcResponse executeProc (ExecuteProcRequest request_)
 Executes a proc. More...
 
ExecuteProcResponse executeProc (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)
 Executes a proc. More...
 
FilterResponse filter (FilterRequest request_)
 Filters data based on the specified expression. More...
 
FilterResponse filter (string table_name, string view_name, string expression, IDictionary< string, string > options=null)
 Filters data based on the specified expression. More...
 
FilterByAreaResponse filterByArea (FilterByAreaRequest request_)
 Calculates which objects from a table are within a named area of interest (NAI/polygon). More...
 
FilterByAreaResponse filterByArea (string table_name, string view_name, string x_column_name, IList< double > x_vector, string y_column_name, IList< double > y_vector, IDictionary< string, string > options=null)
 Calculates which objects from a table are within a named area of interest (NAI/polygon). More...
 
FilterByAreaGeometryResponse filterByAreaGeometry (FilterByAreaGeometryRequest request_)
 Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon). More...
 
FilterByAreaGeometryResponse filterByAreaGeometry (string table_name, string view_name, string column_name, IList< double > x_vector, IList< double > y_vector, IDictionary< string, string > options=null)
 Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon). More...
 
FilterByBoxResponse filterByBox (FilterByBoxRequest request_)
 Calculates how many objects within the given table lie in a rectangular box. More...
 
FilterByBoxResponse filterByBox (string table_name, string view_name, string x_column_name, double min_x, double max_x, string y_column_name, double min_y, double max_y, IDictionary< string, string > options=null)
 Calculates how many objects within the given table lie in a rectangular box. More...
 
FilterByBoxGeometryResponse filterByBoxGeometry (FilterByBoxGeometryRequest request_)
 Calculates which geospatial geometry objects from a table intersect a rectangular box. More...
 
FilterByBoxGeometryResponse filterByBoxGeometry (string table_name, string view_name, string column_name, double min_x, double max_x, double min_y, double max_y, IDictionary< string, string > options=null)
 Calculates which geospatial geometry objects from a table intersect a rectangular box. More...
 
FilterByGeometryResponse filterByGeometry (FilterByGeometryRequest request_)
 Applies a geometry filter against a geospatial geometry column in a given table, collection or view. More...
 
FilterByGeometryResponse filterByGeometry (string table_name, string view_name, string column_name, string input_wkt, string operation, IDictionary< string, string > options=null)
 Applies a geometry filter against a geospatial geometry column in a given table, collection or view. More...
 
FilterByListResponse filterByList (FilterByListRequest request_)
 Calculates which records from a table have values in the given list for the corresponding column. More...
 
FilterByListResponse filterByList (string table_name, string view_name, IDictionary< string, IList< string >> column_values_map, IDictionary< string, string > options=null)
 Calculates which records from a table have values in the given list for the corresponding column. More...
 
FilterByRadiusResponse filterByRadius (FilterByRadiusRequest request_)
 Calculates which objects from a table lie within a circle with the given radius and center point (i.e. More...
 
FilterByRadiusResponse filterByRadius (string table_name, string view_name, string x_column_name, double x_center, string y_column_name, double y_center, double radius, IDictionary< string, string > options=null)
 Calculates which objects from a table lie within a circle with the given radius and center point (i.e. More...
 
FilterByRadiusGeometryResponse filterByRadiusGeometry (FilterByRadiusGeometryRequest request_)
 Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e. More...
 
FilterByRadiusGeometryResponse filterByRadiusGeometry (string table_name, string view_name, string column_name, double x_center, double y_center, double radius, IDictionary< string, string > options=null)
 Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e. More...
 
FilterByRangeResponse filterByRange (FilterByRangeRequest request_)
 Calculates which objects from a table have a column that is within the given bounds. More...
 
FilterByRangeResponse filterByRange (string table_name, string view_name, string column_name, double lower_bound, double upper_bound, IDictionary< string, string > options=null)
 Calculates which objects from a table have a column that is within the given bounds. More...
 
FilterBySeriesResponse filterBySeries (FilterBySeriesRequest request_)
 Filters objects matching all points of the given track (works only on track type data). More...
 
FilterBySeriesResponse filterBySeries (string table_name, string view_name, string track_id, IList< string > target_track_ids, IDictionary< string, string > options=null)
 Filters objects matching all points of the given track (works only on track type data). More...
 
FilterByStringResponse filterByString (FilterByStringRequest request_)
 Calculates which objects from a table, collection, or view match a string expression for the given string columns. More...
 
FilterByStringResponse filterByString (string table_name, string view_name, string expression, string mode, IList< string > column_names, IDictionary< string, string > options=null)
 Calculates which objects from a table, collection, or view match a string expression for the given string columns. More...
 
FilterByTableResponse filterByTable (FilterByTableRequest request_)
 Filters objects in one table based on objects in another table. More...
 
FilterByTableResponse filterByTable (string table_name, string view_name, string column_name, string source_table_name, string source_table_column_name, IDictionary< string, string > options=null)
 Filters objects in one table based on objects in another table. More...
 
FilterByValueResponse filterByValue (FilterByValueRequest request_)
 Calculates which objects from a table has a particular value for a particular column. More...
 
FilterByValueResponse filterByValue (string table_name, string view_name, bool is_string, double _value, string value_str, string column_name, IDictionary< string, string > options=null)
 Calculates which objects from a table has a particular value for a particular column. More...
 
GetJobResponse getJob (GetJobRequest request_)
 
Parameters
request_Request object containing the parameters for the operation.
More...
 
GetJobResponse getJob (int job_id, IDictionary< string, string > options=null)
 
Parameters
job_idA unique identifier for the job whose status and result is to be fetched.
More...
 
GetRecordsResponse< T > getRecords< T > (GetRecordsRequest request_)
 Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column. More...
 
GetRecordsResponse< T > getRecords< T > (string table_name, long offset=0, long limit=10000, IDictionary< string, string > options=null)
 Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column. More...
 
GetRecordsByColumnResponse getRecordsByColumn (GetRecordsByColumnRequest request_)
 For a given table, retrieves the values from the requested column(s). More...
 
GetRecordsByColumnResponse getRecordsByColumn (string table_name, IList< string > column_names, long offset, long limit, IDictionary< string, string > options=null)
 For a given table, retrieves the values from the requested column(s). More...
 
GetRecordsBySeriesResponse< T > getRecordsBySeries< T > (GetRecordsBySeriesRequest request_)
 Retrieves the complete series/track records from the given based on the partial track information contained in the . More...
 
GetRecordsBySeriesResponse< T > getRecordsBySeries< T > (string table_name, string world_table_name, int offset=0, int limit=250, IDictionary< string, string > options=null)
 Retrieves the complete series/track records from the given world_table_name based on the partial track information contained in the table_name . More...
 
GetRecordsFromCollectionResponse< T > getRecordsFromCollection< T > (GetRecordsFromCollectionRequest request_)
 Retrieves records from a collection. More...
 
GetRecordsFromCollectionResponse< T > getRecordsFromCollection< T > (string table_name, long offset=0, long limit=10000, IDictionary< string, string > options=null)
 Retrieves records from a collection. More...
 
GrantPermissionSystemResponse grantPermissionSystem (GrantPermissionSystemRequest request_)
 Grants a system-level permission to a user or role. More...
 
GrantPermissionSystemResponse grantPermissionSystem (string name, string permission, IDictionary< string, string > options=null)
 Grants a system-level permission to a user or role. More...
 
GrantPermissionTableResponse grantPermissionTable (GrantPermissionTableRequest request_)
 Grants a table-level permission to a user or role. More...
 
GrantPermissionTableResponse grantPermissionTable (string name, string permission, string table_name, string filter_expression="", IDictionary< string, string > options=null)
 Grants a table-level permission to a user or role. More...
 
GrantRoleResponse grantRole (GrantRoleRequest request_)
 Grants membership in a role to a user or role. More...
 
GrantRoleResponse grantRole (string role, string member, IDictionary< string, string > options=null)
 Grants membership in a role to a user or role. More...
 
HasProcResponse hasProc (HasProcRequest request_)
 Checks the existence of a proc with the given name. More...
 
HasProcResponse hasProc (string proc_name, IDictionary< string, string > options=null)
 Checks the existence of a proc with the given name. More...
 
HasTableResponse hasTable (HasTableRequest request_)
 Checks for the existence of a table with the given name. More...
 
HasTableResponse hasTable (string table_name, IDictionary< string, string > options=null)
 Checks for the existence of a table with the given name. More...
 
HasTypeResponse hasType (HasTypeRequest request_)
 Check for the existence of a type. More...
 
HasTypeResponse hasType (string type_id, IDictionary< string, string > options=null)
 Check for the existence of a type. More...
 
InsertRecordsResponse insertRecordsRaw (RawInsertRecordsRequest request_)
 Adds multiple records to the specified table. More...
 
InsertRecordsResponse insertRecords< T > (InsertRecordsRequest< T > request_)
 Adds multiple records to the specified table. More...
 
InsertRecordsResponse insertRecords< T > (string table_name, IList< T > data, IDictionary< string, string > options=null)
 Adds multiple records to the specified table. More...
 
InsertRecordsRandomResponse insertRecordsRandom (InsertRecordsRandomRequest request_)
 Generates a specified number of random records and adds them to the given table. More...
 
InsertRecordsRandomResponse insertRecordsRandom (string table_name, long count, IDictionary< string, IDictionary< string, double >> options=null)
 Generates a specified number of random records and adds them to the given table. More...
 
InsertSymbolResponse insertSymbol (InsertSymbolRequest request_)
 Adds a symbol or icon (i.e. More...
 
InsertSymbolResponse insertSymbol (string symbol_id, string symbol_format, byte[] symbol_data, IDictionary< string, string > options=null)
 Adds a symbol or icon (i.e. More...
 
KillProcResponse killProc (KillProcRequest request_)
 Kills a running proc instance. More...
 
KillProcResponse killProc (string run_id="", IDictionary< string, string > options=null)
 Kills a running proc instance. More...
 
LockTableResponse lockTable (LockTableRequest request_)
 Manages global access to a table's data. More...
 
LockTableResponse lockTable (string table_name, string lock_type=LockTableRequest.LockType.STATUS, IDictionary< string, string > options=null)
 Manages global access to a table's data. More...
 
MergeRecordsResponse mergeRecords (MergeRecordsRequest request_)
 Create a new empty result table (specified by ), and insert all records from source tables (specified by ) based on the field mapping information (specified by ). More...
 
MergeRecordsResponse mergeRecords (string table_name, IList< string > source_table_names, IList< IDictionary< string, string >> field_maps, IDictionary< string, string > options=null)
 Create a new empty result table (specified by table_name ), and insert all records from source tables (specified by source_table_names ) based on the field mapping information (specified by field_maps ). More...
 
RevokePermissionSystemResponse revokePermissionSystem (RevokePermissionSystemRequest request_)
 Revokes a system-level permission from a user or role. More...
 
RevokePermissionSystemResponse revokePermissionSystem (string name, string permission, IDictionary< string, string > options=null)
 Revokes a system-level permission from a user or role. More...
 
RevokePermissionTableResponse revokePermissionTable (RevokePermissionTableRequest request_)
 Revokes a table-level permission from a user or role. More...
 
RevokePermissionTableResponse revokePermissionTable (string name, string permission, string table_name, IDictionary< string, string > options=null)
 Revokes a table-level permission from a user or role. More...
 
RevokeRoleResponse revokeRole (RevokeRoleRequest request_)
 Revokes membership in a role from a user or role. More...
 
RevokeRoleResponse revokeRole (string role, string member, IDictionary< string, string > options=null)
 Revokes membership in a role from a user or role. More...
 
ShowProcResponse showProc (ShowProcRequest request_)
 Shows information about a proc. More...
 
ShowProcResponse showProc (string proc_name="", IDictionary< string, string > options=null)
 Shows information about a proc. More...
 
ShowProcStatusResponse showProcStatus (ShowProcStatusRequest request_)
 Shows the statuses of running or completed proc instances. More...
 
ShowProcStatusResponse showProcStatus (string run_id="", IDictionary< string, string > options=null)
 Shows the statuses of running or completed proc instances. More...
 
ShowSecurityResponse showSecurity (ShowSecurityRequest request_)
 Shows security information relating to users and/or roles. More...
 
ShowSecurityResponse showSecurity (IList< string > names, IDictionary< string, string > options=null)
 Shows security information relating to users and/or roles. More...
 
ShowSystemPropertiesResponse showSystemProperties (ShowSystemPropertiesRequest request_)
 Returns server configuration and version related information to the caller. More...
 
ShowSystemPropertiesResponse showSystemProperties (IDictionary< string, string > options=null)
 Returns server configuration and version related information to the caller. More...
 
ShowSystemStatusResponse showSystemStatus (ShowSystemStatusRequest request_)
 Provides server configuration and health related status to the caller. More...
 
ShowSystemStatusResponse showSystemStatus (IDictionary< string, string > options=null)
 Provides server configuration and health related status to the caller. More...
 
ShowSystemTimingResponse showSystemTiming (ShowSystemTimingRequest request_)
 Returns the last 100 database requests along with the request timing and internal job id. More...
 
ShowSystemTimingResponse showSystemTiming (IDictionary< string, string > options=null)
 Returns the last 100 database requests along with the request timing and internal job id. More...
 
ShowTableResponse showTable (ShowTableRequest request_)
 Retrieves detailed information about tables, views, and collections. More...
 
ShowTableResponse showTable (string table_name, IDictionary< string, string > options=null)
 Retrieves detailed information about tables, views, and collections. More...
 
ShowTableMetadataResponse showTableMetadata (ShowTableMetadataRequest request_)
 Retrieves the user provided metadata for the specified tables. More...
 
ShowTableMetadataResponse showTableMetadata (IList< string > table_names, IDictionary< string, string > options=null)
 Retrieves the user provided metadata for the specified tables. More...
 
ShowTablesByTypeResponse showTablesByType (ShowTablesByTypeRequest request_)
 Gets names of the tables whose type matches the given criteria. More...
 
ShowTablesByTypeResponse showTablesByType (string type_id, string label, IDictionary< string, string > options=null)
 Gets names of the tables whose type matches the given criteria. More...
 
ShowTriggersResponse showTriggers (ShowTriggersRequest request_)
 Retrieves information regarding the specified triggers or all existing triggers currently active. More...
 
ShowTriggersResponse showTriggers (IList< string > trigger_ids, IDictionary< string, string > options=null)
 Retrieves information regarding the specified triggers or all existing triggers currently active. More...
 
ShowTypesResponse showTypes (ShowTypesRequest request_)
 Retrieves information for the specified data type ID or type label. More...
 
ShowTypesResponse showTypes (string type_id, string label, IDictionary< string, string > options=null)
 Retrieves information for the specified data type ID or type label. More...
 
UpdateRecordsResponse updateRecordsRaw (RawUpdateRecordsRequest request_)
 Runs multiple predicate-based updates in a single call. More...
 
UpdateRecordsResponse updateRecords< T > (UpdateRecordsRequest< T > request_)
 Runs multiple predicate-based updates in a single call. More...
 
UpdateRecordsResponse updateRecords< T > (string table_name, IList< string > expressions, IList< IDictionary< string, string >> new_values_maps, IList< T > data=null, IDictionary< string, string > options=null)
 Runs multiple predicate-based updates in a single call. More...
 
UpdateRecordsBySeriesResponse updateRecordsBySeries (UpdateRecordsBySeriesRequest request_)
 Updates the view specified by to include full series (track) information from the for the series (tracks) present in the . More...
 
UpdateRecordsBySeriesResponse updateRecordsBySeries (string table_name, string world_table_name, string view_name="", IList< string > reserved=null, IDictionary< string, string > options=null)
 Updates the view specified by table_name to include full series (track) information from the world_table_name for the series (tracks) present in the view_name . More...
 
VisualizeImageChartResponse visualizeImageChart (VisualizeImageChartRequest request_)
 Scatter plot is the only plot type currently supported. More...
 
VisualizeImageChartResponse visualizeImageChart (string table_name, IList< string > x_column_names, IList< string > y_column_names, double min_x, double max_x, double min_y, double max_y, int width, int height, string bg_color, IDictionary< string, IList< string >> style_options, IDictionary< string, string > options=null)
 Scatter plot is the only plot type currently supported. More...
 

Static Public Member Functions

static string GetApiVersion ()
 API Version More...
 

Public Attributes

const int END_OF_SET = -9999
 No Limit More...
 
const string API_VERSION = "6.2.0.1"
 

Properties

string Url [get]
 URL for Kinetica Server (including "http:" and port) as a string More...
 
Uri URL [get]
 URL for Kinetica Server (including "http:" and port) More...
 
string Username [get]
 Optional: User Name for Kinetica security More...
 
bool UseSnappy = null [get, set]
 Use Snappy More...
 
int ThreadCount = false [get, set]
 Thread Count More...
 

Detailed Description

API to talk to Kinetica Database

Definition at line 40 of file Kinetica.cs.

Constructor & Destructor Documentation

◆ Kinetica()

kinetica.Kinetica.Kinetica ( string  url_str,
Options  options = null 
)
inline

API Constructor

Parameters
url_strURL for Kinetica Server (including "http:" and port)
optionsOptional connection options

Definition at line 128 of file Kinetica.cs.

Member Function Documentation

◆ AddTableType()

void kinetica.Kinetica.AddTableType ( string  table_name,
Type  obj_type 
)
inline

Given a table name, add its record type to enable proper encoding of records for insertion or updates.

Parameters
table_nameName of the table.
obj_typeThe type associated with the table.

Definition at line 158 of file Kinetica.cs.

◆ adminAlterJobs() [1/2]

AdminAlterJobsResponse kinetica.Kinetica.adminAlterJobs ( AdminAlterJobsRequest  request_)
inline

Perform the requested action on a list of one or more job(s).

Based on the type of job and the current state of execution, the action may not be successfully executed. The final result of the attempted actions for each specified job is returned in the status array of the response. See Job Manager for more information.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 37 of file KineticaFunctions.cs.

◆ adminAlterJobs() [2/2]

AdminAlterJobsResponse kinetica.Kinetica.adminAlterJobs ( IList< int >  job_ids,
string  action,
IDictionary< string, string >  options = null 
)
inline

Perform the requested action on a list of one or more job(s).

Based on the type of job and the current state of execution, the action may not be successfully executed. The final result of the attempted actions for each specified job is returned in the status array of the response. See Job Manager for more information.

Parameters
job_idsJobs to be modified.
actionAction to be performed on the jobs specified by job_ids. Supported values:
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 69 of file KineticaFunctions.cs.

◆ adminOffline() [1/2]

AdminOfflineResponse kinetica.Kinetica.adminOffline ( AdminOfflineRequest  request_)
inline

Take the system offline.

When the system is offline, no user operations can be performed with the exception of a system shutdown.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 87 of file KineticaFunctions.cs.

◆ adminOffline() [2/2]

AdminOfflineResponse kinetica.Kinetica.adminOffline ( bool  offline,
IDictionary< string, string >  options = null 
)
inline

Take the system offline.

When the system is offline, no user operations can be performed with the exception of a system shutdown.

Parameters
offlineSet to true if desired state is offline. Supported values:
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 135 of file KineticaFunctions.cs.

◆ adminShowAlerts() [1/2]

AdminShowAlertsResponse kinetica.Kinetica.adminShowAlerts ( AdminShowAlertsRequest  request_)
inline

Retrieves a list of the most recent alerts generated.

The number of alerts to retrieve is specified in this request. Returns lists of alert data, earliest to latest

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 152 of file KineticaFunctions.cs.

◆ adminShowAlerts() [2/2]

AdminShowAlertsResponse kinetica.Kinetica.adminShowAlerts ( int  num_alerts,
IDictionary< string, string >  options = null 
)
inline

Retrieves a list of the most recent alerts generated.

The number of alerts to retrieve is specified in this request. Returns lists of alert data, earliest to latest

Parameters
num_alertsNumber of most recent alerts to request. The response will return alerts, or less if there are less in the system. A value of 0 returns all stored alerts.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 175 of file KineticaFunctions.cs.

◆ adminShowJobs() [1/2]

AdminShowJobsResponse kinetica.Kinetica.adminShowJobs ( AdminShowJobsRequest  request_)
inline

Get a list of the current jobs in GPUdb.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 190 of file KineticaFunctions.cs.

◆ adminShowJobs() [2/2]

AdminShowJobsResponse kinetica.Kinetica.adminShowJobs ( IDictionary< string, string >  options = null)
inline

Get a list of the current jobs in GPUdb.

Parameters
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 224 of file KineticaFunctions.cs.

◆ adminShowShards() [1/2]

AdminShowShardsResponse kinetica.Kinetica.adminShowShards ( AdminShowShardsRequest  request_)
inline

Show the mapping of shards to the corresponding rank and tom.

The response message contains list of 16384 (total number of shards in the system) Rank and TOM numbers corresponding to each shard.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 241 of file KineticaFunctions.cs.

◆ adminShowShards() [2/2]

AdminShowShardsResponse kinetica.Kinetica.adminShowShards ( IDictionary< string, string >  options = null)
inline

Show the mapping of shards to the corresponding rank and tom.

The response message contains list of 16384 (total number of shards in the system) Rank and TOM numbers corresponding to each shard.

Parameters
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 260 of file KineticaFunctions.cs.

◆ adminShutdown() [1/2]

AdminShutdownResponse kinetica.Kinetica.adminShutdown ( AdminShutdownRequest  request_)
inline

Exits the database server application.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 274 of file KineticaFunctions.cs.

◆ adminShutdown() [2/2]

AdminShutdownResponse kinetica.Kinetica.adminShutdown ( string  exit_type,
string  authorization,
IDictionary< string, string >  options = null 
)
inline

Exits the database server application.

Parameters
exit_typeReserved for future use. User can pass an empty string.
authorizationNo longer used. User can pass an empty string.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 294 of file KineticaFunctions.cs.

◆ adminVerifyDb() [1/2]

AdminVerifyDbResponse kinetica.Kinetica.adminVerifyDb ( AdminVerifyDbRequest  request_)
inline

Verify database is in a consistent state.

When inconsistencies or errors are found, the verified_ok flag in the response is set to false and the list of errors found is provided in the error_list.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 314 of file KineticaFunctions.cs.

◆ adminVerifyDb() [2/2]

AdminVerifyDbResponse kinetica.Kinetica.adminVerifyDb ( IDictionary< string, string >  options = null)
inline

Verify database is in a consistent state.

When inconsistencies or errors are found, the verified_ok flag in the response is set to false and the list of errors found is provided in the error_list.

Parameters
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 371 of file KineticaFunctions.cs.

◆ aggregateConvexHull() [1/2]

AggregateConvexHullResponse kinetica.Kinetica.aggregateConvexHull ( AggregateConvexHullRequest  request_)
inline

Calculates and returns the convex hull for the values in a table specified by .

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 387 of file KineticaFunctions.cs.

◆ aggregateConvexHull() [2/2]

AggregateConvexHullResponse kinetica.Kinetica.aggregateConvexHull ( string  table_name,
string  x_column_name,
string  y_column_name,
IDictionary< string, string >  options = null 
)
inline

Calculates and returns the convex hull for the values in a table specified by table_name .

Parameters
table_nameName of table on which the operation will be performed. Must be an existing table. It cannot be a collection.
x_column_nameName of the column containing the x coordinates of the points for the operation being performed.
y_column_nameName of the column containing the y coordinates of the points for the operation being performed.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 413 of file KineticaFunctions.cs.

◆ aggregateGroupBy() [1/2]

AggregateGroupByResponse kinetica.Kinetica.aggregateGroupBy ( AggregateGroupByRequest  request_)
inline

Calculates unique combinations (groups) of values for the given columns in a given table/view/collection and computes aggregates on each unique combination.

This is somewhat analogous to an SQL-style SELECT...GROUP BY.
For aggregation details and examples, see Aggregation. For limitations, see Aggregation Limitations.
Any column(s) can be grouped on, and all column types except unrestricted-length strings may be used for computing applicable aggregates; columns marked as store-only are unable to be used in grouping or aggregation.
The results can be paged via the and parameters. For example, to get 10 groups with the largest counts the inputs would be: limit=10, options={"sort_order":"descending", "sort_by":"value"}.
can be used to customize behavior of this call e.g. filtering or sorting the results.
To group by columns 'x' and 'y' and compute the number of objects within each group, use: column_names=['x','y','count(*)'].
To also compute the sum of 'z' over each group, use: column_names=['x','y','count(*)','sum(z)'].
Available aggregation functions are: count(*), sum, min, max, avg, mean, stddev, stddev_pop, stddev_samp, var, var_pop, var_samp, arg_min, arg_max and count_distinct.
Available grouping functions are Rollup, Cube, and Grouping Sets
This service also provides support for Pivot operations.
Filtering on aggregates is supported via expressions using aggregation functions supplied to having.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.
If a result_table name is specified in the , the results are stored in a new table with that name–no results are returned in the response. Both the table name and resulting column names must adhere to standard naming conventions; column/aggregation expressions will need to be aliased. If the source table's shard key is used as the grouping column(s) and all result records are selected ( is 0 and is -9999), the result table will be sharded, in all other cases it will be replicated. Sorting will properly function only if the result table is replicated or if there is only one processing node and should not be relied upon in other cases. Not available when any of the values of is an unrestricted-length string.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 508 of file KineticaFunctions.cs.

◆ aggregateGroupBy() [2/2]

AggregateGroupByResponse kinetica.Kinetica.aggregateGroupBy ( string  table_name,
IList< string >  column_names,
long  offset,
long  limit = 1000,
IDictionary< string, string >  options = null 
)
inline

Calculates unique combinations (groups) of values for the given columns in a given table/view/collection and computes aggregates on each unique combination.

This is somewhat analogous to an SQL-style SELECT...GROUP BY.
For aggregation details and examples, see Aggregation. For limitations, see Aggregation Limitations.
Any column(s) can be grouped on, and all column types except unrestricted-length strings may be used for computing applicable aggregates; columns marked as store-only are unable to be used in grouping or aggregation.
The results can be paged via the offset and limit parameters. For example, to get 10 groups with the largest counts the inputs would be: limit=10, options={"sort_order":"descending", "sort_by":"value"}.
options can be used to customize behavior of this call e.g. filtering or sorting the results.
To group by columns 'x' and 'y' and compute the number of objects within each group, use: column_names=['x','y','count(*)'].
To also compute the sum of 'z' over each group, use: column_names=['x','y','count(*)','sum(z)'].
Available aggregation functions are: count(*), sum, min, max, avg, mean, stddev, stddev_pop, stddev_samp, var, var_pop, var_samp, arg_min, arg_max and count_distinct.
Available grouping functions are Rollup, Cube, and Grouping Sets
This service also provides support for Pivot operations.
Filtering on aggregates is supported via expressions using aggregation functions supplied to having.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.
If a result_table name is specified in the options , the results are stored in a new table with that name–no results are returned in the response. Both the table name and resulting column names must adhere to standard naming conventions; column/aggregation expressions will need to be aliased. If the source table's shard key is used as the grouping column(s) and all result records are selected (offset is 0 and limit is -9999), the result table will be sharded, in all other cases it will be replicated. Sorting will properly function only if the result table is replicated or if there is only one processing node and should not be relied upon in other cases. Not available when any of the values of column_names is an unrestricted-length string.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table/view/collection.
column_namesList of one or more column names, expressions, and aggregate expressions.
offsetA positive integer indicating the number of initial results to skip (this can be useful for paging through the results). The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of results to be returned Or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is 1000.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the table specified in result_table. If the collection provided is non-existent, the collection will be automatically created. If empty, then the table will be a top-level table. Additionally this option is invalid if is a collection.
  • EXPRESSION: Filter expression to apply to the table prior to computing the aggregate group by.
  • HAVING: Filter expression to apply to the aggregated results.
  • SORT_ORDER: String indicating how the returned values should be sorted - ascending or descending. Supported values:
    • ASCENDING: Indicates that the returned values should be sorted in ascending order.
    • DESCENDING: Indicates that the returned values should be sorted in descending order.
    The default value is ASCENDING.
  • SORT_BY: String determining how the results are sorted. Supported values:
    • KEY: Indicates that the returned values should be sorted by key, which corresponds to the grouping columns. If you have multiple grouping columns (and are sorting by key), it will first sort the first grouping column, then the second grouping column, etc.
    • VALUE: Indicates that the returned values should be sorted by value, which corresponds to the aggregates. If you have multiple aggregates (and are sorting by value), it will first sort by the first aggregate, then the second aggregate, etc.
    The default value is VALUE.
  • RESULT_TABLE: The name of the table used to store the results. Has the same naming restrictions as tables. Column names (group-by and aggregate fields) need to be given aliases e.g. ["FChar256 as fchar256", "sum(FDouble) as sfd"]. If present, no results are returned in the response. This option is not available if one of the grouping attributes is an unrestricted string (i.e.; not charN) type.
  • RESULT_TABLE_PERSIST: If true, then the result table specified in result_table will be persisted and will not expire unless a ttl is specified. If false, then the result table will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • RESULT_TABLE_FORCE_REPLICATED: Force the result table to be replicated (ignores any sharding). Must be used in combination with the result_table option. Supported values: The default value is FALSE.
  • RESULT_TABLE_GENERATE_PK: If 'true' then set a primary key for the result table. Must be used in combination with the result_table option. Supported values: The default value is FALSE.
  • TTL: Sets the TTL of the table specified in result_table.
  • CHUNK_SIZE: Indicates the chunk size to be used for the result table. Must be used in combination with the result_table option.
  • CREATE_INDEXES: Comma-separated list of columns on which to create indexes on the result table. Must be used in combination with the result_table option.
  • VIEW_ID: view this result table is part of. The default value is ''.
  • MATERIALIZE_ON_GPU: If true then the columns of the groupby result table will be cached on the GPU. Must be used in combination with the result_table option. Supported values: The default value is FALSE.
  • PIVOT: pivot column
  • PIVOT_VALUES: The value list provided will become the column headers in the output. Should be the values from the pivot_column.
  • GROUPING_SETS: Customize the grouping attribute sets to compute the aggregates. These sets can include ROLLUP or CUBE operartors. The attribute sets should be enclosed in paranthesis and can include composite attributes. All attributes specified in the grouping sets must present in the groupby attributes.
  • ROLLUP: This option is used to specify the multilevel aggregates.
  • CUBE: This option is used to specify the multidimensional aggregates.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 843 of file KineticaFunctions.cs.

◆ aggregateHistogram() [1/2]

AggregateHistogramResponse kinetica.Kinetica.aggregateHistogram ( AggregateHistogramRequest  request_)
inline

Performs a histogram calculation given a table, a column, and an interval function.

The is used to produce bins of that size and the result, computed over the records falling within each bin, is returned. For each bin, the start value is inclusive, but the end value is exclusive–except for the very last bin for which the end value is also inclusive. The value returned for each bin is the number of records in it, except when a column name is provided as a value_column. In this latter case the sum of the values corresponding to the value_column is used as the result instead. The total number of bins requested cannot exceed 10,000.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service a request that specifies a value_column option.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 878 of file KineticaFunctions.cs.

◆ aggregateHistogram() [2/2]

AggregateHistogramResponse kinetica.Kinetica.aggregateHistogram ( string  table_name,
string  column_name,
double  start,
double  end,
double  interval,
IDictionary< string, string >  options = null 
)
inline

Performs a histogram calculation given a table, a column, and an interval function.

The interval is used to produce bins of that size and the result, computed over the records falling within each bin, is returned. For each bin, the start value is inclusive, but the end value is exclusive–except for the very last bin for which the end value is also inclusive. The value returned for each bin is the number of records in it, except when a column name is provided as a value_column. In this latter case the sum of the values corresponding to the value_column is used as the result instead. The total number of bins requested cannot exceed 10,000.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service a request that specifies a value_column option.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table or collection.
column_nameName of a column or an expression of one or more column names over which the histogram will be calculated.
startLower end value of the histogram interval, inclusive.
endUpper end value of the histogram interval, inclusive.
intervalThe size of each bin within the start and end parameters.
optionsOptional parameters.
  • VALUE_COLUMN: The name of the column to use when calculating the bin values (values are summed). The column must be a numerical type (int, double, long, float).
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 929 of file KineticaFunctions.cs.

◆ aggregateKMeans() [1/2]

AggregateKMeansResponse kinetica.Kinetica.aggregateKMeans ( AggregateKMeansRequest  request_)
inline

This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering.

An ideal k-means clustering algorithm selects k points such that the sum of the mean squared distances of each member of the set to the nearest of the k points is minimized. The k-means algorithm however does not necessarily produce such an ideal cluster. It begins with a randomly selected set of k points and then refines the location of the points iteratively and settles to a local minimum. Various parameters and options are provided to control the heuristic search.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service this request.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 963 of file KineticaFunctions.cs.

◆ aggregateKMeans() [2/2]

AggregateKMeansResponse kinetica.Kinetica.aggregateKMeans ( string  table_name,
IList< string >  column_names,
int  k,
double  tolerance,
IDictionary< string, string >  options = null 
)
inline

This endpoint runs the k-means algorithm - a heuristic algorithm that attempts to do k-means clustering.

An ideal k-means clustering algorithm selects k points such that the sum of the mean squared distances of each member of the set to the nearest of the k points is minimized. The k-means algorithm however does not necessarily produce such an ideal cluster. It begins with a randomly selected set of k points and then refines the location of the points iteratively and settles to a local minimum. Various parameters and options are provided to control the heuristic search.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service this request.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table or collection.
column_namesList of column names on which the operation would be performed. If n columns are provided then each of the k result points will have n dimensions corresponding to the n columns.
kThe number of mean points to be determined by the algorithm.
toleranceStop iterating when the distances between successive points is less than the given tolerance.
optionsOptional parameters.
  • WHITEN: When set to 1 each of the columns is first normalized by its stdv - default is not to whiten.
  • MAX_ITERS: Number of times to try to hit the tolerance limit before giving up - default is 10.
  • NUM_TRIES: Number of times to run the k-means algorithm with a different randomly selected starting points - helps avoid local minimum. Default is 1.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1023 of file KineticaFunctions.cs.

◆ aggregateMinMax() [1/2]

AggregateMinMaxResponse kinetica.Kinetica.aggregateMinMax ( AggregateMinMaxRequest  request_)
inline

Calculates and returns the minimum and maximum values of a particular column in a table.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1043 of file KineticaFunctions.cs.

◆ aggregateMinMax() [2/2]

AggregateMinMaxResponse kinetica.Kinetica.aggregateMinMax ( string  table_name,
string  column_name,
IDictionary< string, string >  options = null 
)
inline

Calculates and returns the minimum and maximum values of a particular column in a table.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table.
column_nameName of a column or an expression of one or more column on which the min-max will be calculated.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1064 of file KineticaFunctions.cs.

◆ aggregateMinMaxGeometry() [1/2]

AggregateMinMaxGeometryResponse kinetica.Kinetica.aggregateMinMaxGeometry ( AggregateMinMaxGeometryRequest  request_)
inline

Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1083 of file KineticaFunctions.cs.

◆ aggregateMinMaxGeometry() [2/2]

AggregateMinMaxGeometryResponse kinetica.Kinetica.aggregateMinMaxGeometry ( string  table_name,
string  column_name,
IDictionary< string, string >  options = null 
)
inline

Calculates and returns the minimum and maximum x- and y-coordinates of a particular geospatial geometry column in a table.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table.
column_nameName of a geospatial geometry column on which the min-max will be calculated.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1105 of file KineticaFunctions.cs.

◆ aggregateStatistics() [1/2]

AggregateStatisticsResponse kinetica.Kinetica.aggregateStatistics ( AggregateStatisticsRequest  request_)
inline

Calculates the requested statistics of the given column(s) in a given table.


The available statistics are count (number of total objects), mean, stdv (standard deviation), variance, skew, kurtosis, sum, min, max, weighted_average, cardinality (unique count), estimated_cardinality, percentile and percentile_rank.
Estimated cardinality is calculated by using the hyperloglog approximation technique.
Percentiles and percentile ranks are approximate and are calculated using the t-digest algorithm. They must include the desired percentile/percentile_rank. To compute multiple percentiles each value must be specified separately (i.e. 'percentile(75.0),percentile(99.0),percentile_rank(1234.56),percentile_rank(-5)').
A second, comma-separated value can be added to the percentile statistic to calculate percentile resolution, e.g., a 50th percentile with 200 resolution would be 'percentile(50,200)'.
The weighted average statistic requires a weight_column_name to be specified in . The weighted average is then defined as the sum of the products of times the weight_column_name values divided by the sum of the weight_column_name values.
Additional columns can be used in the calculation of statistics via the additional_column_names option. Values in these columns will be included in the overall aggregate calculation–individual aggregates will not be calculated per additional column. For instance, requesting the count & mean of x and additional_column_names y & z, where x holds the numbers 1-10, y holds 11-20, and z holds 21-30, would return the total number of x, y, & z values (30), and the single average value across all x, y, & z values (15.5).
The response includes a list of key/value pairs of each statistic requested and its corresponding value.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1168 of file KineticaFunctions.cs.

◆ aggregateStatistics() [2/2]

AggregateStatisticsResponse kinetica.Kinetica.aggregateStatistics ( string  table_name,
string  column_name,
string  stats,
IDictionary< string, string >  options = null 
)
inline

Calculates the requested statistics of the given column(s) in a given table.


The available statistics are count (number of total objects), mean, stdv (standard deviation), variance, skew, kurtosis, sum, min, max, weighted_average, cardinality (unique count), estimated_cardinality, percentile and percentile_rank.
Estimated cardinality is calculated by using the hyperloglog approximation technique.
Percentiles and percentile ranks are approximate and are calculated using the t-digest algorithm. They must include the desired percentile/percentile_rank. To compute multiple percentiles each value must be specified separately (i.e. 'percentile(75.0),percentile(99.0),percentile_rank(1234.56),percentile_rank(-5)').
A second, comma-separated value can be added to the percentile statistic to calculate percentile resolution, e.g., a 50th percentile with 200 resolution would be 'percentile(50,200)'.
The weighted average statistic requires a weight_column_name to be specified in options . The weighted average is then defined as the sum of the products of column_name times the weight_column_name values divided by the sum of the weight_column_name values.
Additional columns can be used in the calculation of statistics via the additional_column_names option. Values in these columns will be included in the overall aggregate calculation–individual aggregates will not be calculated per additional column. For instance, requesting the count & mean of column_name x and additional_column_names y & z, where x holds the numbers 1-10, y holds 11-20, and z holds 21-30, would return the total number of x, y, & z values (30), and the single average value across all x, y, & z values (15.5).
The response includes a list of key/value pairs of each statistic requested and its corresponding value.

Parameters
table_nameName of the table on which the statistics operation will be performed.
column_nameName of the primary column for which the statistics are to be calculated.
statsComma separated list of the statistics to calculate, e.g. "sum,mean". Supported values:
  • COUNT: Number of objects (independent of the given column(s)).
  • MEAN: Arithmetic mean (average), equivalent to sum/count.
  • STDV: Sample standard deviation (denominator is count-1).
  • VARIANCE: Unbiased sample variance (denominator is count-1).
  • SKEW: Skewness (third standardized moment).
  • KURTOSIS: Kurtosis (fourth standardized moment).
  • SUM: Sum of all values in the column(s).
  • MIN: Minimum value of the column(s).
  • MAX: Maximum value of the column(s).
  • WEIGHTED_AVERAGE: Weighted arithmetic mean (using the option weight_column_name as the weighting column).
  • CARDINALITY: Number of unique values in the column(s).
  • ESTIMATED_CARDINALITY: Estimate (via hyperloglog technique) of the number of unique values in the column(s).
  • PERCENTILE: Estimate (via t-digest) of the given percentile of the column(s) (percentile(50.0) will be an approximation of the median). Add a second, comma-separated value to calculate percentile resolution, e.g., 'percentile(75,150)'
  • PERCENTILE_RANK: Estimate (via t-digest) of the percentile rank of the given value in the column(s) (if the given value is the median of the column(s), percentile_rank(<median>) will return approximately 50.0).
optionsOptional parameters.
  • ADDITIONAL_COLUMN_NAMES: A list of comma separated column names over which statistics can be accumulated along with the primary column. All columns listed and must be of the same type. Must not include the column specified in and no column can be listed twice.
  • WEIGHT_COLUMN_NAME: Name of column used as weighting attribute for the weighted average statistic.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1340 of file KineticaFunctions.cs.

◆ aggregateStatisticsByRange() [1/2]

AggregateStatisticsByRangeResponse kinetica.Kinetica.aggregateStatisticsByRange ( AggregateStatisticsByRangeRequest  request_)
inline

Divides the given set into bins and calculates statistics of the values of a value-column in each bin.

The bins are based on the values of a given binning-column. The statistics that may be requested are mean, stdv (standard deviation), variance, skew, kurtosis, sum, min, max, first, last and weighted average. In addition to the requested statistics the count of total samples in each bin is returned. This counts vector is just the histogram of the column used to divide the set members into bins. The weighted average statistic requires a weight_column to be specified in . The weighted average is then defined as the sum of the products of the value column times the weight column divided by the sum of the weight column.
There are two methods for binning the set members. In the first, which can be used for numeric valued binning-columns, a min, max and interval are specified. The number of bins, nbins, is the integer upper bound of (max-min)/interval. Values that fall in the range [min+n*interval,min+(n+1)*interval) are placed in the nth bin where n ranges from 0..nbin-2. The final bin is [min+(nbin-1)*interval,max]. In the second method, bin_values specifies a list of binning column values. Binning-columns whose value matches the nth member of the bin_values list are placed in the nth bin. When a list is provided the binning-column must be of type string or int.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service this request.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1387 of file KineticaFunctions.cs.

◆ aggregateStatisticsByRange() [2/2]

AggregateStatisticsByRangeResponse kinetica.Kinetica.aggregateStatisticsByRange ( string  table_name,
string  select_expression,
string  column_name,
string  value_column_name,
string  stats,
double  start,
double  end,
double  interval,
IDictionary< string, string >  options = null 
)
inline

Divides the given set into bins and calculates statistics of the values of a value-column in each bin.

The bins are based on the values of a given binning-column. The statistics that may be requested are mean, stdv (standard deviation), variance, skew, kurtosis, sum, min, max, first, last and weighted average. In addition to the requested statistics the count of total samples in each bin is returned. This counts vector is just the histogram of the column used to divide the set members into bins. The weighted average statistic requires a weight_column to be specified in options . The weighted average is then defined as the sum of the products of the value column times the weight column divided by the sum of the weight column.
There are two methods for binning the set members. In the first, which can be used for numeric valued binning-columns, a min, max and interval are specified. The number of bins, nbins, is the integer upper bound of (max-min)/interval. Values that fall in the range [min+n*interval,min+(n+1)*interval) are placed in the nth bin where n ranges from 0..nbin-2. The final bin is [min+(nbin-1)*interval,max]. In the second method, options bin_values specifies a list of binning column values. Binning-columns whose value matches the nth member of the bin_values list are placed in the nth bin. When a list is provided the binning-column must be of type string or int.
NOTE: The Kinetica instance being accessed must be running a CUDA (GPU-based) build to service this request.

Parameters
table_nameName of the table on which the ranged-statistics operation will be performed.
select_expressionFor a non-empty expression statistics are calculated for those records for which the expression is true. The default value is ''.
column_nameName of the binning-column used to divide the set samples into bins.
value_column_nameName of the value-column for which statistics are to be computed.
statsA string of comma separated list of the statistics to calculate, e.g. 'sum,mean'. Available statistics: mean, stdv (standard deviation), variance, skew, kurtosis, sum.
startThe lower bound of the binning-column.
endThe upper bound of the binning-column.
intervalThe interval of a bin. Set members fall into bin i if the binning-column falls in the range [start+interval*i, start+interval*(i+1)).
optionsMap of optional parameters:
  • ADDITIONAL_COLUMN_NAMES: A list of comma separated value-column names over which statistics can be accumulated along with the primary value_column.
  • BIN_VALUES: A list of comma separated binning-column values. Values that match the nth bin_values value are placed in the nth bin.
  • WEIGHT_COLUMN_NAME: Name of the column used as weighting column for the weighted_average statistic.
  • ORDER_COLUMN_NAME: Name of the column used for candlestick charting techniques.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1476 of file KineticaFunctions.cs.

◆ aggregateUnique() [1/2]

AggregateUniqueResponse kinetica.Kinetica.aggregateUnique ( AggregateUniqueRequest  request_)
inline

Returns all the unique values from a particular column (specified by ) of a particular table or collection (specified by ).

If is a numeric column the values will be in . Otherwise if is a string column the values will be in . The results can be paged via the and parameters.
Columns marked as store-only are unable to be used with this function.
To get the first 10 unique values sorted in descending order would be::
{"limit":"10","sort_order":"descending"}.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.
If a result_table name is specified in the , the results are stored in a new table with that name–no results are returned in the response. Both the table name and resulting column name must adhere to standard naming conventions; any column expression will need to be aliased. If the source table's shard key is used as the , the result table will be sharded, in all other cases it will be replicated. Sorting will properly function only if the result table is replicated or if there is only one processing node and should not be relied upon in other cases. Not available if is a collection or when the value of is an unrestricted-length string.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1550 of file KineticaFunctions.cs.

◆ aggregateUnique() [2/2]

AggregateUniqueResponse kinetica.Kinetica.aggregateUnique ( string  table_name,
string  column_name,
long  offset,
long  limit = 10000,
IDictionary< string, string >  options = null 
)
inline

Returns all the unique values from a particular column (specified by column_name ) of a particular table or collection (specified by table_name ).

If column_name is a numeric column the values will be in . Otherwise if column_name is a string column the values will be in . The results can be paged via the offset and limit parameters.
Columns marked as store-only are unable to be used with this function.
To get the first 10 unique values sorted in descending order options would be::
{"limit":"10","sort_order":"descending"}.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.
If a result_table name is specified in the options , the results are stored in a new table with that name–no results are returned in the response. Both the table name and resulting column name must adhere to standard naming conventions; any column expression will need to be aliased. If the source table's shard key is used as the column_name , the result table will be sharded, in all other cases it will be replicated. Sorting will properly function only if the result table is replicated or if there is only one processing node and should not be relied upon in other cases. Not available if table_name is a collection or when the value of column_name is an unrestricted-length string.

Parameters
table_nameName of an existing table/collection on which the operation will be performed.
column_nameName of the column or an expression containing one or more column names on which the unique function would be applied.
offsetA positive integer indicating the number of initial results to skip (this can be useful for paging through the results). The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of results to be returned. Or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is 10000.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the table specified in result_table. If the collection provided is non-existent, the collection will be automatically created. If empty, then the table will be a top-level table. Additionally this option is invalid if is a collection.
  • EXPRESSION: Optional filter expression to apply to the table.
  • SORT_ORDER: String indicating how the returned values should be sorted. Supported values: The default value is ASCENDING.
  • RESULT_TABLE: The name of the table used to store the results. If present, no results are returned in the response. Has the same naming restrictions as tables. Not available if is a collection or when is an unrestricted-length string.
  • RESULT_TABLE_PERSIST: If true, then the result table specified in result_table will be persisted and will not expire unless a ttl is specified. If false, then the result table will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • RESULT_TABLE_FORCE_REPLICATED: Force the result table to be replicated (ignores any sharding). Must be used in combination with the result_table option. Supported values: The default value is FALSE.
  • RESULT_TABLE_GENERATE_PK: If 'true' then set a primary key for the result table. Must be used in combination with the result_table option. Supported values: The default value is FALSE.
  • TTL: Sets the TTL of the table specified in result_table.
  • CHUNK_SIZE: Indicates the chunk size to be used for the result table. Must be used in combination with the result_table option.
  • VIEW_ID: view this result table is part of. The default value is ''.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1754 of file KineticaFunctions.cs.

◆ aggregateUnpivot() [1/2]

AggregateUnpivotResponse kinetica.Kinetica.aggregateUnpivot ( AggregateUnpivotRequest  request_)
inline

Rotate the column values into rows values.


For unpivot details and examples, see Unpivot. For limitations, see Unpivot Limitations.
Unpivot is used to normalize tables that are built for cross tabular reporting purposes. The unpivot operator rotates the column values for all the pivoted columns. A variable column, value column and all columns from the source table except the unpivot columns are projected into the result table. The variable column and value columns in the result table indicate the pivoted column name and values respectively.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 1790 of file KineticaFunctions.cs.

◆ aggregateUnpivot() [2/2]

AggregateUnpivotResponse kinetica.Kinetica.aggregateUnpivot ( string  table_name,
IList< string >  column_names,
string  variable_column_name,
string  value_column_name,
IList< string >  pivoted_columns,
IDictionary< string, string >  options = null 
)
inline

Rotate the column values into rows values.


For unpivot details and examples, see Unpivot. For limitations, see Unpivot Limitations.
Unpivot is used to normalize tables that are built for cross tabular reporting purposes. The unpivot operator rotates the column values for all the pivoted columns. A variable column, value column and all columns from the source table except the unpivot columns are projected into the result table. The variable column and value columns in the result table indicate the pivoted column name and values respectively.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.

Parameters
table_nameName of the table on which the operation will be performed. Must be an existing table/view.
column_namesList of column names or expressions. A wildcard '*' can be used to include all the non-pivoted columns from the source table.
variable_column_nameSpecifies the variable/parameter column name. The default value is ''.
value_column_nameSpecifies the value column name. The default value is ''.
pivoted_columnsList of one or more values typically the column names of the input table. All the columns in the source table must have the same data type.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the table specified in result_table. If the collection provided is non-existent, the collection will be automatically created. If empty, then the table will be a top-level table.
  • RESULT_TABLE: The name of the table used to store the results. Has the same naming restrictions as tables. If present, no results are returned in the response.
  • RESULT_TABLE_PERSIST: If true, then the result table specified in result_table will be persisted and will not expire unless a ttl is specified. If false, then the result table will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • EXPRESSION: Filter expression to apply to the table prior to unpivot processing.
  • ORDER_BY: Comma-separated list of the columns to be sorted by; e.g. 'timestamp asc, x desc'. The columns specified must be present in input table. If any alias is given for any column name, the alias must be used, rather than the original column name. The default value is ''.
  • CHUNK_SIZE: Indicates the chunk size to be used for the result table. Must be used in combination with the result_table option.
  • LIMIT: The number of records to keep. The default value is ''.
  • TTL: Sets the TTL of the table specified in result_table.
  • VIEW_ID: view this result table is part of. The default value is ''.
  • MATERIALIZE_ON_GPU: If true then the output columns will be cached on the GPU. Supported values: The default value is FALSE.
  • CREATE_INDEXES: Comma-separated list of columns on which to create indexes on the table specified in result_table. The columns specified must be present in output column names. If any alias is given for any column name, the alias must be used, rather than the original column name.
  • RESULT_TABLE_FORCE_REPLICATED: Force the result table to be replicated (ignores any sharding). Must be used in combination with the result_table option. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 1969 of file KineticaFunctions.cs.

◆ alterSystemProperties() [1/2]

AlterSystemPropertiesResponse kinetica.Kinetica.alterSystemProperties ( AlterSystemPropertiesRequest  request_)
inline

The Kinetica.alterSystemProperties(IDictionary<string, string>,IDictionary<string, string>) endpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution.

Commands are given through the whose keys are commands and values are strings representing integer values (for example '8000') or boolean values ('true' or 'false').

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2000 of file KineticaFunctions.cs.

◆ alterSystemProperties() [2/2]

AlterSystemPropertiesResponse kinetica.Kinetica.alterSystemProperties ( IDictionary< string, string >  property_updates_map,
IDictionary< string, string >  options = null 
)
inline

The Kinetica.alterSystemProperties(IDictionary<string, string>,IDictionary<string, string>) endpoint is primarily used to simplify the testing of the system and is not expected to be used during normal execution.

Commands are given through the property_updates_map whose keys are commands and values are strings representing integer values (for example '8000') or boolean values ('true' or 'false').

Parameters
property_updates_mapMap containing the properties of the system to be updated. Error if empty.
  • SM_OMP_THREADS: Set the number of OpenMP threads that will be used to service filter & aggregation requests against collections to the specified integer value.
  • KERNEL_OMP_THREADS: Set the number of kernel OpenMP threads to the specified integer value.
  • CONCURRENT_KERNEL_EXECUTION: Enables concurrent kernel execution if the value is true and disables it if the value is false. Supported values:
  • CHUNK_SIZE: Sets the chunk size of all new sets to the specified integer value.
  • EXECUTION_MODE: Sets the execution_mode for kernel executions to the specified string value. Possible values are host, device, default (engine decides) or an integer value that indicates max chunk size to exec on host
  • FLUSH_TO_DISK: Flushes any changes to any tables to the persistent store. These changes include updates to the vector store, object store, and text search store, Value string is ignored
  • CLEAR_CACHE: Clears cached results. Useful to allow repeated timing of endpoints. Value string is ignored
  • COMMUNICATOR_TEST: Invoke the communicator test and report timing results. Value string is is a comma separated list of <key>=

    expressions. Expressions are: num_transactions=<num> where num is the number of request reply transactions to invoke per test; message_size=<bytes> where bytes is the size of the messages to send in bytes; check_values=<enabled> where if enabled is true the value of the messages received are verified.

  • SET_MESSAGE_TIMERS_ENABLED: Enables the communicator test to collect additional timing statistics when the value string is true. Disables the collection when the value string is false Supported values:
  • BULK_ADD_TEST: Invoke the bulk add test and report timing results. Value string is ignored.
  • NETWORK_SPEED: Invoke the network speed test and report timing results. Value string is a semicolon-separated list of <key>=

    expressions. Valid expressions are: seconds=<time> where time is the time in seconds to run the test; data_size=<size> where size is the size in bytes of the block to be transferred; threads=<number of="" threads>="">; to_ranks=<space-separated list of ranks> where the list of ranks is the ranks that rank 0 will send data to and get data from. If to_ranks is unspecified then all worker ranks are used.

  • REQUEST_TIMEOUT: Number of minutes after which filtering (e.g., /filter) and aggregating (e.g., /aggregate/groupby) queries will timeout. The default value is '20'.
  • MAX_GET_RECORDS_SIZE: The maximum number of records the database will serve for a given data retrieval call. The default value is '20000'.
  • MEMORY_ALLOCATION_LIMIT_MB: Set the memory allocation limit for all rank processes in megabytes, 0 means no limit. Overrides any individual rank memory allocation limits. The default value is '0'.
  • ENABLE_AUDIT: Enable or disable auditing.
  • AUDIT_HEADERS: Enable or disable auditing of request headers.
  • AUDIT_BODY: Enable or disable auditing of request bodies.
  • AUDIT_DATA: Enable or disable auditing of request data.
  • ENABLE_JOB_MANAGER: Enable JobManager to enforce processing of requests in the order received.
  • CHUNK_CACHE_ENABLED: Enable chunk level query caching. Flushes the chunk cache when value is false
  • CHUNK_CACHE_SIZE: Size of the chunk cache in bytes. The default value is '10000000'.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2197 of file KineticaFunctions.cs.

◆ alterTable() [1/2]

AlterTableResponse kinetica.Kinetica.alterTable ( AlterTableRequest  request_)
inline

Apply various modifications to a table, view, or collection.

The available modifications include the following:
Create or delete an index on a particular column. This can speed up certain operations when using expressions containing equality or relational operators on indexed columns. This only applies to tables.
Set the time-to-live (TTL). This can be applied to tables, views, or collections. When applied to collections, every contained table & view that is not protected will have its TTL set to the given value.
Set the global access mode (i.e. locking) for a table. This setting trumps any role-based access controls that may be in place; e.g., a user with write access to a table marked read-only will not be able to insert records into it. The mode can be set to read-only, write-only, read/write, and no access.
Change the protection mode to prevent or allow automatic expiration. This can be applied to tables, views, and collections.
Allow homogeneous tables within a collection.
Manage a table's columns–a column can be added, removed, or have its type and properties modified.
Set or unset compression for a column.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2256 of file KineticaFunctions.cs.

◆ alterTable() [2/2]

AlterTableResponse kinetica.Kinetica.alterTable ( string  table_name,
string  action,
string  _value,
IDictionary< string, string >  options = null 
)
inline

Apply various modifications to a table, view, or collection.

The available modifications include the following:
Create or delete an index on a particular column. This can speed up certain operations when using expressions containing equality or relational operators on indexed columns. This only applies to tables.
Set the time-to-live (TTL). This can be applied to tables, views, or collections. When applied to collections, every contained table & view that is not protected will have its TTL set to the given value.
Set the global access mode (i.e. locking) for a table. This setting trumps any role-based access controls that may be in place; e.g., a user with write access to a table marked read-only will not be able to insert records into it. The mode can be set to read-only, write-only, read/write, and no access.
Change the protection mode to prevent or allow automatic expiration. This can be applied to tables, views, and collections.
Allow homogeneous tables within a collection.
Manage a table's columns–a column can be added, removed, or have its type and properties modified.
Set or unset compression for a column.

Parameters
table_nameTable on which the operation will be performed. Must be an existing table, view, or collection.
actionModification operation to be applied Supported values:
  • ALLOW_HOMOGENEOUS_TABLES: Sets whether homogeneous tables are allowed in the given collection. This action is only valid if is a collection. The must be either 'true' or 'false'.
  • CREATE_INDEX: Creates an index on the column name specified in . If this column is already indexed, an error will be returned.
  • DELETE_INDEX: Deletes an existing index on the column name specified in . If this column does not have indexing turned on, an error will be returned.
  • MOVE_TO_COLLECTION: Moves a table into a collection .
  • PROTECTED: Sets whether the given should be protected or not. The must be either 'true' or 'false'.
  • RENAME_TABLE: Renames a table, view or collection to . Has the same naming restrictions as tables.
  • TTL: Sets the time-to-live in minutes of the table, view, or collection specified in .
  • MEMORY_TTL: Sets the time-to-live in minutes for the individual chunks of the columns of the table, view, or collection specified in to free their memory if unused longer than the given time. Specify an empty string to restore the global memory_ttl setting and a value of '-1' for an infinite timeout.
  • ADD_COLUMN: Adds the column specified in to the table specified in . Use column_type and column_properties in to set the column's type and properties, respectively.
  • CHANGE_COLUMN: Changes type and properties of the column specified in . Use column_type and column_properties in to set the column's type and properties, respectively. Note that primary key and/or shard key columns cannot be changed. All unchanging column properties must be listed for the change to take place, e.g., to add dictionary encoding to an existing 'char4' column, both 'char4' and 'dict' must be specified in the map.
  • SET_COLUMN_COMPRESSION: Modifies the compression setting on the column specified in .
  • DELETE_COLUMN: Deletes the column specified in from the table specified in .
  • CREATE_FOREIGN_KEY: Creates a foreign key using the format '(source_column_name [, ...]) references target_table_name(primary_key_column_name [, ...]) [as foreign_key_name]'.
  • DELETE_FOREIGN_KEY: Deletes a foreign key. The should be the foreign_key_name specified when creating the key or the complete string used to define it.
  • SET_GLOBAL_ACCESS_MODE: Sets the global access mode (i.e. locking) for the table specified in . Specify the access mode in . Valid modes are 'no_access', 'read_only', 'write_only' and 'read_write'.
  • REFRESH: Replays all the table creation commands required to create this materialized view.
  • SET_REFRESH_METHOD: Sets the method by which this materialized view is refreshed - one of 'manual', 'periodic', 'on_change'.
  • SET_REFRESH_START_TIME: Sets the time to start periodic refreshes of this materialized view to datetime string with format 'YYYY-MM-DD HH:MM:SS'. Subsequent refreshes occur at the specified time + N * the refresh period.
  • SET_REFRESH_PERIOD: Sets the time interval in seconds at which to refresh this materialized view. Also, sets the refresh method to periodic if not alreay set.
  • REMOVE_TEXT_SEARCH_ATTRIBUTES: remove text_search attribute from all columns, if exists.
_valueThe value of the modification. May be a column name, 'true' or 'false', a TTL, or the global access mode depending on .
optionsOptional parameters.
  • COLUMN_DEFAULT_VALUE: When adding a column, set a default value for existing records. For nullable columns, the default value will be null, regardless of data type.
  • COLUMN_PROPERTIES: When adding or changing a column, set the column properties (strings, separated by a comma: data, store_only, text_search, char8, int8 etc).
  • COLUMN_TYPE: When adding or changing a column, set the column type (strings, separated by a comma: int, double, string, null etc).
  • COMPRESSION_TYPE: When setting column compression (set_column_compression for ), compression type to use: none (to use no compression) or a valid compression type. Supported values: The default value is SNAPPY.
  • COPY_VALUES_FROM_COLUMN: please see add_column_expression instead.
  • RENAME_COLUMN: When changing a column, specify new column name.
  • VALIDATE_CHANGE_COLUMN: When changing a column, validate the change before applying it. If true, then validate all values. A value too large (or too long) for the new type will prevent any change. If false, then when a value is too large or long, it will be truncated. Supported values: The default value is TRUE.
  • UPDATE_LAST_ACCESS_TIME: Indicates whether need to update the last_access_time. Supported values: The default value is TRUE.
  • ADD_COLUMN_EXPRESSION: expression for new column's values (optional with add_column). Any valid expressions including existing columns.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2612 of file KineticaFunctions.cs.

◆ alterTableMetadata() [1/2]

AlterTableMetadataResponse kinetica.Kinetica.alterTableMetadata ( AlterTableMetadataRequest  request_)
inline

Updates (adds or changes) metadata for tables.

The metadata key and values must both be strings. This is an easy way to annotate whole tables rather than single records within tables. Some examples of metadata are owner of the table, table creation timestamp etc.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2633 of file KineticaFunctions.cs.

◆ alterTableMetadata() [2/2]

AlterTableMetadataResponse kinetica.Kinetica.alterTableMetadata ( IList< string >  table_names,
IDictionary< string, string >  metadata_map,
IDictionary< string, string >  options = null 
)
inline

Updates (adds or changes) metadata for tables.

The metadata key and values must both be strings. This is an easy way to annotate whole tables rather than single records within tables. Some examples of metadata are owner of the table, table creation timestamp etc.

Parameters
table_namesNames of the tables whose metadata will be updated. All specified tables must exist, or an error will be returned.
metadata_mapA map which contains the metadata of the tables that are to be updated. Note that only one map is provided for all the tables; so the change will be applied to every table. If the provided map is empty, then all existing metadata for the table(s) will be cleared.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2661 of file KineticaFunctions.cs.

◆ alterUser() [1/2]

AlterUserResponse kinetica.Kinetica.alterUser ( AlterUserRequest  request_)
inline

Alters a user.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2679 of file KineticaFunctions.cs.

◆ alterUser() [2/2]

AlterUserResponse kinetica.Kinetica.alterUser ( string  name,
string  action,
string  _value,
IDictionary< string, string >  options = null 
)
inline

Alters a user.

Parameters
nameName of the user to be altered. Must be an existing user.
actionModification operation to be applied to the user. Supported values:
  • SET_PASSWORD: Sets the password of the user. The user must be an internal user.
_valueThe value of the modification, depending on .
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2710 of file KineticaFunctions.cs.

◆ appendRecords() [1/2]

AppendRecordsResponse kinetica.Kinetica.appendRecords ( AppendRecordsRequest  request_)
inline

Append (or insert) all records from a source table (specified by ) to a particular target table (specified by ).

The field map (specified by ) holds the user specified map of target table column names with their mapped source column names.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2734 of file KineticaFunctions.cs.

◆ appendRecords() [2/2]

AppendRecordsResponse kinetica.Kinetica.appendRecords ( string  table_name,
string  source_table_name,
IDictionary< string, string >  field_map,
IDictionary< string, string >  options = null 
)
inline

Append (or insert) all records from a source table (specified by source_table_name ) to a particular target table (specified by table_name ).

The field map (specified by field_map ) holds the user specified map of target table column names with their mapped source column names.

Parameters
table_nameThe table name for the records to be appended. Must be an existing table.
source_table_nameThe source table name to get records from. Must be an existing table name.
field_mapContains the mapping of column names from the target table (specified by ) as the keys, and corresponding column names or expressions (e.g., 'col_name+1') from the source table (specified by ). Must be existing column names in source table and target table, and their types must be matched. For details on using expressions, see Expressions.
optionsOptional parameters.
  • OFFSET: A positive integer indicating the number of initial results to skip from source table (specified by ). Default is 0. The minimum allowed value is 0. The maximum allowed value is MAX_INT. The default value is '0'.
  • LIMIT: A positive integer indicating the maximum number of results to be returned from source table (specified by ). Or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is '-9999'.
  • EXPRESSION: Optional filter expression to apply to the source table (specified by ). Empty by default. The default value is ''.
  • ORDER_BY: Comma-separated list of the columns and expressions to be sorted by from the source table (specified by ); e.g. 'timestamp asc, x desc'. The order_by columns do not have to be present in . The default value is ''.
  • UPDATE_ON_EXISTING_PK: Specifies the record collision policy for inserting the source table records (specified by ) into the target table (specified by ) table with a primary key. If set to true, any existing target table record with primary key values that match those of a source table record being inserted will be replaced by that new record. If set to false, any existing target table record with primary key values that match those of a source table record being inserted will remain unchanged and the new record discarded. If the specified table does not have a primary key, then this option is ignored. Supported values: The default value is FALSE.
  • TRUNCATE_STRINGS: If set to true, it allows inserting unrestricted length strings into charN string columns by truncating the unrestricted length strings to fit. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2858 of file KineticaFunctions.cs.

◆ clearTable() [1/2]

ClearTableResponse kinetica.Kinetica.clearTable ( ClearTableRequest  request_)
inline

Clears (drops) one or all tables in the database cluster.

The operation is synchronous meaning that the table will be cleared before the function returns. The response payload returns the status of the operation along with the name of the table that was cleared.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2880 of file KineticaFunctions.cs.

◆ clearTable() [2/2]

ClearTableResponse kinetica.Kinetica.clearTable ( string  table_name = "",
string  authorization = "",
IDictionary< string, string >  options = null 
)
inline

Clears (drops) one or all tables in the database cluster.

The operation is synchronous meaning that the table will be cleared before the function returns. The response payload returns the status of the operation along with the name of the table that was cleared.

Parameters
table_nameName of the table to be cleared. Must be an existing table. Empty string clears all available tables, though this behavior is be prevented by default via gpudb.conf parameter 'disable_clear_all'. The default value is ''.
authorizationNo longer used. User can pass an empty string. The default value is ''.
optionsOptional parameters.
  • NO_ERROR_IF_NOT_EXISTS: If true and if the table specified in does not exist no error is returned. If false and if the table specified in does not exist then an error is returned. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2930 of file KineticaFunctions.cs.

◆ clearTableMonitor() [1/2]

ClearTableMonitorResponse kinetica.Kinetica.clearTableMonitor ( ClearTableMonitorRequest  request_)
inline

Deactivates a table monitor previously created with Kinetica.createTableMonitor(string,IDictionary<string, string>).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2948 of file KineticaFunctions.cs.

◆ clearTableMonitor() [2/2]

ClearTableMonitorResponse kinetica.Kinetica.clearTableMonitor ( string  topic_id,
IDictionary< string, string >  options = null 
)
inline

Deactivates a table monitor previously created with Kinetica.createTableMonitor(string,IDictionary<string, string>).

Parameters
topic_idThe topic ID returned by /create/tablemonitor.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 2968 of file KineticaFunctions.cs.

◆ clearTrigger() [1/2]

ClearTriggerResponse kinetica.Kinetica.clearTrigger ( ClearTriggerRequest  request_)
inline

Clears or cancels the trigger identified by the specified handle.

The output returns the handle of the trigger cleared as well as indicating success or failure of the trigger deactivation.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 2986 of file KineticaFunctions.cs.

◆ clearTrigger() [2/2]

ClearTriggerResponse kinetica.Kinetica.clearTrigger ( string  trigger_id,
IDictionary< string, string >  options = null 
)
inline

Clears or cancels the trigger identified by the specified handle.

The output returns the handle of the trigger cleared as well as indicating success or failure of the trigger deactivation.

Parameters
trigger_idID for the trigger to be deactivated.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3007 of file KineticaFunctions.cs.

◆ createJob() [1/2]

CreateJobResponse kinetica.Kinetica.createJob ( CreateJobRequest  request_)
inline

Create a job which will run asynchronously.

The response returns a job ID, which can be used to query the status and result of the job. The status and the result of the job upon completion can be requested by Kinetica.getJob(int,IDictionary<string, string>).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3027 of file KineticaFunctions.cs.

◆ createJob() [2/2]

CreateJobResponse kinetica.Kinetica.createJob ( string  endpoint,
string  request_encoding,
byte []  data,
string  data_str,
IDictionary< string, string >  options = null 
)
inline

Create a job which will run asynchronously.

The response returns a job ID, which can be used to query the status and result of the job. The status and the result of the job upon completion can be requested by Kinetica.getJob(int,IDictionary<string, string>).

Parameters
endpointIndicates which endpoint to execute, e.g. '/alter/table'.
request_encodingThe encoding of the request payload for the job. Supported values: The default value is BINARY.
dataBinary-encoded payload for the job to be run asynchronously. The payload must contain the relevant input parameters for the endpoint indicated in . Please see the documentation for the appropriate endpoint to see what values must (or can) be specified. If this parameter is used, then must be binary or snappy.
data_strJSON-encoded payload for the job to be run asynchronously. The payload must contain the relevant input parameters for the endpoint indicated in . Please see the documentation for the appropriate endpoint to see what values must (or can) be specified. If this parameter is used, then must be json.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3086 of file KineticaFunctions.cs.

◆ createJoinTable() [1/2]

CreateJoinTableResponse kinetica.Kinetica.createJoinTable ( CreateJoinTableRequest  request_)
inline

Creates a table that is the result of a SQL JOIN.


For join details and examples see: Joins. For limitations, see Join Limitations and Cautions.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3111 of file KineticaFunctions.cs.

◆ createJoinTable() [2/2]

CreateJoinTableResponse kinetica.Kinetica.createJoinTable ( string  join_table_name,
IList< string >  table_names,
IList< string >  column_names,
IList< string >  expressions = null,
IDictionary< string, string >  options = null 
)
inline

Creates a table that is the result of a SQL JOIN.


For join details and examples see: Joins. For limitations, see Join Limitations and Cautions.

Parameters
join_table_nameName of the join table to be created. Has the same naming restrictions as tables.
table_namesThe list of table names composing the join. Corresponds to a SQL statement FROM clause.
column_namesList of member table columns or column expressions to be included in the join. Columns can be prefixed with 'table_id.column_name', where 'table_id' is the table name or alias. Columns can be aliased via the syntax 'column_name as alias'. Wild cards '*' can be used to include all columns across member tables or 'table_id.*' for all of a single table's columns. Columns and column expressions composing the join must be uniquely named or aliased–therefore, the '*' wild card cannot be used if column names aren't unique across all tables.
expressionsAn optional list of expressions to combine and filter the joined tables. Corresponds to a SQL statement WHERE clause. For details see: expressions. The default value is an empty List.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the join. If the collection provided is non-existent, the collection will be automatically created. If empty, then the join will be at the top level. The default value is ''.
  • MAX_QUERY_DIMENSIONS: The maximum number of tables in a join that can be accessed by a query and are not equated by a foreign-key to primary-key equality predicate
  • OPTIMIZE_LOOKUPS: Use more memory to speed up the joining of tables. Supported values: The default value is FALSE.
  • REFRESH_METHOD: Method by which the join can be refreshed when the data in underlying member tables have changed. Supported values:
    • MANUAL: refresh only occurs when manually requested by calling this endpoint with refresh option set to refresh or full_refresh
    • ON_QUERY: incrementally refresh (refresh just those records added) whenever a new query is issued and new data is inserted into the base table. A full refresh of all the records occurs when a new query is issued and there have been inserts to any non-base-tables since the last query. TTL will be set to not expire; any ttl specified will be ignored.
    • ON_INSERT: incrementally refresh (refresh just those records added) whenever new data is inserted into a base table. A full refresh of all the records occurs when a new query is issued and there have been inserts to any non-base-tables since the last query. TTL will be set to not expire; any ttl specified will be ignored.
    The default value is MANUAL.
  • REFRESH: Do a manual refresh of the join if it exists - throws an error otherwise Supported values:
    • NO_REFRESH: don't refresh
    • REFRESH: incrementally refresh (refresh just those records added) if new data has been inserted into the base table. A full refresh of all the records occurs if there have been inserts to any non-base-tables since the last refresh
    • FULL_REFRESH: always refresh even if no new records have been added. Only refresh method guaranteed to do a full refresh (refresh all the records) if a delete or update has occurred since the last refresh.
    The default value is NO_REFRESH.
  • TTL: Sets the TTL of the join table specified in . Ignored if refresh_method is either on_insert or on_query.
  • VIEW_ID: view this projection is part of. The default value is ''.
  • NO_COUNT: return a count of 0 for the join table for logging and for show_table. optimization needed for large overlapped equi-join stencils. The default value is 'false'.
  • CHUNK_SIZE: Maximum size of a joined-chunk for this table. Defaults to the gpudb.conf file chunk size
  • ALLOW_RIGHT_PRIMARY_KEY_JOIN: When true allows right joins from a key to a primary key to be done as primary key joins. Such a join table cannot be joined to other join tables. When false the right join shall be done as an equi-join. The default value is 'false'.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3300 of file KineticaFunctions.cs.

◆ createMaterializedView() [1/2]

CreateMaterializedViewResponse kinetica.Kinetica.createMaterializedView ( CreateMaterializedViewRequest  request_)
inline

Initiates the process of creating a materialized view, reserving the view's name to prevent other views or tables from being created with that name.


For materialized view details and examples, see Materialized Views.
The response contains , which is used to tag each subsequent operation (projection, union, aggregation, filter, or join) that will compose the view.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3331 of file KineticaFunctions.cs.

◆ createMaterializedView() [2/2]

CreateMaterializedViewResponse kinetica.Kinetica.createMaterializedView ( string  table_name,
IDictionary< string, string >  options = null 
)
inline

Initiates the process of creating a materialized view, reserving the view's name to prevent other views or tables from being created with that name.


For materialized view details and examples, see Materialized Views.
The response contains , which is used to tag each subsequent operation (projection, union, aggregation, filter, or join) that will compose the view.

Parameters
table_nameName of the table to be created that is the top-level table of the materialized view.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created table will be a top-level table.
  • TTL: Sets the TTL of the table specified in .
  • PERSIST: If true, then the materialized view specified in will be persisted and will not expire unless a ttl is specified. If false, then the materialized view will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • REFRESH_METHOD: Method by which the join can be refreshed when the data in underlying member tables have changed. Supported values:
    • MANUAL: Refresh only occurs when manually requested by calling /alter/table with an 'action' of 'refresh'
    • ON_QUERY: For future use.
    • ON_CHANGE: If possible, incrementally refresh (refresh just those records added) whenever an insert, update, delete or refresh of input table is done. A full refresh is done if an incremental refresh is not possible.
    • PERIODIC: Refresh table periodically at rate specified by refresh_period
    The default value is MANUAL.
  • REFRESH_PERIOD: When refresh_method is periodic, specifies the period in seconds at which refresh occurs
  • REFRESH_START_TIME: When refresh_method is periodic, specifies the first time at which a refresh is to be done. Value is a datetime string with format 'YYYY-MM-DD HH:MM:SS'.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3451 of file KineticaFunctions.cs.

◆ createProc() [1/2]

CreateProcResponse kinetica.Kinetica.createProc ( CreateProcRequest  request_)
inline

Creates an instance (proc) of the user-defined function (UDF) specified by the given command, options, and files, and makes it available for execution.

For details on UDFs, see: User-Defined Functions

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3471 of file KineticaFunctions.cs.

◆ createProc() [2/2]

CreateProcResponse kinetica.Kinetica.createProc ( string  proc_name,
string  execution_mode = CreateProcRequest.ExecutionMode.DISTRIBUTED,
IDictionary< string, byte[]>  files = null,
string  command = "",
IList< string >  args = null,
IDictionary< string, string >  options = null 
)
inline

Creates an instance (proc) of the user-defined function (UDF) specified by the given command, options, and files, and makes it available for execution.

For details on UDFs, see: User-Defined Functions

Parameters
proc_nameName of the proc to be created. Must not be the name of a currently existing proc.
execution_modeThe execution mode of the proc. Supported values:
  • DISTRIBUTED: Input table data will be divided into data segments that are distributed across all nodes in the cluster, and the proc command will be invoked once per data segment in parallel. Output table data from each invocation will be saved to the same node as the corresponding input data.
  • NONDISTRIBUTED: The proc command will be invoked only once per execution, and will not have access to any input or output table data.
The default value is DISTRIBUTED.
filesA map of the files that make up the proc. The keys of the map are file names, and the values are the binary contents of the files. The file names may include subdirectory names (e.g. 'subdir/file') but must not resolve to a directory above the root for the proc. The default value is an empty Dictionary.
commandThe command (excluding arguments) that will be invoked when the proc is executed. It will be invoked from the directory containing the proc and may be any command that can be resolved from that directory. It need not refer to a file actually in that directory; for example, it could be 'java' if the proc is a Java application; however, any necessary external programs must be preinstalled on every database node. If the command refers to a file in that directory, it must be preceded with './' as per Linux convention. If not specified, and exactly one file is provided in , that file will be invoked. The default value is ''.
argsAn array of command-line arguments that will be passed to when the proc is executed. The default value is an empty List.
optionsOptional parameters.
  • MAX_CONCURRENCY_PER_NODE: The maximum number of concurrent instances of the proc that will be executed per node. 0 allows unlimited concurrency. The default value is '0'.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3547 of file KineticaFunctions.cs.

◆ createProjection() [1/2]

CreateProjectionResponse kinetica.Kinetica.createProjection ( CreateProjectionRequest  request_)
inline

Creates a new projection of an existing table.

A projection represents a subset of the columns (potentially including derived columns) of a table.
For projection details and examples, see Projections. For limitations, see Projection Limitations and Cautions.
Window functions, which can perform operations like moving averages, are available through this endpoint as well as Kinetica.getRecordsByColumn(string,IList<string>,long,long,IDictionary<string, string>).
A projection can be created with a different shard key than the source table. By specifying shard_key, the projection will be sharded according to the specified columns, regardless of how the source table is sharded. The source table can even be unsharded or replicated.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3589 of file KineticaFunctions.cs.

◆ createProjection() [2/2]

CreateProjectionResponse kinetica.Kinetica.createProjection ( string  table_name,
string  projection_name,
IList< string >  column_names,
IDictionary< string, string >  options = null 
)
inline

Creates a new projection of an existing table.

A projection represents a subset of the columns (potentially including derived columns) of a table.
For projection details and examples, see Projections. For limitations, see Projection Limitations and Cautions.
Window functions, which can perform operations like moving averages, are available through this endpoint as well as Kinetica.getRecordsByColumn(string,IList<string>,long,long,IDictionary<string, string>).
A projection can be created with a different shard key than the source table. By specifying shard_key, the projection will be sharded according to the specified columns, regardless of how the source table is sharded. The source table can even be unsharded or replicated.

Parameters
table_nameName of the existing table on which the projection is to be applied.
projection_nameName of the projection to be created. Has the same naming restrictions as tables.
column_namesList of columns from to be included in the projection. Can include derived columns. Can be specified as aliased via the syntax 'column_name as alias'.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection to which the projection is to be assigned as a child. If the collection provided is non-existent, the collection will be automatically created. If empty, then the projection will be at the top level. The default value is ''.
  • EXPRESSION: An optional filter expression to be applied to the source table prior to the projection. The default value is ''.
  • IS_REPLICATED: If true then the projection will be replicated even if the source table is not. Supported values: The default value is FALSE.
  • LIMIT: The number of records to keep. The default value is ''.
  • ORDER_BY: Comma-separated list of the columns to be sorted by; e.g. 'timestamp asc, x desc'. The columns specified must be present in . If any alias is given for any column name, the alias must be used, rather than the original column name. The default value is ''.
  • MATERIALIZE_ON_GPU: If true then the columns of the projection will be cached on the GPU. Supported values: The default value is FALSE.
  • CHUNK_SIZE: Indicates the chunk size to be used for this table.
  • CREATE_INDEXES: Comma-separated list of columns on which to create indexes on the output table. The columns specified must be present in . If any alias is given for any column name, the alias must be used, rather than the original column name.
  • TTL: Sets the TTL of the projection specified in .
  • SHARD_KEY: Comma-separated list of the columns to be sharded on; e.g. 'column1, column2'. The columns specified must be present in . If any alias is given for any column name, the alias must be used, rather than the original column name. The default value is ''.
  • PERSIST: If true, then the projection specified in will be persisted and will not expire unless a ttl is specified. If false, then the projection will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • PRESERVE_DICT_ENCODING: If true, then columns that were dict encoded in the source table will be dict encoded in the projection table. Supported values: The default value is FALSE.
  • VIEW_ID: view this projection is part of. The default value is ''.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3791 of file KineticaFunctions.cs.

◆ createRole() [1/2]

CreateRoleResponse kinetica.Kinetica.createRole ( CreateRoleRequest  request_)
inline

Creates a new role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3810 of file KineticaFunctions.cs.

◆ createRole() [2/2]

CreateRoleResponse kinetica.Kinetica.createRole ( string  name,
IDictionary< string, string >  options = null 
)
inline

Creates a new role.

Parameters
nameName of the role to be created. Must contain only lowercase letters, digits, and underscores, and cannot begin with a digit. Must not be the same name as an existing user or role.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 3830 of file KineticaFunctions.cs.

◆ createTable() [1/2]

CreateTableResponse kinetica.Kinetica.createTable ( CreateTableRequest  request_)
inline

Creates a new table or collection.

If a new table is being created, the type of the table is given by , which must the be the ID of a currently registered type (i.e. one created via Kinetica.createType(string,string,IDictionary<string, IList<string>>,IDictionary<string, string>)). The table will be created inside a collection if the option collection_name is specified. If that collection does not already exist, it will be created.
To create a new collection, specify the name of the collection in and set the is_collection option to true; will be ignored.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 3857 of file KineticaFunctions.cs.

◆ createTable() [2/2]

CreateTableResponse kinetica.Kinetica.createTable ( string  table_name,
string  type_id,
IDictionary< string, string >  options = null 
)
inline

Creates a new table or collection.

If a new table is being created, the type of the table is given by type_id , which must the be the ID of a currently registered type (i.e. one created via Kinetica.createType(string,string,IDictionary<string, IList<string>>,IDictionary<string, string>)). The table will be created inside a collection if the option collection_name is specified. If that collection does not already exist, it will be created.
To create a new collection, specify the name of the collection in table_name and set the is_collection option to true; type_id will be ignored.

Parameters
table_nameName of the table to be created. Error for requests with existing table of the same name and type id may be suppressed by using the no_error_if_exists option. See Tables for naming restrictions.
type_idID of a currently registered type. All objects added to the newly created table will be of this type. Ignored if is_collection is true.
optionsOptional parameters.
  • NO_ERROR_IF_EXISTS: If true, prevents an error from occurring if the table already exists and is of the given type. If a table with the same ID but a different type exists, it is still an error. Supported values: The default value is FALSE.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created table. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created table will be a top-level table.
  • IS_COLLECTION: Indicates whether the new table to be created will be a collection. Supported values: The default value is FALSE.
  • DISALLOW_HOMOGENEOUS_TABLES: For a collection, indicates whether the collection prohibits containment of multiple tables of exactly the same data type. Supported values: The default value is FALSE.
  • IS_REPLICATED: For a table, indicates the distribution scheme for the table's data. If true, the table will be replicated. If false, the table will be sharded according to the shard key specified in the given , or randomly sharded, if no shard key is specified. Supported values: The default value is FALSE.
  • 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]'.
  • FOREIGN_SHARD_KEY: Foreign shard key of the format 'source_column references shard_by_column from target_table(primary_key_column)'
  • TTL: For a table, sets the TTL of the table specified in .
  • CHUNK_SIZE: Indicates the chunk size to be used for this table.
  • IS_RESULT_TABLE: For a table, indicates whether the table is an in-memory table. A result table cannot contain store_only, text_search, or string columns (charN columns are acceptable), and it will not be retained if the server is restarted. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4044 of file KineticaFunctions.cs.

◆ createTableMonitor() [1/2]

CreateTableMonitorResponse kinetica.Kinetica.createTableMonitor ( CreateTableMonitorRequest  request_)
inline

Creates a monitor that watches for new records inserted into a particular table (identified by ) and forwards copies to subscribers via ZMQ.

After this call completes, subscribe to the returned on the ZMQ table monitor port (default 9002). Each time an insert operation on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that was inserted. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with Kinetica.clearTableMonitor(string,IDictionary<string, string>).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4072 of file KineticaFunctions.cs.

◆ createTableMonitor() [2/2]

CreateTableMonitorResponse kinetica.Kinetica.createTableMonitor ( string  table_name,
IDictionary< string, string >  options = null 
)
inline

Creates a monitor that watches for new records inserted into a particular table (identified by table_name ) and forwards copies to subscribers via ZMQ.

After this call completes, subscribe to the returned on the ZMQ table monitor port (default 9002). Each time an insert operation on the table completes, a multipart message is published for that topic; the first part contains only the topic ID, and each subsequent part contains one binary-encoded Avro object that was inserted. The monitor will continue to run (regardless of whether or not there are any subscribers) until deactivated with Kinetica.clearTableMonitor(string,IDictionary<string, string>).

Parameters
table_nameName of the table to monitor. Must not refer to a collection.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4102 of file KineticaFunctions.cs.

◆ createTriggerByArea() [1/2]

CreateTriggerByAreaResponse kinetica.Kinetica.createTriggerByArea ( CreateTriggerByAreaRequest  request_)
inline

Sets up an area trigger mechanism for two column_names for one or more tables.

(This function is essentially the two-dimensional version of Kinetica.createTriggerByRange(string,IList<string>,string,double,double,IDictionary<string, string>).) Once the trigger has been activated, any record added to the listed tables(s) via Kinetica.insertRecords<T>(string,IList<T>,IDictionary<string, string>) with the chosen columns' values falling within the specified region will trip the trigger. All such records will be queued at the trigger port (by default '9001' but able to be retrieved via Kinetica.showSystemStatus(IDictionary<string, string>)) for any listening client to collect. Active triggers can be cancelled by using the Kinetica.clearTrigger(string,IDictionary<string, string>) endpoint or by clearing all relevant tables.
The output returns the trigger handle as well as indicating success or failure of the trigger activation.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4135 of file KineticaFunctions.cs.

◆ createTriggerByArea() [2/2]

CreateTriggerByAreaResponse kinetica.Kinetica.createTriggerByArea ( string  request_id,
IList< string >  table_names,
string  x_column_name,
IList< double >  x_vector,
string  y_column_name,
IList< double >  y_vector,
IDictionary< string, string >  options = null 
)
inline

Sets up an area trigger mechanism for two column_names for one or more tables.

(This function is essentially the two-dimensional version of Kinetica.createTriggerByRange(string,IList<string>,string,double,double,IDictionary<string, string>).) Once the trigger has been activated, any record added to the listed tables(s) via Kinetica.insertRecords<T>(string,IList<T>,IDictionary<string, string>) with the chosen columns' values falling within the specified region will trip the trigger. All such records will be queued at the trigger port (by default '9001' but able to be retrieved via Kinetica.showSystemStatus(IDictionary<string, string>)) for any listening client to collect. Active triggers can be cancelled by using the Kinetica.clearTrigger(string,IDictionary<string, string>) endpoint or by clearing all relevant tables.
The output returns the trigger handle as well as indicating success or failure of the trigger activation.

Parameters
request_idUser-created ID for the trigger. The ID can be alphanumeric, contain symbols, and must contain at least one character.
table_namesNames of the tables on which the trigger will be activated and maintained.
x_column_nameName of a numeric column on which the trigger is activated. Usually 'x' for geospatial data points.
x_vectorThe respective coordinate values for the region on which the trigger is activated. This usually translates to the x-coordinates of a geospatial region.
y_column_nameName of a second numeric column on which the trigger is activated. Usually 'y' for geospatial data points.
y_vectorThe respective coordinate values for the region on which the trigger is activated. This usually translates to the y-coordinates of a geospatial region. Must be the same length as xvals.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4187 of file KineticaFunctions.cs.

◆ createTriggerByRange() [1/2]

CreateTriggerByRangeResponse kinetica.Kinetica.createTriggerByRange ( CreateTriggerByRangeRequest  request_)
inline

Sets up a simple range trigger for a column_name for one or more tables.

Once the trigger has been activated, any record added to the listed tables(s) via Kinetica.insertRecords<T>(string,IList<T>,IDictionary<string, string>) with the chosen column_name's value falling within the specified range will trip the trigger. All such records will be queued at the trigger port (by default '9001' but able to be retrieved via Kinetica.showSystemStatus(IDictionary<string, string>)) for any listening client to collect. Active triggers can be cancelled by using the Kinetica.clearTrigger(string,IDictionary<string, string>) endpoint or by clearing all relevant tables.
The output returns the trigger handle as well as indicating success or failure of the trigger activation.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4226 of file KineticaFunctions.cs.

◆ createTriggerByRange() [2/2]

CreateTriggerByRangeResponse kinetica.Kinetica.createTriggerByRange ( string  request_id,
IList< string >  table_names,
string  column_name,
double  min,
double  max,
IDictionary< string, string >  options = null 
)
inline

Sets up a simple range trigger for a column_name for one or more tables.

Once the trigger has been activated, any record added to the listed tables(s) via Kinetica.insertRecords<T>(string,IList<T>,IDictionary<string, string>) with the chosen column_name's value falling within the specified range will trip the trigger. All such records will be queued at the trigger port (by default '9001' but able to be retrieved via Kinetica.showSystemStatus(IDictionary<string, string>)) for any listening client to collect. Active triggers can be cancelled by using the Kinetica.clearTrigger(string,IDictionary<string, string>) endpoint or by clearing all relevant tables.
The output returns the trigger handle as well as indicating success or failure of the trigger activation.

Parameters
request_idUser-created ID for the trigger. The ID can be alphanumeric, contain symbols, and must contain at least one character.
table_namesTables on which the trigger will be active.
column_nameName of a numeric column_name on which the trigger is activated.
minThe lower bound (inclusive) for the trigger range.
maxThe upper bound (inclusive) for the trigger range.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4267 of file KineticaFunctions.cs.

◆ createType() [1/2]

CreateTypeResponse kinetica.Kinetica.createType ( CreateTypeRequest  request_)
inline

Creates a new type describing the layout or schema of a table.

The type definition is a JSON string describing the fields (i.e. columns) of the type. Each field consists of a name and a data type. Supported data types are: double, float, int, long, string, and bytes. In addition one or more properties can be specified for each column which customize the memory usage and query availability of that column. Note that some properties are mutually exclusive–i.e. they cannot be specified for any given column simultaneously. One example of mutually exclusive properties are data and store_only.
A single primary key and/or single shard key can be set across one or more columns. If a primary key is specified, then a uniqueness constraint is enforced, in that only a single object can exist with a given primary key. When inserting data into a table with a primary key, depending on the parameters in the request, incoming objects with primary key values that match existing objects will either overwrite (i.e. update) the existing object or will be skipped and not added into the set.
Example of a type definition with some of the parameters::
{"type":"record", "name":"point", "fields":[{"name":"msg_id","type":"string"}, {"name":"x","type":"double"}, {"name":"y","type":"double"}, {"name":"TIMESTAMP","type":"double"}, {"name":"source","type":"string"}, {"name":"group_id","type":"string"}, {"name":"OBJECT_ID","type":"string"}] }
Properties::
{"group_id":["store_only"], "msg_id":["store_only","text_search"] }

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4330 of file KineticaFunctions.cs.

◆ createType() [2/2]

CreateTypeResponse kinetica.Kinetica.createType ( string  type_definition,
string  label,
IDictionary< string, IList< string >>  properties = null,
IDictionary< string, string >  options = null 
)
inline

Creates a new type describing the layout or schema of a table.

The type definition is a JSON string describing the fields (i.e. columns) of the type. Each field consists of a name and a data type. Supported data types are: double, float, int, long, string, and bytes. In addition one or more properties can be specified for each column which customize the memory usage and query availability of that column. Note that some properties are mutually exclusive–i.e. they cannot be specified for any given column simultaneously. One example of mutually exclusive properties are data and store_only.
A single primary key and/or single shard key can be set across one or more columns. If a primary key is specified, then a uniqueness constraint is enforced, in that only a single object can exist with a given primary key. When inserting data into a table with a primary key, depending on the parameters in the request, incoming objects with primary key values that match existing objects will either overwrite (i.e. update) the existing object or will be skipped and not added into the set.
Example of a type definition with some of the parameters::
{"type":"record", "name":"point", "fields":[{"name":"msg_id","type":"string"}, {"name":"x","type":"double"}, {"name":"y","type":"double"}, {"name":"TIMESTAMP","type":"double"}, {"name":"source","type":"string"}, {"name":"group_id","type":"string"}, {"name":"OBJECT_ID","type":"string"}] }
Properties::
{"group_id":["store_only"], "msg_id":["store_only","text_search"] }

Parameters
type_definitiona JSON string describing the columns of the type to be registered.
labelA user-defined description string which can be used to differentiate between tables and types with otherwise identical schemas.
propertiesEach key-value pair specifies the properties to use for a given column where the key is the column name. All keys used must be relevant column names for the given table. Specifying any property overrides the default properties for that column (which is based on the column's data type). Valid values are:
  • DATA: Default property for all numeric and string type columns; makes the column available for GPU queries.
  • TEXT_SEARCH: Valid only for 'string' columns. Enables full text search for string columns. Can be set independently of data and store_only.
  • STORE_ONLY: Persist the column value but do not make it available to queries (e.g. /filter)-i.e. it is mutually exclusive to the data property. Any 'bytes' type column must have a store_only property. This property reduces system memory usage.
  • DISK_OPTIMIZED: Works in conjunction with the data property for string columns. This property reduces system disk usage by disabling reverse string lookups. Queries like /filter, /filter/bylist, and /filter/byvalue work as usual but /aggregate/unique, /aggregate/groupby and /get/records/bycolumn are not allowed on columns with this property.
  • TIMESTAMP: Valid only for 'long' columns. Indicates that this field represents a timestamp and will be provided in milliseconds since the Unix epoch: 00:00:00 Jan 1 1970. Dates represented by a timestamp must fall between the year 1000 and the year 2900.
  • DECIMAL: Valid only for 'string' columns. It represents a SQL type NUMERIC(19, 4) data type. There can be up to 15 digits before the decimal point and up to four digits in the fractional part. The value can be positive or negative (indicated by a minus sign at the beginning). This property is mutually exclusive with the text_search property.
  • DATE: Valid only for 'string' columns. Indicates that this field represents a date and will be provided in the format 'YYYY-MM-DD'. The allowable range is 1000-01-01 through 2900-01-01. This property is mutually exclusive with the text_search property.
  • TIME: Valid only for 'string' columns. Indicates that this field represents a time-of-day and will be provided in the format 'HH:MM:SS.mmm'. The allowable range is 00:00:00.000 through 23:59:59.999. This property is mutually exclusive with the text_search property.
  • DATETIME: Valid only for 'string' columns. Indicates that this field represents a datetime and will be provided in the format 'YYYY-MM-DD HH:MM:SS.mmm'. The allowable range is 1000-01-01 00:00:00.000 through 2900-01-01 23:59:59.999. This property is mutually exclusive with the text_search property.
  • CHAR1: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 1 character.
  • CHAR2: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 2 characters.
  • CHAR4: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 4 characters.
  • CHAR8: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 8 characters.
  • CHAR16: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 16 characters.
  • CHAR32: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 32 characters.
  • CHAR64: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 64 characters.
  • CHAR128: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 128 characters.
  • CHAR256: This property provides optimized memory, disk and query performance for string columns. Strings with this property must be no longer than 256 characters.
  • INT8: This property provides optimized memory and query performance for int columns. Ints with this property must be between -128 and +127 (inclusive)
  • INT16: This property provides optimized memory and query performance for int columns. Ints with this property must be between -32768 and +32767 (inclusive)
  • IPV4: This property provides optimized memory, disk and query performance for string columns representing IPv4 addresses (i.e. 192.168.1.1). Strings with this property must be of the form: A.B.C.D where A, B, C and D are in the range of 0-255.
  • WKT: Valid only for 'string' and 'bytes' columns. Indicates that this field contains geospatial geometry objects in Well-Known Text (WKT) or Well-Known Binary (WKB) format.
  • PRIMARY_KEY: This property indicates that this column will be part of (or the entire) primary key.
  • SHARD_KEY: This property indicates that this column will be part of (or the entire) shard key.
  • NULLABLE: This property indicates that this column is nullable. However, setting this property is insufficient for making the column nullable. The user must declare the type of the column as a union between its regular type and 'null' in the avro schema for the record type in . For example, if a column is of type integer and is nullable, then the entry for the column in the avro schema must be: ['int', 'null']. The C++, C#, Java, and Python APIs have built-in convenience for bypassing setting the avro schema by hand. For those languages, one can use this property as usual and not have to worry about the avro schema for the record.
  • DICT: This property indicates that this column should be dictionary encoded. It can only be used in conjunction with string columns marked with a charN or date property or with int or long columns. This property is appropriate for columns where the cardinality (the number of unique values) is expected to be low, and can save a large amount of memory.
  • INIT_WITH_NOW: For columns with attributes of date, time, datetime or timestamp, at insert time, replace empty strings and invalid timestamps with NOW()
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4626 of file KineticaFunctions.cs.

◆ createUnion() [1/2]

CreateUnionResponse kinetica.Kinetica.createUnion ( CreateUnionRequest  request_)
inline

Merges data from one or more tables with comparable data types into a new table.


The following merges are supported:
UNION (DISTINCT/ALL) - For data set union details and examples, see Union. For limitations, see Union Limitations and Cautions.
INTERSECT (DISTINCT/ALL) - For data set intersection details and examples, see Intersect. For limitations, see Intersect Limitations.
EXCEPT (DISTINCT/ALL) - For data set subtraction details and examples, see Except. For limitations, see Except Limitations.
MERGE VIEWS - For a given set of filtered views on a single table, creates a single filtered view containing all of the unique records across all of the given filtered data sets.
Non-charN 'string' and 'bytes' column types cannot be merged, nor can columns marked as store-only.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4676 of file KineticaFunctions.cs.

◆ createUnion() [2/2]

CreateUnionResponse kinetica.Kinetica.createUnion ( string  table_name,
IList< string >  table_names,
IList< IList< string >>  input_column_names,
IList< string >  output_column_names,
IDictionary< string, string >  options = null 
)
inline

Merges data from one or more tables with comparable data types into a new table.


The following merges are supported:
UNION (DISTINCT/ALL) - For data set union details and examples, see Union. For limitations, see Union Limitations and Cautions.
INTERSECT (DISTINCT/ALL) - For data set intersection details and examples, see Intersect. For limitations, see Intersect Limitations.
EXCEPT (DISTINCT/ALL) - For data set subtraction details and examples, see Except. For limitations, see Except Limitations.
MERGE VIEWS - For a given set of filtered views on a single table, creates a single filtered view containing all of the unique records across all of the given filtered data sets.
Non-charN 'string' and 'bytes' column types cannot be merged, nor can columns marked as store-only.

Parameters
table_nameName of the table to be created. Has the same naming restrictions as tables.
table_namesThe list of table names to merge. Must contain the names of one or more existing tables.
input_column_namesThe list of columns from each of the corresponding input tables.
output_column_namesThe list of names of the columns to be stored in the output table.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the output table. If the collection provided is non-existent, the collection will be automatically created. If empty, the output table will be a top-level table. The default value is ''.
  • MATERIALIZE_ON_GPU: If true, then the columns of the output table will be cached on the GPU. Supported values: The default value is FALSE.
  • MODE: If merge_views, then this operation will merge the provided views. All must be views from the same underlying base table. Supported values:
    • UNION_ALL: Retains all rows from the specified tables.
    • UNION: Retains all unique rows from the specified tables (synonym for union_distinct).
    • UNION_DISTINCT: Retains all unique rows from the specified tables.
    • EXCEPT: Retains all unique rows from the first table that do not appear in the second table (only works on 2 tables).
    • EXCEPT_ALL: Retains all rows(including duplicates) from the first table that do not appear in the second table (only works on 2 tables).
    • INTERSECT: Retains all unique rows that appear in both of the specified tables (only works on 2 tables).
    • INTERSECT_ALL: Retains all rows(including duplicates) that appear in both of the specified tables (only works on 2 tables).
    • MERGE_VIEWS: Merge two or more views (or views of views) of the same base data set into a new view. If this mode is selected AND must be empty. The resulting view would match the results of a SQL OR operation, e.g., if filter 1 creates a view using the expression 'x = 20' and filter 2 creates a view using the expression 'x <= 10', then the merge views operation creates a new view using the expression 'x = 20 OR x <= 10'.
    The default value is UNION_ALL.
  • CHUNK_SIZE: Indicates the chunk size to be used for this table.
  • CREATE_INDEXES: Comma-separated list of columns on which to create indexes on the output table. The columns specified must be present in .
  • TTL: Sets the TTL of the table specified in .
  • PERSIST: If true, then the table specified in will be persisted and will not expire unless a ttl is specified. If false, then the table will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is FALSE.
  • VIEW_ID: view the output table will be a part of. The default value is ''.
  • FORCE_REPLICATED: If true, then the table specified in will be replicated even if the source tables are not. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4903 of file KineticaFunctions.cs.

◆ createUserExternal() [1/2]

CreateUserExternalResponse kinetica.Kinetica.createUserExternal ( CreateUserExternalRequest  request_)
inline

Creates a new external user (a user whose credentials are managed by an external LDAP).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4924 of file KineticaFunctions.cs.

◆ createUserExternal() [2/2]

CreateUserExternalResponse kinetica.Kinetica.createUserExternal ( string  name,
IDictionary< string, string >  options = null 
)
inline

Creates a new external user (a user whose credentials are managed by an external LDAP).

Parameters
nameName of the user to be created. Must exactly match the user's name in the external LDAP, prefixed with a . Must not be the same name as an existing user.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4944 of file KineticaFunctions.cs.

◆ createUserInternal() [1/2]

CreateUserInternalResponse kinetica.Kinetica.createUserInternal ( CreateUserInternalRequest  request_)
inline

Creates a new internal user (a user whose credentials are managed by the database system).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 4960 of file KineticaFunctions.cs.

◆ createUserInternal() [2/2]

CreateUserInternalResponse kinetica.Kinetica.createUserInternal ( string  name,
string  password,
IDictionary< string, string >  options = null 
)
inline

Creates a new internal user (a user whose credentials are managed by the database system).

Parameters
nameName of the user to be created. Must contain only lowercase letters, digits, and underscores, and cannot begin with a digit. Must not be the same name as an existing user or role.
passwordInitial password of the user to be created. May be an empty string for no password.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 4983 of file KineticaFunctions.cs.

◆ DecodeRawBinaryDataUsingRecordType< T >()

void kinetica.Kinetica.DecodeRawBinaryDataUsingRecordType< T > ( KineticaType  record_type,
IList< byte[]>  records_binary,
IList< T >  records 
)
inline

Given a KineticaType object for a certain record type, decode binary data into distinct records (objects).

Template Parameters
TThe type of the records.
Parameters
record_typeThe type for the records.
records_binaryThe binary encoded data to be decoded.
recordsThe decoded objects/records.
Type Constraints
T :new() 

Definition at line 200 of file Kinetica.cs.

◆ DecodeRawBinaryDataUsingSchemaString< T >() [1/2]

void kinetica.Kinetica.DecodeRawBinaryDataUsingSchemaString< T > ( string  schema_string,
IList< byte[]>  records_binary,
IList< T >  records 
)
inline

Given a schema string for a certain record type, decode binary data into distinct records (objects).

Template Parameters
TThe type of the records.
Parameters
schema_stringThe schema for the records.
records_binaryThe binary encoded data to be decoded.
recordsThe decoded objects/records.
Type Constraints
T :new() 

Definition at line 221 of file Kinetica.cs.

◆ DecodeRawBinaryDataUsingSchemaString< T >() [2/2]

void kinetica.Kinetica.DecodeRawBinaryDataUsingSchemaString< T > ( IList< string >  schema_strings,
IList< IList< byte[]>>  lists_records_binary,
IList< IList< T >>  record_lists 
)
inline

Given a list of schema strings, decode binary data into distinct records (objects).

Template Parameters
TThe type of the records.
Parameters
schema_stringsThe schemas for the records.
lists_records_binaryThe binary encoded data to be decoded (the data is in a 2D list).
record_listsThe decoded objects/records in a 2d list.
Type Constraints
T :new() 

Definition at line 245 of file Kinetica.cs.

◆ DecodeRawBinaryDataUsingTypeIDs< T >() [1/2]

void kinetica.Kinetica.DecodeRawBinaryDataUsingTypeIDs< T > ( IList< string >  type_ids,
IList< byte[]>  records_binary,
IList< T >  records 
)
inline

Given IDs of records types registered with Kinetica, decode binary data into distinct records (objects).

Template Parameters
TThe type of the records.
Parameters
type_idsThe IDs for each of the records' types.
records_binaryThe binary encoded data to be decoded.
recordsThe decoded objects/records.
Type Constraints
T :new() 

Definition at line 285 of file Kinetica.cs.

◆ DecodeRawBinaryDataUsingTypeIDs< T >() [2/2]

void kinetica.Kinetica.DecodeRawBinaryDataUsingTypeIDs< T > ( IList< string >  type_ids,
IList< IList< byte[]>>  lists_records_binary,
IList< IList< T >>  record_lists 
)
inline

Given IDs of records types registered with Kinetica, decode binary data into distinct records (objects).

Template Parameters
TThe type of the records.
Parameters
type_idsThe IDs for each of the lists of records.
lists_records_binaryThe binary encoded data to be decoded in a 2d list.
record_listsThe decoded objects/records in a 2d list.
Type Constraints
T :new() 

Definition at line 314 of file Kinetica.cs.

◆ deleteProc() [1/2]

DeleteProcResponse kinetica.Kinetica.deleteProc ( DeleteProcRequest  request_)
inline

Deletes a proc.

Any currently running instances of the proc will be killed.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5001 of file KineticaFunctions.cs.

◆ deleteProc() [2/2]

DeleteProcResponse kinetica.Kinetica.deleteProc ( string  proc_name,
IDictionary< string, string >  options = null 
)
inline

Deletes a proc.

Any currently running instances of the proc will be killed.

Parameters
proc_nameName of the proc to be deleted. Must be the name of a currently existing proc.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5020 of file KineticaFunctions.cs.

◆ deleteRecords() [1/2]

DeleteRecordsResponse kinetica.Kinetica.deleteRecords ( DeleteRecordsRequest  request_)
inline

Deletes record(s) matching the provided criteria from the given table.

The record selection criteria can either be one or more (matching multiple records), a single record identified by record_id options, or all records when using delete_all_records. Note that the three selection criteria are mutually exclusive. This operation cannot be run on a collection or a view. The operation is synchronous meaning that a response will not be available until the request is completely processed and all the matching records are deleted.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5044 of file KineticaFunctions.cs.

◆ deleteRecords() [2/2]

DeleteRecordsResponse kinetica.Kinetica.deleteRecords ( string  table_name,
IList< string >  expressions,
IDictionary< string, string >  options = null 
)
inline

Deletes record(s) matching the provided criteria from the given table.

The record selection criteria can either be one or more expressions (matching multiple records), a single record identified by record_id options, or all records when using delete_all_records. Note that the three selection criteria are mutually exclusive. This operation cannot be run on a collection or a view. The operation is synchronous meaning that a response will not be available until the request is completely processed and all the matching records are deleted.

Parameters
table_nameName of the table from which to delete records. The set must be a currently existing table and not a collection or a view.
expressionsA list of the actual predicates, one for each select; format should follow the guidelines provided here. Specifying one or more is mutually exclusive to specifying record_id in the .
optionsOptional parameters.
  • GLOBAL_EXPRESSION: An optional global expression to reduce the search space of the . The default value is ''.
  • RECORD_ID: A record ID identifying a single record, obtained at the time of /insert/records or by calling /get/records/fromcollection with the return_record_ids option. This option cannot be used to delete records from replicated tables.
  • DELETE_ALL_RECORDS: If set to true, all records in the table will be deleted. If set to false, then the option is effectively ignored. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5119 of file KineticaFunctions.cs.

◆ deleteRole() [1/2]

DeleteRoleResponse kinetica.Kinetica.deleteRole ( DeleteRoleRequest  request_)
inline

Deletes an existing role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5136 of file KineticaFunctions.cs.

◆ deleteRole() [2/2]

DeleteRoleResponse kinetica.Kinetica.deleteRole ( string  name,
IDictionary< string, string >  options = null 
)
inline

Deletes an existing role.

Parameters
nameName of the role to be deleted. Must be an existing role.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5154 of file KineticaFunctions.cs.

◆ deleteUser() [1/2]

DeleteUserResponse kinetica.Kinetica.deleteUser ( DeleteUserRequest  request_)
inline

Deletes an existing user.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5169 of file KineticaFunctions.cs.

◆ deleteUser() [2/2]

DeleteUserResponse kinetica.Kinetica.deleteUser ( string  name,
IDictionary< string, string >  options = null 
)
inline

Deletes an existing user.

Parameters
nameName of the user to be deleted. Must be an existing user.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5187 of file KineticaFunctions.cs.

◆ executeProc() [1/2]

ExecuteProcResponse kinetica.Kinetica.executeProc ( ExecuteProcRequest  request_)
inline

Executes a proc.

This endpoint is asynchronous and does not wait for the proc to complete before returning.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5203 of file KineticaFunctions.cs.

◆ executeProc() [2/2]

ExecuteProcResponse kinetica.Kinetica.executeProc ( 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 
)
inline

Executes a proc.

This endpoint is asynchronous and does not wait for the proc to complete before returning.

Parameters
proc_nameName of the proc to execute. Must be the name of a currently existing proc.
_paramsA map containing named parameters to pass to the proc. Each key/value pair specifies the name of a parameter and its value. The default value is an empty Dictionary.
bin_paramsA map containing named binary parameters to pass to the proc. Each key/value pair specifies the name of a parameter and its value. The default value is an empty Dictionary.
input_table_namesNames of the tables containing data to be passed to the proc. Each name specified must be the name of a currently existing table. If no table names are specified, no data will be passed to the proc. The default value is an empty List.
input_column_namesMap of table names from to lists of names of columns from those tables that will be passed to the proc. Each column name specified must be the name of an existing column in the corresponding table. If a table name from is not included, all columns from that table will be passed to the proc. The default value is an empty Dictionary.
output_table_namesNames of the tables to which output data from the proc will be written. If a specified table does not exist, it will automatically be created with the same schema as the corresponding table (by order) from , excluding any primary and shard keys. If a specified table is a non-persistent result table, it must not have primary or shard keys. If no table names are specified, no output data can be returned from the proc. The default value is an empty List.
optionsOptional parameters.
  • CACHE_INPUT: A comma-delimited list of table names from from which input data will be cached for use in subsequent calls to /execute/proc with the use_cached_input option. Cached input data will be retained until the proc status is cleared with the /show/proc/status option of /show/proc/status and all proc instances using the cached data have completed. The default value is ''.
  • USE_CACHED_INPUT: A comma-delimited list of run IDs (as returned from prior calls to /execute/proc) of running or completed proc instances from which input data cached using the cache_input option will be used. Cached input data will not be used for any tables specified in , but data from all other tables cached for the specified run IDs will be passed to the proc. If the same table was cached for multiple specified run IDs, the cached data from the first run ID specified in the list that includes that table will be used. The default value is ''.
  • KIFS_INPUT_DIRS: A comma-delimited list of KiFS directories whose local files will be made directly accessible to the proc through the API. (All KiFS files, local or not, are also accessible through the file system below the KiFS mount point.) Each name specified must the name of an existing KiFS directory. The default value is ''.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5291 of file KineticaFunctions.cs.

◆ filter() [1/2]

FilterResponse kinetica.Kinetica.filter ( FilterRequest  request_)
inline

Filters data based on the specified expression.

The results are stored in a result set with the given .
For details see Expressions.
The response message contains the number of points for which the expression evaluated to be true, which is equivalent to the size of the result view.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5324 of file KineticaFunctions.cs.

◆ filter() [2/2]

FilterResponse kinetica.Kinetica.filter ( string  table_name,
string  view_name,
string  expression,
IDictionary< string, string >  options = null 
)
inline

Filters data based on the specified expression.

The results are stored in a result set with the given view_name .
For details see Expressions.
The response message contains the number of points for which the expression evaluated to be true, which is equivalent to the size of the result view.

Parameters
table_nameName of the table to filter. This may be the ID of a collection, table or a result set (for chaining queries). If filtering a collection, all child tables where the filter expression is valid will be filtered; the filtered result tables will then be placed in a collection specified by .
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
expressionThe select expression to filter the specified table. For details see Expressions.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
  • VIEW_ID: view this filtered-view is part of. The default value is ''.
  • TTL: Sets the TTL of the view specified in .
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5387 of file KineticaFunctions.cs.

◆ filterByArea() [1/2]

FilterByAreaResponse kinetica.Kinetica.filterByArea ( FilterByAreaRequest  request_)
inline

Calculates which objects from a table are within a named area of interest (NAI/polygon).

The operation is synchronous, meaning that a response will not be returned until all the matching objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input NAI restriction specification is created with the name passed in as part of the input.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5411 of file KineticaFunctions.cs.

◆ filterByArea() [2/2]

FilterByAreaResponse kinetica.Kinetica.filterByArea ( string  table_name,
string  view_name,
string  x_column_name,
IList< double >  x_vector,
string  y_column_name,
IList< double >  y_vector,
IDictionary< string, string >  options = null 
)
inline

Calculates which objects from a table are within a named area of interest (NAI/polygon).

The operation is synchronous, meaning that a response will not be returned until all the matching objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input NAI restriction specification is created with the name view_name passed in as part of the input.

Parameters
table_nameName of the table to filter. This may be the name of a collection, a table or a view (when chaining queries). If filtering a collection, all child tables where the filter expression is valid will be filtered; the filtered result tables will then be placed in a collection specified by .
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
x_column_nameName of the column containing the x values to be filtered.
x_vectorList of x coordinates of the vertices of the polygon representing the area to be filtered.
y_column_nameName of the column containing the y values to be filtered.
y_vectorList of y coordinates of the vertices of the polygon representing the area to be filtered.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5462 of file KineticaFunctions.cs.

◆ filterByAreaGeometry() [1/2]

FilterByAreaGeometryResponse kinetica.Kinetica.filterByAreaGeometry ( FilterByAreaGeometryRequest  request_)
inline

Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon).

The operation is synchronous, meaning that a response will not be returned until all the matching objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input NAI restriction specification is created with the name passed in as part of the input.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5492 of file KineticaFunctions.cs.

◆ filterByAreaGeometry() [2/2]

FilterByAreaGeometryResponse kinetica.Kinetica.filterByAreaGeometry ( string  table_name,
string  view_name,
string  column_name,
IList< double >  x_vector,
IList< double >  y_vector,
IDictionary< string, string >  options = null 
)
inline

Calculates which geospatial geometry objects from a table intersect a named area of interest (NAI/polygon).

The operation is synchronous, meaning that a response will not be returned until all the matching objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input NAI restriction specification is created with the name view_name passed in as part of the input.

Parameters
table_nameName of the table to filter. This may be the name of a collection, a table or a view (when chaining queries). If filtering a collection, all child tables where the filter expression is valid will be filtered; the filtered result tables will then be placed in a collection specified by .
view_nameIf provided, then this will be the name of the view containing the results. Must not be an already existing collection, table or view. The default value is ''.
column_nameName of the geospatial geometry column to be filtered.
x_vectorList of x coordinates of the vertices of the polygon representing the area to be filtered.
y_vectorList of y coordinates of the vertices of the polygon representing the area to be filtered.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5540 of file KineticaFunctions.cs.

◆ filterByBox() [1/2]

FilterByBoxResponse kinetica.Kinetica.filterByBox ( FilterByBoxRequest  request_)
inline

Calculates how many objects within the given table lie in a rectangular box.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set which satisfies the input NAI restriction specification is also created when a is passed in as part of the input payload.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5571 of file KineticaFunctions.cs.

◆ filterByBox() [2/2]

FilterByBoxResponse kinetica.Kinetica.filterByBox ( string  table_name,
string  view_name,
string  x_column_name,
double  min_x,
double  max_x,
string  y_column_name,
double  min_y,
double  max_y,
IDictionary< string, string >  options = null 
)
inline

Calculates how many objects within the given table lie in a rectangular box.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set which satisfies the input NAI restriction specification is also created when a view_name is passed in as part of the input payload.

Parameters
table_nameName of the table on which the bounding box operation will be performed. Must be an existing table.
view_nameOptional name of the result view that will be created containing the results of the query. Has the same naming restrictions as tables. The default value is ''.
x_column_nameName of the column on which to perform the bounding box query. Must be a valid numeric column.
min_xLower bound for the column chosen by . Must be less than or equal to .
max_xUpper bound for . Must be greater than or equal to .
y_column_nameName of a column on which to perform the bounding box query. Must be a valid numeric column.
min_yLower bound for . Must be less than or equal to .
max_yUpper bound for . Must be greater than or equal to .
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5626 of file KineticaFunctions.cs.

◆ filterByBoxGeometry() [1/2]

FilterByBoxGeometryResponse kinetica.Kinetica.filterByBoxGeometry ( FilterByBoxGeometryRequest  request_)
inline

Calculates which geospatial geometry objects from a table intersect a rectangular box.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set which satisfies the input NAI restriction specification is also created when a is passed in as part of the input payload.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5658 of file KineticaFunctions.cs.

◆ filterByBoxGeometry() [2/2]

FilterByBoxGeometryResponse kinetica.Kinetica.filterByBoxGeometry ( string  table_name,
string  view_name,
string  column_name,
double  min_x,
double  max_x,
double  min_y,
double  max_y,
IDictionary< string, string >  options = null 
)
inline

Calculates which geospatial geometry objects from a table intersect a rectangular box.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set which satisfies the input NAI restriction specification is also created when a view_name is passed in as part of the input payload.

Parameters
table_nameName of the table on which the bounding box operation will be performed. Must be an existing table.
view_nameOptional name of the result view that will be created containing the results of the query. Must not be an already existing collection, table or view. The default value is ''.
column_nameName of the geospatial geometry column to be filtered.
min_xLower bound for the x-coordinate of the rectangular box. Must be less than or equal to .
max_xUpper bound for the x-coordinate of the rectangular box. Must be greater than or equal to .
min_yLower bound for the y-coordinate of the rectangular box. Must be less than or equal to .
max_yUpper bound for the y-coordinate of the rectangular box. Must be greater than or equal to .
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5712 of file KineticaFunctions.cs.

◆ filterByGeometry() [1/2]

FilterByGeometryResponse kinetica.Kinetica.filterByGeometry ( FilterByGeometryRequest  request_)
inline

Applies a geometry filter against a geospatial geometry column in a given table, collection or view.

The filtering geometry is provided by .

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5741 of file KineticaFunctions.cs.

◆ filterByGeometry() [2/2]

FilterByGeometryResponse kinetica.Kinetica.filterByGeometry ( string  table_name,
string  view_name,
string  column_name,
string  input_wkt,
string  operation,
IDictionary< string, string >  options = null 
)
inline

Applies a geometry filter against a geospatial geometry column in a given table, collection or view.

The filtering geometry is provided by input_wkt .

Parameters
table_nameName of the table on which the filter by geometry will be performed. Must be an existing table, collection or view containing a geospatial geometry column.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
column_nameName of the column to be used in the filter. Must be a geospatial geometry column.
input_wktA geometry in WKT format that will be used to filter the objects in . The default value is ''.
operationThe geometric filtering operation to perform Supported values:
  • CONTAINS: Matches records that contain the given WKT in , i.e. the given WKT is within the bounds of a record's geometry.
  • CROSSES: Matches records that cross the given WKT.
  • DISJOINT: Matches records that are disjoint from the given WKT.
  • EQUALS: Matches records that are the same as the given WKT.
  • INTERSECTS: Matches records that intersect the given WKT.
  • OVERLAPS: Matches records that overlap the given WKT.
  • TOUCHES: Matches records that touch the given WKT.
  • WITHIN: Matches records that are within the given WKT.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5837 of file KineticaFunctions.cs.

◆ filterByList() [1/2]

FilterByListResponse kinetica.Kinetica.filterByList ( FilterByListRequest  request_)
inline

Calculates which records from a table have values in the given list for the corresponding column.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input filter specification is also created if a is passed in as part of the request.
For example, if a type definition has the columns 'x' and 'y', then a filter by list query with the column map {"x":["10.1", "2.3"], "y":["0.0", "-31.5", "42.0"]} will return the count of all data points whose x and y values match both in the respective x- and y-lists, e.g., "x = 10.1 and y = 0.0", "x = 2.3 and y = -31.5", etc. However, a record with "x = 10.1 and y = -31.5" or "x = 2.3 and y = 0.0" would not be returned because the values in the given lists do not correspond.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5874 of file KineticaFunctions.cs.

◆ filterByList() [2/2]

FilterByListResponse kinetica.Kinetica.filterByList ( string  table_name,
string  view_name,
IDictionary< string, IList< string >>  column_values_map,
IDictionary< string, string >  options = null 
)
inline

Calculates which records from a table have values in the given list for the corresponding column.

The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input filter specification is also created if a view_name is passed in as part of the request.
For example, if a type definition has the columns 'x' and 'y', then a filter by list query with the column map {"x":["10.1", "2.3"], "y":["0.0", "-31.5", "42.0"]} will return the count of all data points whose x and y values match both in the respective x- and y-lists, e.g., "x = 10.1 and y = 0.0", "x = 2.3 and y = -31.5", etc. However, a record with "x = 10.1 and y = -31.5" or "x = 2.3 and y = 0.0" would not be returned because the values in the given lists do not correspond.

Parameters
table_nameName of the table to filter. This may be the ID of a collection, table or a result set (for chaining queries). If filtering a collection, all child tables where the filter expression is valid will be filtered; the filtered result tables will then be placed in a collection specified by .
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
column_values_mapList of values for the corresponding column in the table
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
  • FILTER_MODE: String indicating the filter mode, either 'in_list' or 'not_in_list'. Supported values:
    • IN_LIST: The filter will match all items that are in the provided list(s).
    • NOT_IN_LIST: The filter will match all items that are not in the provided list(s).
    The default value is IN_LIST.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 5950 of file KineticaFunctions.cs.

◆ filterByRadius() [1/2]

FilterByRadiusResponse kinetica.Kinetica.filterByRadius ( FilterByRadiusRequest  request_)
inline

Calculates which objects from a table lie within a circle with the given radius and center point (i.e.

circular NAI). The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input circular NAI restriction specification is also created if a is passed in as part of the request.
For track data, all track points that lie within the circle plus one point on either side of the circle (if the track goes beyond the circle) will be included in the result.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 5980 of file KineticaFunctions.cs.

◆ filterByRadius() [2/2]

FilterByRadiusResponse kinetica.Kinetica.filterByRadius ( string  table_name,
string  view_name,
string  x_column_name,
double  x_center,
string  y_column_name,
double  y_center,
double  radius,
IDictionary< string, string >  options = null 
)
inline

Calculates which objects from a table lie within a circle with the given radius and center point (i.e.

circular NAI). The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input circular NAI restriction specification is also created if a view_name is passed in as part of the request.
For track data, all track points that lie within the circle plus one point on either side of the circle (if the track goes beyond the circle) will be included in the result.

Parameters
table_nameName of the table on which the filter by radius operation will be performed. Must be an existing table.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
x_column_nameName of the column to be used for the x-coordinate (the longitude) of the center.
x_centerValue of the longitude of the center. Must be within [-180.0, 180.0]. The minimum allowed value is -180. The maximum allowed value is 180.
y_column_nameName of the column to be used for the y-coordinate-the latitude-of the center.
y_centerValue of the latitude of the center. Must be within [-90.0, 90.0]. The minimum allowed value is -90. The maximum allowed value is 90.
radiusThe radius of the circle within which the search will be performed. Must be a non-zero positive value. It is in meters; so, for example, a value of '42000' means 42 km. The minimum allowed value is 0. The maximum allowed value is MAX_INT.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6039 of file KineticaFunctions.cs.

◆ filterByRadiusGeometry() [1/2]

FilterByRadiusGeometryResponse kinetica.Kinetica.filterByRadiusGeometry ( FilterByRadiusGeometryRequest  request_)
inline

Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e.

circular NAI). The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input circular NAI restriction specification is also created if a is passed in as part of the request.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6071 of file KineticaFunctions.cs.

◆ filterByRadiusGeometry() [2/2]

FilterByRadiusGeometryResponse kinetica.Kinetica.filterByRadiusGeometry ( string  table_name,
string  view_name,
string  column_name,
double  x_center,
double  y_center,
double  radius,
IDictionary< string, string >  options = null 
)
inline

Calculates which geospatial geometry objects from a table intersect a circle with the given radius and center point (i.e.

circular NAI). The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new resultant set (view) which satisfies the input circular NAI restriction specification is also created if a view_name is passed in as part of the request.

Parameters
table_nameName of the table on which the filter by radius operation will be performed. Must be an existing table.
view_nameIf provided, then this will be the name of the view containing the results. Must not be an already existing collection, table or view. The default value is ''.
column_nameName of the geospatial geometry column to be filtered.
x_centerValue of the longitude of the center. Must be within [-180.0, 180.0]. The minimum allowed value is -180. The maximum allowed value is 180.
y_centerValue of the latitude of the center. Must be within [-90.0, 90.0]. The minimum allowed value is -90. The maximum allowed value is 90.
radiusThe radius of the circle within which the search will be performed. Must be a non-zero positive value. It is in meters; so, for example, a value of '42000' means 42 km. The minimum allowed value is 0. The maximum allowed value is MAX_INT.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6123 of file KineticaFunctions.cs.

◆ filterByRange() [1/2]

FilterByRangeResponse kinetica.Kinetica.filterByRange ( FilterByRangeRequest  request_)
inline

Calculates which objects from a table have a column that is within the given bounds.

An object from the table identified by is added to the view if its column is within [, ] (inclusive). The operation is synchronous. The response provides a count of the number of objects which passed the bound filter. Although this functionality can also be accomplished with the standard filter function, it is more efficient.
For track objects, the count reflects how many points fall within the given bounds (which may not include all the track points of any given track).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6162 of file KineticaFunctions.cs.

◆ filterByRange() [2/2]

FilterByRangeResponse kinetica.Kinetica.filterByRange ( string  table_name,
string  view_name,
string  column_name,
double  lower_bound,
double  upper_bound,
IDictionary< string, string >  options = null 
)
inline

Calculates which objects from a table have a column that is within the given bounds.

An object from the table identified by table_name is added to the view view_name if its column is within [lower_bound , upper_bound ] (inclusive). The operation is synchronous. The response provides a count of the number of objects which passed the bound filter. Although this functionality can also be accomplished with the standard filter function, it is more efficient.
For track objects, the count reflects how many points fall within the given bounds (which may not include all the track points of any given track).

Parameters
table_nameName of the table on which the filter by range operation will be performed. Must be an existing table.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
column_nameName of a column on which the operation would be applied.
lower_boundValue of the lower bound (inclusive).
upper_boundValue of the upper bound (inclusive).
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6213 of file KineticaFunctions.cs.

◆ filterBySeries() [1/2]

FilterBySeriesResponse kinetica.Kinetica.filterBySeries ( FilterBySeriesRequest  request_)
inline

Filters objects matching all points of the given track (works only on track type data).

It allows users to specify a particular track to find all other points in the table that fall within specified ranges-spatial and temporal-of all points of the given track. Additionally, the user can specify another track to see if the two intersect (or go close to each other within the specified ranges). The user also has the flexibility of using different metrics for the spatial distance calculation: Euclidean (flat geometry) or Great Circle (spherical geometry to approximate the Earth's surface distances). The filtered points are stored in a newly created result set. The return value of the function is the number of points in the resultant set (view).
This operation is synchronous, meaning that a response will not be returned until all the objects are fully available.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6248 of file KineticaFunctions.cs.

◆ filterBySeries() [2/2]

FilterBySeriesResponse kinetica.Kinetica.filterBySeries ( string  table_name,
string  view_name,
string  track_id,
IList< string >  target_track_ids,
IDictionary< string, string >  options = null 
)
inline

Filters objects matching all points of the given track (works only on track type data).

It allows users to specify a particular track to find all other points in the table that fall within specified ranges-spatial and temporal-of all points of the given track. Additionally, the user can specify another track to see if the two intersect (or go close to each other within the specified ranges). The user also has the flexibility of using different metrics for the spatial distance calculation: Euclidean (flat geometry) or Great Circle (spherical geometry to approximate the Earth's surface distances). The filtered points are stored in a newly created result set. The return value of the function is the number of points in the resultant set (view).
This operation is synchronous, meaning that a response will not be returned until all the objects are fully available.

Parameters
table_nameName of the table on which the filter by track operation will be performed. Must be a currently existing table with a track present.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
track_idThe ID of the track which will act as the filtering points. Must be an existing track within the given table.
target_track_idsUp to one track ID to intersect with the "filter" track. If any provided, it must be an valid track ID within the given set.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
  • SPATIAL_RADIUS: A positive number passed as a string representing the radius of the search area centered around each track point's geospatial coordinates. The value is interpreted in meters. Required parameter.
  • TIME_RADIUS: A positive number passed as a string representing the maximum allowable time difference between the timestamps of a filtered object and the given track's points. The value is interpreted in seconds. Required parameter.
  • SPATIAL_DISTANCE_METRIC: A string representing the coordinate system to use for the spatial search criteria. Acceptable values are 'euclidean' and 'great_circle'. Optional parameter; default is 'euclidean'. Supported values:
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6337 of file KineticaFunctions.cs.

◆ filterByString() [1/2]

FilterByStringResponse kinetica.Kinetica.filterByString ( FilterByStringRequest  request_)
inline

Calculates which objects from a table, collection, or view match a string expression for the given string columns.

The options 'case_sensitive' can be used to modify the behavior for all modes except 'search'. For 'search' mode details and limitations, see Full Text Search.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6362 of file KineticaFunctions.cs.

◆ filterByString() [2/2]

FilterByStringResponse kinetica.Kinetica.filterByString ( string  table_name,
string  view_name,
string  expression,
string  mode,
IList< string >  column_names,
IDictionary< string, string >  options = null 
)
inline

Calculates which objects from a table, collection, or view match a string expression for the given string columns.

The options 'case_sensitive' can be used to modify the behavior for all modes except 'search'. For 'search' mode details and limitations, see Full Text Search.

Parameters
table_nameName of the table on which the filter operation will be performed. Must be an existing table, collection or view.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
expressionThe expression with which to filter the table.
modeThe string filtering mode to apply. See below for details. Supported values:
  • SEARCH: Full text search query with wildcards and boolean operators. Note that for this mode, no column can be specified in ; all string columns of the table that have text search enabled will be searched.
  • EQUALS: Exact whole-string match (accelerated).
  • CONTAINS: Partial substring match (not accelerated). If the column is a string type (non-charN) and the number of records is too large, it will return 0.
  • STARTS_WITH: Strings that start with the given expression (not accelerated). If the column is a string type (non-charN) and the number of records is too large, it will return 0.
  • REGEX: Full regular expression search (not accelerated). If the column is a string type (non-charN) and the number of records is too large, it will return 0.
column_namesList of columns on which to apply the filter. Ignored for 'search' mode.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
  • CASE_SENSITIVE: If 'false' then string filtering will ignore case. Does not apply to 'search' mode. Supported values: The default value is TRUE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6464 of file KineticaFunctions.cs.

◆ filterByTable() [1/2]

FilterByTableResponse kinetica.Kinetica.filterByTable ( FilterByTableRequest  request_)
inline

Filters objects in one table based on objects in another table.

The user must specify matching column types from the two tables (i.e. the target table from which objects will be filtered and the source table based on which the filter will be created); the column names need not be the same. If a is specified, then the filtered objects will then be put in a newly created view. The operation is synchronous, meaning that a response will not be returned until all objects are fully available in the result view. The return value contains the count (i.e. the size) of the resulting view.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6495 of file KineticaFunctions.cs.

◆ filterByTable() [2/2]

FilterByTableResponse kinetica.Kinetica.filterByTable ( string  table_name,
string  view_name,
string  column_name,
string  source_table_name,
string  source_table_column_name,
IDictionary< string, string >  options = null 
)
inline

Filters objects in one table based on objects in another table.

The user must specify matching column types from the two tables (i.e. the target table from which objects will be filtered and the source table based on which the filter will be created); the column names need not be the same. If a view_name is specified, then the filtered objects will then be put in a newly created view. The operation is synchronous, meaning that a response will not be returned until all objects are fully available in the result view. The return value contains the count (i.e. the size) of the resulting view.

Parameters
table_nameName of the table whose data will be filtered. Must be an existing table.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
column_nameName of the column by whose value the data will be filtered from the table designated by .
source_table_nameName of the table whose data will be compared against in the table called . Must be an existing table.
source_table_column_nameName of the column in the whose values will be used as the filter for table . Must be a geospatial geometry column if in 'spatial' mode; otherwise, Must match the type of the .
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
  • FILTER_MODE: String indicating the filter mode, either in_table or not_in_table. Supported values: The default value is IN_TABLE.
  • MODE: Mode - should be either spatial or normal. Supported values: The default value is NORMAL.
  • BUFFER: Buffer size, in meters. Only relevant for spatial mode. The default value is '0'.
  • BUFFER_METHOD: Method used to buffer polygons. Only relevant for spatial mode. Supported values:
    • NORMAL
    • GEOS: Use geos 1 edge per corner algorithm
    The default value is NORMAL.
  • MAX_PARTITION_SIZE: Maximum number of points in a partition. Only relevant for spatial mode. The default value is '0'.
  • MAX_PARTITION_SCORE: Maximum number of points * edges in a partition. Only relevant for spatial mode. The default value is '8000000'.
  • X_COLUMN_NAME: Name of column containing x value of point being filtered in spatial mode. The default value is 'x'.
  • Y_COLUMN_NAME: Name of column containing y value of point being filtered in spatial mode. The default value is 'y'.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6643 of file KineticaFunctions.cs.

◆ filterByValue() [1/2]

FilterByValueResponse kinetica.Kinetica.filterByValue ( FilterByValueRequest  request_)
inline

Calculates which objects from a table has a particular value for a particular column.

The input parameters provide a way to specify either a String or a Double valued column and a desired value for the column on which the filter is performed. The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new result view which satisfies the input filter restriction specification is also created with a view name passed in as part of the input payload. Although this functionality can also be accomplished with the standard filter function, it is more efficient.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6676 of file KineticaFunctions.cs.

◆ filterByValue() [2/2]

FilterByValueResponse kinetica.Kinetica.filterByValue ( string  table_name,
string  view_name,
bool  is_string,
double  _value,
string  value_str,
string  column_name,
IDictionary< string, string >  options = null 
)
inline

Calculates which objects from a table has a particular value for a particular column.

The input parameters provide a way to specify either a String or a Double valued column and a desired value for the column on which the filter is performed. The operation is synchronous, meaning that a response will not be returned until all the objects are fully available. The response payload provides the count of the resulting set. A new result view which satisfies the input filter restriction specification is also created with a view name passed in as part of the input payload. Although this functionality can also be accomplished with the standard filter function, it is more efficient.

Parameters
table_nameName of an existing table on which to perform the calculation.
view_nameIf provided, then this will be the name of the view containing the results. Has the same naming restrictions as tables. The default value is ''.
is_stringIndicates whether the value being searched for is string or numeric.
_valueThe value to search for. The default value is 0.
value_strThe string value to search for. The default value is ''.
column_nameName of a column on which the filter by value would be applied.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created view. If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created view will be top-level.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6726 of file KineticaFunctions.cs.

◆ GetApiVersion()

static string kinetica.Kinetica.GetApiVersion ( )
inlinestatic

API Version

Returns
Version String for API

Definition at line 77 of file Kinetica.cs.

◆ getJob() [1/2]

GetJobResponse kinetica.Kinetica.getJob ( GetJobRequest  request_)
inline

Parameters
request_Request object containing the parameters for the operation.

Returns
Response object containing the result of the operation.

Definition at line 6747 of file KineticaFunctions.cs.

◆ getJob() [2/2]

GetJobResponse kinetica.Kinetica.getJob ( int  job_id,
IDictionary< string, string >  options = null 
)
inline

Parameters
job_idA unique identifier for the job whose status and result is to be fetched.

Parameters
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 6764 of file KineticaFunctions.cs.

◆ getRecords< T >() [1/2]

GetRecordsResponse<T> kinetica.Kinetica.getRecords< T > ( GetRecordsRequest  request_)
inline

Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.

This operation can be performed on tables, views, or on homogeneous collections (collections containing tables of all the same type). Records can be returned encoded as binary, json or geojson.
This operation supports paging through the data via the and parameters. Note that when paging through a table, if the table (or the underlying table in case of a view) is updated (records are inserted, deleted or modified) the records retrieved may differ between calls based on the updates applied.

Template Parameters
TThe type of object being retrieved.
Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 6793 of file KineticaFunctions.cs.

◆ getRecords< T >() [2/2]

GetRecordsResponse<T> kinetica.Kinetica.getRecords< T > ( string  table_name,
long  offset = 0,
long  limit = 10000,
IDictionary< string, string >  options = null 
)
inline

Retrieves records from a given table, optionally filtered by an expression and/or sorted by a column.

This operation can be performed on tables, views, or on homogeneous collections (collections containing tables of all the same type). Records can be returned encoded as binary, json or geojson.
This operation supports paging through the data via the offset and limit parameters. Note that when paging through a table, if the table (or the underlying table in case of a view) is updated (records are inserted, deleted or modified) the records retrieved may differ between calls based on the updates applied.

Template Parameters
TThe type of object being retrieved.
Parameters
table_nameName of the table from which the records will be fetched. Must be a table, view or homogeneous collection.
offsetA positive integer indicating the number of initial results to skip (this can be useful for paging through the results). The default value is 0.The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of results to be returned. Or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is 10000.
options
  • EXPRESSION: Optional filter expression to apply to the table.
  • FAST_INDEX_LOOKUP: Indicates if indexes should be used to perform the lookup for a given expression if possible. Only applicable if there is no sorting, the expression contains only equivalence comparisons based on existing tables indexes and the range of requested values is from [0 to END_OF_SET]. Supported values: The default value is TRUE.
  • SORT_BY: Optional column that the data should be sorted by. Empty by default (i.e. no sorting is applied).
  • SORT_ORDER: String indicating how the returned values should be sorted - ascending or descending. If sort_order is provided, sort_by has to be provided. Supported values: The default value is ASCENDING.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 6897 of file KineticaFunctions.cs.

◆ getRecordsByColumn() [1/2]

GetRecordsByColumnResponse kinetica.Kinetica.getRecordsByColumn ( GetRecordsByColumnRequest  request_)
inline

For a given table, retrieves the values from the requested column(s).

Maps of column name to the array of values as well as the column data type are returned. This endpoint supports pagination with the and parameters.
Window functions, which can perform operations like moving averages, are available through this endpoint as well as Kinetica.createProjection(string,string,IList<string>,IDictionary<string, string>).
When using pagination, if the table (or the underlying table in the case of a view) is modified (records are inserted, updated, or deleted) during a call to the endpoint, the records or values retrieved may differ between calls based on the type of the update, e.g., the contiguity across pages cannot be relied upon.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 6936 of file KineticaFunctions.cs.

◆ getRecordsByColumn() [2/2]

GetRecordsByColumnResponse kinetica.Kinetica.getRecordsByColumn ( string  table_name,
IList< string >  column_names,
long  offset,
long  limit,
IDictionary< string, string >  options = null 
)
inline

For a given table, retrieves the values from the requested column(s).

Maps of column name to the array of values as well as the column data type are returned. This endpoint supports pagination with the offset and limit parameters.
Window functions, which can perform operations like moving averages, are available through this endpoint as well as Kinetica.createProjection(string,string,IList<string>,IDictionary<string, string>).
When using pagination, if the table (or the underlying table in the case of a view) is modified (records are inserted, updated, or deleted) during a call to the endpoint, the records or values retrieved may differ between calls based on the type of the update, e.g., the contiguity across pages cannot be relied upon.
The response is returned as a dynamic schema. For details see: dynamic schemas documentation.

Parameters
table_nameName of the table on which this operation will be performed. The table cannot be a parent set.
column_namesThe list of column values to retrieve.
offsetA positive integer indicating the number of initial results to skip (this can be useful for paging through the results). The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of results to be returned (if not provided the default is 10000), or END_OF_SET (-9999) to indicate that the maximum number of results allowed by the server should be returned.
options
  • EXPRESSION: Optional filter expression to apply to the table.
  • SORT_BY: Optional column(s) that the data should be sorted by. Empty by default (i.e. no sorting is applied).
  • SORT_ORDER: String indicating how the returned values should be sorted - ascending or descending. If sort_order is provided, sort_by has to be provided. Supported values: The default value is ASCENDING.
  • ORDER_BY: Comma-separated list of the columns to be sorted by; e.g. 'timestamp asc, x desc'. The default value is ''.
  • CONVERT_WKTS_TO_WKBS: If true, then WKT string columns will be returned as WKB bytes. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7050 of file KineticaFunctions.cs.

◆ getRecordsBySeries< T >() [1/2]

GetRecordsBySeriesResponse<T> kinetica.Kinetica.getRecordsBySeries< T > ( GetRecordsBySeriesRequest  request_)
inline

Retrieves the complete series/track records from the given based on the partial track information contained in the .


This operation supports paging through the data via the and parameters.
In contrast to Kinetica.getRecords<T>(string,long,long,IDictionary<string, string>) this returns records grouped by series/track. So if is 0 and is 5 this operation would return the first 5 series/tracks in . Each series/track will be returned sorted by their TIMESTAMP column.

Template Parameters
TThe type of object being retrieved.
Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 7089 of file KineticaFunctions.cs.

◆ getRecordsBySeries< T >() [2/2]

GetRecordsBySeriesResponse<T> kinetica.Kinetica.getRecordsBySeries< T > ( string  table_name,
string  world_table_name,
int  offset = 0,
int  limit = 250,
IDictionary< string, string >  options = null 
)
inline

Retrieves the complete series/track records from the given world_table_name based on the partial track information contained in the table_name .


This operation supports paging through the data via the offset and limit parameters.
In contrast to Kinetica.getRecords<T>(string,long,long,IDictionary<string, string>) this returns records grouped by series/track. So if offset is 0 and limit is 5 this operation would return the first 5 series/tracks in table_name . Each series/track will be returned sorted by their TIMESTAMP column.

Template Parameters
TThe type of object being retrieved.
Parameters
table_nameName of the collection/table/view for which series/tracks will be fetched.
world_table_nameName of the table containing the complete series/track information to be returned for the tracks present in the . Typically this is used when retrieving series/tracks from a view (which contains partial series/tracks) but the user wants to retrieve the entire original series/tracks. Can be blank.
offsetA positive integer indicating the number of initial series/tracks to skip (useful for paging through the results). The default value is 0.The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of series/tracks to be returned. Or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is 250.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 7143 of file KineticaFunctions.cs.

◆ getRecordsFromCollection< T >() [1/2]

GetRecordsFromCollectionResponse<T> kinetica.Kinetica.getRecordsFromCollection< T > ( GetRecordsFromCollectionRequest  request_)
inline

Retrieves records from a collection.

The operation can optionally return the record IDs which can be used in certain queries such as Kinetica.deleteRecords(string,IList<string>,IDictionary<string, string>).
This operation supports paging through the data via the and parameters.
Note that when using the Java API, it is not possible to retrieve records from join tables using this operation.

Template Parameters
TThe type of object being retrieved.
Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 7177 of file KineticaFunctions.cs.

◆ getRecordsFromCollection< T >() [2/2]

GetRecordsFromCollectionResponse<T> kinetica.Kinetica.getRecordsFromCollection< T > ( string  table_name,
long  offset = 0,
long  limit = 10000,
IDictionary< string, string >  options = null 
)
inline

Retrieves records from a collection.

The operation can optionally return the record IDs which can be used in certain queries such as Kinetica.deleteRecords(string,IList<string>,IDictionary<string, string>).
This operation supports paging through the data via the offset and limit parameters.
Note that when using the Java API, it is not possible to retrieve records from join tables using this operation.

Template Parameters
TThe type of object being retrieved.
Parameters
table_nameName of the collection or table from which records are to be retrieved. Must be an existing collection or table.
offsetA positive integer indicating the number of initial results to skip (this can be useful for paging through the results). The default value is 0.The minimum allowed value is 0. The maximum allowed value is MAX_INT.
limitA positive integer indicating the maximum number of results to be returned, or END_OF_SET (-9999) to indicate that the max number of results should be returned. The default value is 10000.
options
  • RETURN_RECORD_IDS: If 'true' then return the internal record ID along with each returned record. Default is 'false'. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.
Type Constraints
T :new() 

Definition at line 7243 of file KineticaFunctions.cs.

◆ grantPermissionSystem() [1/2]

GrantPermissionSystemResponse kinetica.Kinetica.grantPermissionSystem ( GrantPermissionSystemRequest  request_)
inline

Grants a system-level permission to a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7265 of file KineticaFunctions.cs.

◆ grantPermissionSystem() [2/2]

GrantPermissionSystemResponse kinetica.Kinetica.grantPermissionSystem ( string  name,
string  permission,
IDictionary< string, string >  options = null 
)
inline

Grants a system-level permission to a user or role.

Parameters
nameName of the user or role to which the permission will be granted. Must be an existing user or role.
permissionPermission to grant to the user or role. Supported values:
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7305 of file KineticaFunctions.cs.

◆ grantPermissionTable() [1/2]

GrantPermissionTableResponse kinetica.Kinetica.grantPermissionTable ( GrantPermissionTableRequest  request_)
inline

Grants a table-level permission to a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7324 of file KineticaFunctions.cs.

◆ grantPermissionTable() [2/2]

GrantPermissionTableResponse kinetica.Kinetica.grantPermissionTable ( string  name,
string  permission,
string  table_name,
string  filter_expression = "",
IDictionary< string, string >  options = null 
)
inline

Grants a table-level permission to a user or role.

Parameters
nameName of the user or role to which the permission will be granted. Must be an existing user or role.
permissionPermission to grant to the user or role. Supported values:
table_nameName of the table to which the permission grants access. Must be an existing table, collection, or view. If a collection, the permission also applies to tables and views in the collection.
filter_expressionReserved for future use. The default value is ''.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7379 of file KineticaFunctions.cs.

◆ grantRole() [1/2]

GrantRoleResponse kinetica.Kinetica.grantRole ( GrantRoleRequest  request_)
inline

Grants membership in a role to a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7401 of file KineticaFunctions.cs.

◆ grantRole() [2/2]

GrantRoleResponse kinetica.Kinetica.grantRole ( string  role,
string  member,
IDictionary< string, string >  options = null 
)
inline

Grants membership in a role to a user or role.

Parameters
roleName of the role in which membership will be granted. Must be an existing role.
memberName of the user or role that will be granted membership in . Must be an existing user or role.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7422 of file KineticaFunctions.cs.

◆ hasProc() [1/2]

HasProcResponse kinetica.Kinetica.hasProc ( HasProcRequest  request_)
inline

Checks the existence of a proc with the given name.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7439 of file KineticaFunctions.cs.

◆ hasProc() [2/2]

HasProcResponse kinetica.Kinetica.hasProc ( string  proc_name,
IDictionary< string, string >  options = null 
)
inline

Checks the existence of a proc with the given name.

Parameters
proc_nameName of the proc to check for existence.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7458 of file KineticaFunctions.cs.

◆ hasTable() [1/2]

HasTableResponse kinetica.Kinetica.hasTable ( HasTableRequest  request_)
inline

Checks for the existence of a table with the given name.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7474 of file KineticaFunctions.cs.

◆ hasTable() [2/2]

HasTableResponse kinetica.Kinetica.hasTable ( string  table_name,
IDictionary< string, string >  options = null 
)
inline

Checks for the existence of a table with the given name.

Parameters
table_nameName of the table to check for existence.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7493 of file KineticaFunctions.cs.

◆ hasType() [1/2]

HasTypeResponse kinetica.Kinetica.hasType ( HasTypeRequest  request_)
inline

Check for the existence of a type.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7508 of file KineticaFunctions.cs.

◆ hasType() [2/2]

HasTypeResponse kinetica.Kinetica.hasType ( string  type_id,
IDictionary< string, string >  options = null 
)
inline

Check for the existence of a type.

Parameters
type_idId of the type returned in response to /create/type request.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7526 of file KineticaFunctions.cs.

◆ insertRecords< T >() [1/2]

InsertRecordsResponse kinetica.Kinetica.insertRecords< T > ( InsertRecordsRequest< T >  request_)
inline

Adds multiple records to the specified table.

The operation is synchronous, meaning that a response will not be returned until all the records are fully inserted and available. The response payload provides the counts of the number of records actually inserted and/or updated, and can provide the unique identifier of each added record.
The parameter can be used to customize this function's behavior.
The update_on_existing_pk option specifies the record collision policy for inserting into a table with a primary key, but is ignored if no primary key exists.
The return_record_ids option indicates that the database should return the unique identifiers of inserted records.

Template Parameters
TThe type of object being added.
Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7593 of file KineticaFunctions.cs.

◆ insertRecords< T >() [2/2]

InsertRecordsResponse kinetica.Kinetica.insertRecords< T > ( string  table_name,
IList< T >  data,
IDictionary< string, string >  options = null 
)
inline

Adds multiple records to the specified table.

The operation is synchronous, meaning that a response will not be returned until all the records are fully inserted and available. The response payload provides the counts of the number of records actually inserted and/or updated, and can provide the unique identifier of each added record.
The options parameter can be used to customize this function's behavior.
The update_on_existing_pk option specifies the record collision policy for inserting into a table with a primary key, but is ignored if no primary key exists.
The return_record_ids option indicates that the database should return the unique identifiers of inserted records.

Template Parameters
TThe type of object being added.
Parameters
table_nameTable to which the records are to be added. Must be an existing table.
dataAn array of binary-encoded data for the records to be added. All records must be of the same type as that of the table. Empty array if is json.
optionsOptional parameters.
  • UPDATE_ON_EXISTING_PK: Specifies the record collision policy for inserting into a table with a primary key. If set to true, any existing table record with primary key values that match those of a record being inserted will be replaced by that new record. If set to false, any existing table record with primary key values that match those of a record being inserted will remain unchanged and the new record discarded. If the specified table does not have a primary key, then this option is ignored. Supported values: The default value is FALSE.
  • RETURN_RECORD_IDS: If true then return the internal record id along for each inserted record. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7687 of file KineticaFunctions.cs.

◆ insertRecordsRandom() [1/2]

InsertRecordsRandomResponse kinetica.Kinetica.insertRecordsRandom ( InsertRecordsRandomRequest  request_)
inline

Generates a specified number of random records and adds them to the given table.

There is an optional parameter that allows the user to customize the ranges of the column values. It also allows the user to specify linear profiles for some or all columns in which case linear values are generated rather than random ones. Only individual tables are supported for this operation.
This operation is synchronous, meaning that a response will not be returned until all random records are fully available.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7712 of file KineticaFunctions.cs.

◆ insertRecordsRandom() [2/2]

InsertRecordsRandomResponse kinetica.Kinetica.insertRecordsRandom ( string  table_name,
long  count,
IDictionary< string, IDictionary< string, double >>  options = null 
)
inline

Generates a specified number of random records and adds them to the given table.

There is an optional parameter that allows the user to customize the ranges of the column values. It also allows the user to specify linear profiles for some or all columns in which case linear values are generated rather than random ones. Only individual tables are supported for this operation.
This operation is synchronous, meaning that a response will not be returned until all random records are fully available.

Parameters
table_nameTable to which random records will be added. Must be an existing table. Also, must be an individual table, not a collection of tables, nor a view of a table.
countNumber of records to generate.
optionsOptional parameter to pass in specifications for the randomness of the values. This map is different from the options parameter of most other endpoints in that it is a map of string to map of string to doubles, while most others are maps of string to string. In this map, the top level keys represent which column's parameters are being specified, while the internal keys represents which parameter is being specified. These parameters take on different meanings depending on the type of the column. Below follows a more detailed description of the map:
  • SEED: If provided, the internal random number generator will be initialized with the given value. The minimum is 0. This allows for the same set of random numbers to be generated across invocation of this endpoint in case the user wants to repeat the test. Since , is a map of maps, we need an internal map to provide the seed value. For example, to pass 100 as the seed value through this parameter, you need something equivalent to: 'options' = {'seed': { 'value': 100 } }
    • VALUE: Pass the seed value here.
  • ALL: This key indicates that the specifications relayed in the internal map are to be applied to all columns of the records.
    • MIN: For numerical columns, the minimum of the generated values is set to this value. Default is -99999. For point, shape, and track columns, min for numeric 'x' and 'y' columns needs to be within [-180, 180] and [-90, 90], respectively. The default minimum possible values for these columns in such cases are -180.0 and -90.0. For the 'TIMESTAMP' column, the default minimum corresponds to Jan 1, 2010. For string columns, the minimum length of the randomly generated strings is set to this value (default is 0). If both minimum and maximum are provided, minimum must be less than or equal to max. Value needs to be within [0, 200]. If the min is outside the accepted ranges for strings columns and 'x' and 'y' columns for point/shape/track, then those parameters will not be set; however, an error will not be thrown in such a case. It is the responsibility of the user to use the all parameter judiciously.
    • MAX: For numerical columns, the maximum of the generated values is set to this value. Default is 99999. For point, shape, and track columns, max for numeric 'x' and 'y' columns needs to be within [-180, 180] and [-90, 90], respectively. The default minimum possible values for these columns in such cases are 180.0 and 90.0. For string columns, the maximum length of the randomly generated strings is set to this value (default is 200). If both minimum and maximum are provided, max must be greater than or equal to min. Value needs to be within [0, 200]. If the max is outside the accepted ranges for strings columns and 'x' and 'y' columns for point/shape/track, then those parameters will not be set; however, an error will not be thrown in such a case. It is the responsibility of the user to use the all parameter judiciously.
    • INTERVAL: If specified, generate values for all columns evenly spaced with the given interval value. If a max value is specified for a given column the data is randomly generated between min and max and decimated down to the interval. If no max is provided the data is linerally generated starting at the minimum value (instead of generating random data). For non-decimated string-type columns the interval value is ignored. Instead the values are generated following the pattern: 'attrname_creationIndex#', i.e. the column name suffixed with an underscore and a running counter (starting at 0). For string types with limited size (eg char4) the prefix is dropped. No nulls will be generated for nullable columns.
    • NULL_PERCENTAGE: If specified, then generate the given percentage of the count as nulls for all nullable columns. This option will be ignored for non-nullable columns. The value must be within the range [0, 1.0]. The default value is 5% (0.05).
    • CARDINALITY: If specified, limit the randomly generated values to a fixed set. Not allowed on a column with interval specified, and is not applicable to WKT or Track-specific columns. The value must be greater than 0. This option is disabled by default.
  • ATTR_NAME: Use the desired column name in place of attr_name, and set the following parameters for the column specified. This overrides any parameter set by all.
    • MIN: For numerical columns, the minimum of the generated values is set to this value. Default is -99999. For point, shape, and track columns, min for numeric 'x' and 'y' columns needs to be within [-180, 180] and [-90, 90], respectively. The default minimum possible values for these columns in such cases are -180.0 and -90.0. For the 'TIMESTAMP' column, the default minimum corresponds to Jan 1, 2010. For string columns, the minimum length of the randomly generated strings is set to this value (default is 0). If both minimum and maximum are provided, minimum must be less than or equal to max. Value needs to be within [0, 200]. If the min is outside the accepted ranges for strings columns and 'x' and 'y' columns for point/shape/track, then those parameters will not be set; however, an error will not be thrown in such a case. It is the responsibility of the user to use the all parameter judiciously.
    • MAX: For numerical columns, the maximum of the generated values is set to this value. Default is 99999. For point, shape, and track columns, max for numeric 'x' and 'y' columns needs to be within [-180, 180] and [-90, 90], respectively. The default minimum possible values for these columns in such cases are 180.0 and 90.0. For string columns, the maximum length of the randomly generated strings is set to this value (default is 200). If both minimum and maximum are provided, max must be greater than or equal to min. Value needs to be within [0, 200]. If the max is outside the accepted ranges for strings columns and 'x' and 'y' columns for point/shape/track, then those parameters will not be set; however, an error will not be thrown in such a case. It is the responsibility of the user to use the all parameter judiciously.
    • INTERVAL: If specified, generate values for all columns evenly spaced with the given interval value. If a max value is specified for a given column the data is randomly generated between min and max and decimated down to the interval. If no max is provided the data is linerally generated starting at the minimum value (instead of generating random data). For non-decimated string-type columns the interval value is ignored. Instead the values are generated following the pattern: 'attrname_creationIndex#', i.e. the column name suffixed with an underscore and a running counter (starting at 0). For string types with limited size (eg char4) the prefix is dropped. No nulls will be generated for nullable columns.
    • NULL_PERCENTAGE: If specified and if this column is nullable, then generate the given percentage of the count as nulls. This option will result in an error if the column is not nullable. The value must be within the range [0, 1.0]. The default value is 5% (0.05).
    • CARDINALITY: If specified, limit the randomly generated values to a fixed set. Not allowed on a column with interval specified, and is not applicable to WKT or Track-specific columns. The value must be greater than 0. This option is disabled by default.
  • TRACK_LENGTH: This key-map pair is only valid for track data sets (an error is thrown otherwise). No nulls would be generated for nullable columns.
    • MIN: Minimum possible length for generated series; default is 100 records per series. Must be an integral value within the range [1, 500]. If both min and max are specified, min must be less than or equal to max.
    • MAX: Maximum possible length for generated series; default is 500 records per series. Must be an integral value within the range [1, 500]. If both min and max are specified, max must be greater than or equal to min.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 7963 of file KineticaFunctions.cs.

◆ insertRecordsRaw()

InsertRecordsResponse kinetica.Kinetica.insertRecordsRaw ( RawInsertRecordsRequest  request_)
inline

Adds multiple records to the specified table.

The operation is synchronous, meaning that a response will not be returned until all the records are fully inserted and available. The response payload provides the counts of the number of records actually inserted and/or updated, and can provide the unique identifier of each added record.
The parameter can be used to customize this function's behavior.
The update_on_existing_pk option specifies the record collision policy for inserting into a table with a primary key, but is ignored if no primary key exists.
The return_record_ids option indicates that the database should return the unique identifiers of inserted records.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7558 of file KineticaFunctions.cs.

◆ insertSymbol() [1/2]

InsertSymbolResponse kinetica.Kinetica.insertSymbol ( InsertSymbolRequest  request_)
inline

Adds a symbol or icon (i.e.

an image) to represent data points when data is rendered visually. Users must provide the symbol identifier (string), a format (currently supported: 'svg' and 'svg_path'), the data for the symbol, and any additional optional parameter (e.g. color). To have a symbol used for rendering create a table with a string column named 'SYMBOLCODE' (along with 'x' or 'y' for example). Then when the table is rendered (via WMS) if the 'dosymbology' parameter is 'true' then the value of the 'SYMBOLCODE' column is used to pick the symbol displayed for each point.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 7990 of file KineticaFunctions.cs.

◆ insertSymbol() [2/2]

InsertSymbolResponse kinetica.Kinetica.insertSymbol ( string  symbol_id,
string  symbol_format,
byte []  symbol_data,
IDictionary< string, string >  options = null 
)
inline

Adds a symbol or icon (i.e.

an image) to represent data points when data is rendered visually. Users must provide the symbol identifier (string), a format (currently supported: 'svg' and 'svg_path'), the data for the symbol, and any additional optional parameter (e.g. color). To have a symbol used for rendering create a table with a string column named 'SYMBOLCODE' (along with 'x' or 'y' for example). Then when the table is rendered (via WMS) if the 'dosymbology' parameter is 'true' then the value of the 'SYMBOLCODE' column is used to pick the symbol displayed for each point.

Parameters
symbol_idThe id of the symbol being added. This is the same id that should be in the 'SYMBOLCODE' column for objects using this symbol
symbol_formatSpecifies the symbol format. Must be either 'svg' or 'svg_path'. Supported values:
symbol_dataThe actual symbol data. If is 'svg' then this should be the raw bytes representing an svg file. If is svg path then this should be an svg path string, for example: 'M25.979,12.896,5.979,12.896,5.979,19.562,25.979,19.562z'
optionsOptional parameters.
  • COLOR: If is 'svg' this is ignored. If is 'svg_path' then this option specifies the color (in RRGGBB hex format) of the path. For example, to have the path rendered in red, used 'FF0000'. If 'color' is not provided then '00FF00' (i.e. green) is used by default.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8051 of file KineticaFunctions.cs.

◆ killProc() [1/2]

KillProcResponse kinetica.Kinetica.killProc ( KillProcRequest  request_)
inline

Kills a running proc instance.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8069 of file KineticaFunctions.cs.

◆ killProc() [2/2]

KillProcResponse kinetica.Kinetica.killProc ( string  run_id = "",
IDictionary< string, string >  options = null 
)
inline

Kills a running proc instance.

Parameters
run_idThe run ID of the running proc instance. If the run ID is not found or the proc instance has already completed, this does nothing. If not specified, all running proc instances will be killed. The default value is ''.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8089 of file KineticaFunctions.cs.

◆ lockTable() [1/2]

LockTableResponse kinetica.Kinetica.lockTable ( LockTableRequest  request_)
inline

Manages global access to a table's data.

By default a table has a of read_write, indicating all operations are permitted. A user may request a read_only or a write_only lock, after which only read or write operations, respectively, are permitted on the table until the lock is removed. When is no_access then no operations are permitted on the table. The lock status can be queried by setting to status.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8113 of file KineticaFunctions.cs.

◆ lockTable() [2/2]

LockTableResponse kinetica.Kinetica.lockTable ( string  table_name,
string  lock_type = LockTableRequest.LockType.STATUS,
IDictionary< string, string >  options = null 
)
inline

Manages global access to a table's data.

By default a table has a lock_type of read_write, indicating all operations are permitted. A user may request a read_only or a write_only lock, after which only read or write operations, respectively, are permitted on the table until the lock is removed. When lock_type is no_access then no operations are permitted on the table. The lock status can be queried by setting lock_type to status.

Parameters
table_nameName of the table to be locked. It must be a currently existing table, collection, or view.
lock_typeThe type of lock being applied to the table. Setting it to status will return the current lock status of the table without changing it. Supported values: The default value is STATUS.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8172 of file KineticaFunctions.cs.

◆ mergeRecords() [1/2]

MergeRecordsResponse kinetica.Kinetica.mergeRecords ( MergeRecordsRequest  request_)
inline

Create a new empty result table (specified by ), and insert all records from source tables (specified by ) based on the field mapping information (specified by ).


For merge records details and examples, see Merge Records. For limitations, see Merge Records Limitations and Cautions.
The field map (specified by ) holds the user-specified maps of target table column names to source table columns. The array of must match one-to-one with the , e.g., there's a map present in for each table listed in .

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8209 of file KineticaFunctions.cs.

◆ mergeRecords() [2/2]

MergeRecordsResponse kinetica.Kinetica.mergeRecords ( string  table_name,
IList< string >  source_table_names,
IList< IDictionary< string, string >>  field_maps,
IDictionary< string, string >  options = null 
)
inline

Create a new empty result table (specified by table_name ), and insert all records from source tables (specified by source_table_names ) based on the field mapping information (specified by field_maps ).


For merge records details and examples, see Merge Records. For limitations, see Merge Records Limitations and Cautions.
The field map (specified by field_maps ) holds the user-specified maps of target table column names to source table columns. The array of field_maps must match one-to-one with the source_table_names , e.g., there's a map present in field_maps for each table listed in source_table_names .

Parameters
table_nameThe new result table name for the records to be merged. Must NOT be an existing table.
source_table_namesThe list of source table names to get the records from. Must be existing table names.
field_mapsContains a list of source/target column mappings, one mapping for each source table listed in being merged into the target table specified by . Each mapping contains the target column names (as keys) that the data in the mapped source columns or column expressions (as values) will be merged into. All of the source columns being merged into a given target column must match in type, as that type will determine the type of the new target column.
optionsOptional parameters.
  • COLLECTION_NAME: Name of a collection which is to contain the newly created merged table specified by . If the collection provided is non-existent, the collection will be automatically created. If empty, then the newly created merged table will be a top-level table.
  • IS_REPLICATED: Indicates the distribution scheme for the data of the merged table specified in . If true, the table will be replicated. If false, the table will be randomly sharded. Supported values: The default value is FALSE.
  • TTL: Sets the TTL of the merged table specified in .
  • PERSIST: If true, then the table specified in will be persisted and will not expire unless a ttl is specified. If false, then the table will be an in-memory table and will expire unless a ttl is specified otherwise. Supported values: The default value is TRUE.
  • CHUNK_SIZE: Indicates the chunk size to be used for the merged table specified in .
  • VIEW_ID: view this result table is part of. The default value is ''.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8338 of file KineticaFunctions.cs.

◆ revokePermissionSystem() [1/2]

RevokePermissionSystemResponse kinetica.Kinetica.revokePermissionSystem ( RevokePermissionSystemRequest  request_)
inline

Revokes a system-level permission from a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8388 of file KineticaFunctions.cs.

◆ revokePermissionSystem() [2/2]

RevokePermissionSystemResponse kinetica.Kinetica.revokePermissionSystem ( string  name,
string  permission,
IDictionary< string, string >  options = null 
)
inline

Revokes a system-level permission from a user or role.

Parameters
nameName of the user or role from which the permission will be revoked. Must be an existing user or role.
permissionPermission to revoke from the user or role. Supported values:
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8430 of file KineticaFunctions.cs.

◆ revokePermissionTable() [1/2]

RevokePermissionTableResponse kinetica.Kinetica.revokePermissionTable ( RevokePermissionTableRequest  request_)
inline

Revokes a table-level permission from a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8449 of file KineticaFunctions.cs.

◆ revokePermissionTable() [2/2]

RevokePermissionTableResponse kinetica.Kinetica.revokePermissionTable ( string  name,
string  permission,
string  table_name,
IDictionary< string, string >  options = null 
)
inline

Revokes a table-level permission from a user or role.

Parameters
nameName of the user or role from which the permission will be revoked. Must be an existing user or role.
permissionPermission to revoke from the user or role. Supported values:
table_nameName of the table to which the permission grants access. Must be an existing table, collection, or view.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8503 of file KineticaFunctions.cs.

◆ revokeRole() [1/2]

RevokeRoleResponse kinetica.Kinetica.revokeRole ( RevokeRoleRequest  request_)
inline

Revokes membership in a role from a user or role.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8524 of file KineticaFunctions.cs.

◆ revokeRole() [2/2]

RevokeRoleResponse kinetica.Kinetica.revokeRole ( string  role,
string  member,
IDictionary< string, string >  options = null 
)
inline

Revokes membership in a role from a user or role.

Parameters
roleName of the role in which membership will be revoked. Must be an existing role.
memberName of the user or role that will be revoked membership in . Must be an existing user or role.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8546 of file KineticaFunctions.cs.

◆ SetKineticaSourceClassToTypeMapping()

void kinetica.Kinetica.SetKineticaSourceClassToTypeMapping ( Type  objectType,
KineticaType  kineticaType 
)
inline

Saves an object class type to a KineticaType association.

If the class type already exists in the map, replaces the old KineticaType value.

Parameters
objectTypeThe type of the object.
kineticaTypeThe associated KinetiaType object.

Definition at line 184 of file Kinetica.cs.

◆ showProc() [1/2]

ShowProcResponse kinetica.Kinetica.showProc ( ShowProcRequest  request_)
inline

Shows information about a proc.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8562 of file KineticaFunctions.cs.

◆ showProc() [2/2]

ShowProcResponse kinetica.Kinetica.showProc ( string  proc_name = "",
IDictionary< string, string >  options = null 
)
inline

Shows information about a proc.

Parameters
proc_nameName of the proc to show information about. If specified, must be the name of a currently existing proc. If not specified, information about all procs will be returned. The default value is ''.
optionsOptional parameters.
  • INCLUDE_FILES: If set to true, the files that make up the proc will be returned. If set to false, the files will not be returned. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8604 of file KineticaFunctions.cs.

◆ showProcStatus() [1/2]

ShowProcStatusResponse kinetica.Kinetica.showProcStatus ( ShowProcStatusRequest  request_)
inline

Shows the statuses of running or completed proc instances.

Results are grouped by run ID (as returned from Kinetica.executeProc(string,IDictionary<string, string>,IDictionary<string, byte[]>,IList<string>,IDictionary<string, IList<string>>,IList<string>,IDictionary<string, string>)) and data segment ID (each invocation of the proc command on a data segment is assigned a data segment ID).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8623 of file KineticaFunctions.cs.

◆ showProcStatus() [2/2]

ShowProcStatusResponse kinetica.Kinetica.showProcStatus ( string  run_id = "",
IDictionary< string, string >  options = null 
)
inline

Shows the statuses of running or completed proc instances.

Results are grouped by run ID (as returned from Kinetica.executeProc(string,IDictionary<string, string>,IDictionary<string, byte[]>,IList<string>,IDictionary<string, IList<string>>,IList<string>,IDictionary<string, string>)) and data segment ID (each invocation of the proc command on a data segment is assigned a data segment ID).

Parameters
run_idThe run ID of a specific running or completed proc instance for which the status will be returned. If the run ID is not found, nothing will be returned. If not specified, the statuses of all running and completed proc instances will be returned. The default value is ''.
optionsOptional parameters.
  • CLEAR_COMPLETE: If set to true, if a proc instance has completed (either successfully or unsuccessfully) then its status will be cleared and no longer returned in subsequent calls. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8670 of file KineticaFunctions.cs.

◆ showSecurity() [1/2]

ShowSecurityResponse kinetica.Kinetica.showSecurity ( ShowSecurityRequest  request_)
inline

Shows security information relating to users and/or roles.

If the caller is not a system administrator, only information relating to the caller and their roles is returned.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8687 of file KineticaFunctions.cs.

◆ showSecurity() [2/2]

ShowSecurityResponse kinetica.Kinetica.showSecurity ( IList< string >  names,
IDictionary< string, string >  options = null 
)
inline

Shows security information relating to users and/or roles.

If the caller is not a system administrator, only information relating to the caller and their roles is returned.

Parameters
namesA list of names of users and/or roles about which security information is requested. If none are provided, information about all users and roles will be returned.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8708 of file KineticaFunctions.cs.

◆ showSystemProperties() [1/2]

ShowSystemPropertiesResponse kinetica.Kinetica.showSystemProperties ( ShowSystemPropertiesRequest  request_)
inline

Returns server configuration and version related information to the caller.

The admin tool uses it to present server related information to the user.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8725 of file KineticaFunctions.cs.

◆ showSystemProperties() [2/2]

ShowSystemPropertiesResponse kinetica.Kinetica.showSystemProperties ( IDictionary< string, string >  options = null)
inline

Returns server configuration and version related information to the caller.

The admin tool uses it to present server related information to the user.

Parameters
optionsOptional parameters.
  • PROPERTIES: A list of comma separated names of properties requested. If not specified, all properties will be returned.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8752 of file KineticaFunctions.cs.

◆ showSystemStatus() [1/2]

ShowSystemStatusResponse kinetica.Kinetica.showSystemStatus ( ShowSystemStatusRequest  request_)
inline

Provides server configuration and health related status to the caller.

The admin tool uses it to present server related information to the user.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8768 of file KineticaFunctions.cs.

◆ showSystemStatus() [2/2]

ShowSystemStatusResponse kinetica.Kinetica.showSystemStatus ( IDictionary< string, string >  options = null)
inline

Provides server configuration and health related status to the caller.

The admin tool uses it to present server related information to the user.

Parameters
optionsOptional parameters, currently unused. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8786 of file KineticaFunctions.cs.

◆ showSystemTiming() [1/2]

ShowSystemTimingResponse kinetica.Kinetica.showSystemTiming ( ShowSystemTimingRequest  request_)
inline

Returns the last 100 database requests along with the request timing and internal job id.

The admin tool uses it to present request timing information to the user.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8802 of file KineticaFunctions.cs.

◆ showSystemTiming() [2/2]

ShowSystemTimingResponse kinetica.Kinetica.showSystemTiming ( IDictionary< string, string >  options = null)
inline

Returns the last 100 database requests along with the request timing and internal job id.

The admin tool uses it to present request timing information to the user.

Parameters
optionsOptional parameters, currently unused. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 8820 of file KineticaFunctions.cs.

◆ showTable() [1/2]

ShowTableResponse kinetica.Kinetica.showTable ( ShowTableRequest  request_)
inline

Retrieves detailed information about tables, views, and collections.


If specifies a table or view, information specific to that entity will be returned.
If specifies a collection, the call can return information about either the collection itself (setting the show_children option to false) or the tables and views it contains (setting show_children to true).
If is empty, information about all collections and top-level tables and views can be returned. Note: show_children must be set to true.
If is '*', information about all tables, collections, and views will be returned. Note: show_children must be set to true.
If the option get_sizes is set to true, then the sizes (objects and elements) of each table are returned (in and ), along with the total number of objects in the requested table (in and ).

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 8862 of file KineticaFunctions.cs.

◆ showTable() [2/2]

ShowTableResponse kinetica.Kinetica.showTable ( string  table_name,
IDictionary< string, string >  options = null 
)
inline

Retrieves detailed information about tables, views, and collections.


If table_name specifies a table or view, information specific to that entity will be returned.
If table_name specifies a collection, the call can return information about either the collection itself (setting the show_children option to false) or the tables and views it contains (setting show_children to true).
If table_name is empty, information about all collections and top-level tables and views can be returned. Note: show_children must be set to true.
If table_name is '*', information about all tables, collections, and views will be returned. Note: show_children must be set to true.
If the option get_sizes is set to true, then the sizes (objects and elements) of each table are returned (in and ), along with the total number of objects in the requested table (in and ).

Parameters
table_nameName of the table for which to retrieve the information. If blank, then information about all collections and top-level tables and views is returned.
optionsOptional parameters.
  • FORCE_SYNCHRONOUS: If true then the table sizes will wait for read lock before returning. Supported values: The default value is TRUE.
  • GET_SIZES: If true then the table sizes will be returned; blank, otherwise. Supported values: The default value is FALSE.
  • SHOW_CHILDREN: If is a collection, then true will return information about the children of the collection, while false will return information about the collection itself. If is empty or '*', then show_children must be true (or not specified); otherwise, no results will be returned. Supported values: The default value is TRUE.
  • NO_ERROR_IF_NOT_EXISTS: If false will return an error if the provided does not exist. If true then it will return an empty result. Supported values: The default value is FALSE.
  • GET_COLUMN_INFO: If true then column info (memory usage, etc) will be returned. Supported values: The default value is FALSE.
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9019 of file KineticaFunctions.cs.

◆ showTableMetadata() [1/2]

ShowTableMetadataResponse kinetica.Kinetica.showTableMetadata ( ShowTableMetadataRequest  request_)
inline

Retrieves the user provided metadata for the specified tables.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9035 of file KineticaFunctions.cs.

◆ showTableMetadata() [2/2]

ShowTableMetadataResponse kinetica.Kinetica.showTableMetadata ( IList< string >  table_names,
IDictionary< string, string >  options = null 
)
inline

Retrieves the user provided metadata for the specified tables.

Parameters
table_namesTables whose metadata will be fetched. All provided tables must exist, or an error is returned.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9054 of file KineticaFunctions.cs.

◆ showTablesByType() [1/2]

ShowTablesByTypeResponse kinetica.Kinetica.showTablesByType ( ShowTablesByTypeRequest  request_)
inline

Gets names of the tables whose type matches the given criteria.

Each table has a particular type. This type comprises the schema and properties of the table and sometimes a type label. This function allows a look up of the existing tables based on full or partial type information. The operation is synchronous.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9073 of file KineticaFunctions.cs.

◆ showTablesByType() [2/2]

ShowTablesByTypeResponse kinetica.Kinetica.showTablesByType ( string  type_id,
string  label,
IDictionary< string, string >  options = null 
)
inline

Gets names of the tables whose type matches the given criteria.

Each table has a particular type. This type comprises the schema and properties of the table and sometimes a type label. This function allows a look up of the existing tables based on full or partial type information. The operation is synchronous.

Parameters
type_idType id returned by a call to /create/type.
labelOptional user supplied label which can be used instead of the type_id to retrieve all tables with the given label.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9098 of file KineticaFunctions.cs.

◆ showTriggers() [1/2]

ShowTriggersResponse kinetica.Kinetica.showTriggers ( ShowTriggersRequest  request_)
inline

Retrieves information regarding the specified triggers or all existing triggers currently active.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9115 of file KineticaFunctions.cs.

◆ showTriggers() [2/2]

ShowTriggersResponse kinetica.Kinetica.showTriggers ( IList< string >  trigger_ids,
IDictionary< string, string >  options = null 
)
inline

Retrieves information regarding the specified triggers or all existing triggers currently active.

Parameters
trigger_idsList of IDs of the triggers whose information is to be retrieved. An empty list means information will be retrieved on all active triggers.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9135 of file KineticaFunctions.cs.

◆ showTypes() [1/2]

ShowTypesResponse kinetica.Kinetica.showTypes ( ShowTypesRequest  request_)
inline

Retrieves information for the specified data type ID or type label.

For all data types that match the input criteria, the database returns the type ID, the type schema, the label (if available), and the type's column properties.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9153 of file KineticaFunctions.cs.

◆ showTypes() [2/2]

ShowTypesResponse kinetica.Kinetica.showTypes ( string  type_id,
string  label,
IDictionary< string, string >  options = null 
)
inline

Retrieves information for the specified data type ID or type label.

For all data types that match the input criteria, the database returns the type ID, the type schema, the label (if available), and the type's column properties.

Parameters
type_idType Id returned in response to a call to /create/type.
labelOption string that was supplied by user in a call to /create/type.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9206 of file KineticaFunctions.cs.

◆ updateRecords< T >() [1/2]

UpdateRecordsResponse kinetica.Kinetica.updateRecords< T > ( UpdateRecordsRequest< T >  request_)
inline

Runs multiple predicate-based updates in a single call.

With the list of given expressions, any matching record's column values will be updated as provided in . There is also an optional 'upsert' capability where if a particular predicate doesn't match any existing record, then a new record can be inserted.
Note that this operation can only be run on an original table and not on a collection or a result view.
This operation can update primary key values. By default only 'pure primary key' predicates are allowed when updating primary key values. If the primary key for a table is the column 'attr1', then the operation will only accept predicates of the form: "attr1 == 'foo'" if the attr1 column is being updated. For a composite primary key (e.g. columns 'attr1' and 'attr2') then this operation will only accept predicates of the form: "(attr1 == 'foo') and (attr2 == 'bar')". Meaning, all primary key columns must appear in an equality predicate in the expressions. Furthermore each 'pure primary key' predicate must be unique within a given request. These restrictions can be removed by utilizing some available options through .

Template Parameters
TThe type of object being added.
Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9286 of file KineticaFunctions.cs.

◆ updateRecords< T >() [2/2]

UpdateRecordsResponse kinetica.Kinetica.updateRecords< T > ( string  table_name,
IList< string >  expressions,
IList< IDictionary< string, string >>  new_values_maps,
IList< T >  data = null,
IDictionary< string, string >  options = null 
)
inline

Runs multiple predicate-based updates in a single call.

With the list of given expressions, any matching record's column values will be updated as provided in new_values_maps . There is also an optional 'upsert' capability where if a particular predicate doesn't match any existing record, then a new record can be inserted.
Note that this operation can only be run on an original table and not on a collection or a result view.
This operation can update primary key values. By default only 'pure primary key' predicates are allowed when updating primary key values. If the primary key for a table is the column 'attr1', then the operation will only accept predicates of the form: "attr1 == 'foo'" if the attr1 column is being updated. For a composite primary key (e.g. columns 'attr1' and 'attr2') then this operation will only accept predicates of the form: "(attr1 == 'foo') and (attr2 == 'bar')". Meaning, all primary key columns must appear in an equality predicate in the expressions. Furthermore each 'pure primary key' predicate must be unique within a given request. These restrictions can be removed by utilizing some available options through options .

Template Parameters
TThe type of object being added.
Parameters
table_nameTable to be updated. Must be a currently existing table and not a collection or view.
expressionsA list of the actual predicates, one for each update; format should follow the guidelines /filter.
new_values_mapsList of new values for the matching records. Each element is a map with (key, value) pairs where the keys are the names of the columns whose values are to be updated; the values are the new values. The number of elements in the list should match the length of .
dataAn optional list of new binary-avro encoded records to insert, one for each update. If one of does not yield a matching record to be updated, then the corresponding element from this list will be added to the table. The default value is an empty List.
optionsOptional parameters.
  • GLOBAL_EXPRESSION: An optional global expression to reduce the search space of the predicates listed in . The default value is ''.
  • BYPASS_SAFETY_CHECKS: When set to true, all predicates are available for primary key updates. Keep in mind that it is possible to destroy data in this case, since a single predicate may match multiple objects (potentially all of records of a table), and then updating all of those records to have the same primary key will, due to the primary key uniqueness constraints, effectively delete all but one of those updated records. Supported values: The default value is FALSE.
  • UPDATE_ON_EXISTING_PK: Can be used to customize behavior when the updated primary key value already exists as described in /insert/records. Supported values: The default value is FALSE.
  • USE_EXPRESSIONS_IN_NEW_VALUES_MAPS: When set to true, all new values in are considered as expression values. When set to false, all new values in are considered as constants. NOTE: When true, string constants will need to be quoted to avoid being evaluated as expressions. Supported values: The default value is FALSE.
  • RECORD_ID: ID of a single record to be updated (returned in the call to /insert/records or /get/records/fromcollection).
The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9432 of file KineticaFunctions.cs.

◆ updateRecordsBySeries() [1/2]

UpdateRecordsBySeriesResponse kinetica.Kinetica.updateRecordsBySeries ( UpdateRecordsBySeriesRequest  request_)
inline

Updates the view specified by to include full series (track) information from the for the series (tracks) present in the .

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9457 of file KineticaFunctions.cs.

◆ updateRecordsBySeries() [2/2]

UpdateRecordsBySeriesResponse kinetica.Kinetica.updateRecordsBySeries ( string  table_name,
string  world_table_name,
string  view_name = "",
IList< string >  reserved = null,
IDictionary< string, string >  options = null 
)
inline

Updates the view specified by table_name to include full series (track) information from the world_table_name for the series (tracks) present in the view_name .

Parameters
table_nameName of the view on which the update operation will be performed. Must be an existing view.
world_table_nameName of the table containing the complete series (track) information.
view_nameOptional name of the view containing the series (tracks) which have to be updated. The default value is ''.
reservedThe default value is an empty List.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 9485 of file KineticaFunctions.cs.

◆ updateRecordsRaw()

UpdateRecordsResponse kinetica.Kinetica.updateRecordsRaw ( RawUpdateRecordsRequest  request_)
inline

Runs multiple predicate-based updates in a single call.

With the list of given expressions, any matching record's column values will be updated as provided in . There is also an optional 'upsert' capability where if a particular predicate doesn't match any existing record, then a new record can be inserted.
Note that this operation can only be run on an original table and not on a collection or a result view.
This operation can update primary key values. By default only 'pure primary key' predicates are allowed when updating primary key values. If the primary key for a table is the column 'attr1', then the operation will only accept predicates of the form: "attr1 == 'foo'" if the attr1 column is being updated. For a composite primary key (e.g. columns 'attr1' and 'attr2') then this operation will only accept predicates of the form: "(attr1 == 'foo') and (attr2 == 'bar')". Meaning, all primary key columns must appear in an equality predicate in the expressions. Furthermore each 'pure primary key' predicate must be unique within a given request. These restrictions can be removed by utilizing some available options through .

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9245 of file KineticaFunctions.cs.

◆ visualizeImageChart() [1/2]

VisualizeImageChartResponse kinetica.Kinetica.visualizeImageChart ( VisualizeImageChartRequest  request_)
inline

Scatter plot is the only plot type currently supported.

A non-numeric column can be specified as x or y column and jitters can be added to them to avoid excessive overlapping. All color values must be in the format RRGGBB or AARRGGBB (to specify the alpha value). The image is contained in the field.

Parameters
request_Request object containing the parameters for the operation.
Returns
Response object containing the result of the operation.

Definition at line 9937 of file KineticaFunctions.cs.

◆ visualizeImageChart() [2/2]

VisualizeImageChartResponse kinetica.Kinetica.visualizeImageChart ( string  table_name,
IList< string >  x_column_names,
IList< string >  y_column_names,
double  min_x,
double  max_x,
double  min_y,
double  max_y,
int  width,
int  height,
string  bg_color,
IDictionary< string, IList< string >>  style_options,
IDictionary< string, string >  options = null 
)
inline

Scatter plot is the only plot type currently supported.

A non-numeric column can be specified as x or y column and jitters can be added to them to avoid excessive overlapping. All color values must be in the format RRGGBB or AARRGGBB (to specify the alpha value). The image is contained in the field.

Parameters
table_nameName of the table containing the data to be drawn as a chart.
x_column_namesNames of the columns containing the data mapped to the x axis of a chart.
y_column_namesNames of the columns containing the data mapped to the y axis of a chart.
min_xLower bound for the x column values. For non-numeric x column, each x column item is mapped to an integral value starting from 0.
max_xUpper bound for the x column values. For non-numeric x column, each x column item is mapped to an integral value starting from 0.
min_yLower bound for the y column values. For non-numeric y column, each y column item is mapped to an integral value starting from 0.
max_yUpper bound for the y column values. For non-numeric y column, each y column item is mapped to an integral value starting from 0.
widthWidth of the generated image in pixels.
heightHeight of the generated image in pixels.
bg_colorBackground color of the generated image.
style_optionsRendering style options for a chart.
  • POINTCOLOR: The color of points in the plot represented as a hexadecimal number. The default value is '0000FF'.
  • POINTSIZE: The size of points in the plot represented as number of pixels. The default value is '3'.
  • POINTSHAPE: The shape of points in the plot. Supported values: The default value is SQUARE.
  • CB_POINTCOLORS: Point color class break information consisting of three entries: class-break attribute, class-break values/ranges, and point color values. This option overrides the pointcolor option if both are provided. Class-break ranges are represented in the form of "min:max". Class-break values/ranges and point color values are separated by cb_delimiter, e.g. {"price", "20:30;30:40;40:50", "0xFF0000;0x00FF00;0x0000FF"}.
  • CB_POINTSIZES: Point size class break information consisting of three entries: class-break attribute, class-break values/ranges, and point size values. This option overrides the pointsize option if both are provided. Class-break ranges are represented in the form of "min:max". Class-break values/ranges and point size values are separated by cb_delimiter, e.g. {"states", "NY;TX;CA", "3;5;7"}.
  • CB_POINTSHAPES: Point shape class break information consisting of three entries: class-break attribute, class-break values/ranges, and point shape names. This option overrides the pointshape option if both are provided. Class-break ranges are represented in the form of "min:max". Class-break values/ranges and point shape names are separated by cb_delimiter, e.g. {"states", "NY;TX;CA", "circle;square;diamond"}.
  • CB_DELIMITER: A character or string which separates per-class values in a class-break style option string. The default value is ';'.
  • X_ORDER_BY: An expression or aggregate expression by which non-numeric x column values are sorted, e.g. "avg(price) descending".
  • Y_ORDER_BY: An expression or aggregate expression by which non-numeric y column values are sorted, e.g. "avg(price)", which defaults to "avg(price) ascending".
  • SCALE_TYPE_X: Type of x axis scale. Supported values:
    • NONE: No scale is applied to the x axis.
    • LOG: A base-10 log scale is applied to the x axis.
    The default value is NONE.
  • SCALE_TYPE_Y: Type of y axis scale. Supported values:
    • NONE: No scale is applied to the y axis.
    • LOG: A base-10 log scale is applied to the y axis.
    The default value is NONE.
  • MIN_MAX_SCALED: If this options is set to "false", this endpoint expects request's min/max values are not yet scaled. They will be scaled according to scale_type_x or scale_type_y for response. If this options is set to "true", this endpoint expects request's min/max values are already scaled according to scale_type_x/scale_type_y. Response's min/max values will be equal to request's min/max values. The default value is 'false'.
  • JITTER_X: Amplitude of horizontal jitter applied to non-numeric x column values. The default value is '0.0'.
  • JITTER_Y: Amplitude of vertical jitter applied to non-numeric y column values. The default value is '0.0'.
  • PLOT_ALL: If this options is set to "true", all non-numeric column values are plotted ignoring min_x, max_x, min_y and max_y parameters. The default value is 'false'.
optionsOptional parameters. The default value is an empty Dictionary.
Returns
Response object containing the result of the operation.

Definition at line 10168 of file KineticaFunctions.cs.

Member Data Documentation

◆ API_VERSION

const string kinetica.Kinetica.API_VERSION = "6.2.0.1"

Definition at line 19 of file KineticaFunctions.cs.

◆ END_OF_SET

const int kinetica.Kinetica.END_OF_SET = -9999

No Limit

Definition at line 45 of file Kinetica.cs.

Property Documentation

◆ ThreadCount

int kinetica.Kinetica.ThreadCount = false
getset

Thread Count

Definition at line 112 of file Kinetica.cs.

◆ Url

string kinetica.Kinetica.Url
get

URL for Kinetica Server (including "http:" and port) as a string

Definition at line 82 of file Kinetica.cs.

◆ URL

Uri kinetica.Kinetica.URL
get

URL for Kinetica Server (including "http:" and port)

Definition at line 87 of file Kinetica.cs.

◆ Username

string kinetica.Kinetica.Username
get

Optional: User Name for Kinetica security

Definition at line 92 of file Kinetica.cs.

◆ UseSnappy

bool kinetica.Kinetica.UseSnappy = null
getset

Use Snappy

Definition at line 107 of file Kinetica.cs.


The documentation for this class was generated from the following files: